package util

import "github.com/containerd/containerd/pkg/cri/util"

Index ¶

• func AlphaReqToV1Req( alphar protoreflect.ProtoMessage, v1r interface{ Unmarshal(_ []byte) error }, ) error
• func DeepCopy(dst interface{}, src interface{}) error
• func DeferContext() (context.Context, context.CancelFunc)
• func GenerateID() string
• func InStringSlice(ss []string, str string) bool
• func MergeStringSlices(a []string, b []string) []string
• func NamespacedContext() context.Context
• func SubtractStringSlice(ss []string, str string) []string
• func V1RespToAlphaResp( v1res interface{ Marshal() ([]byte, error) }, alphares protoreflect.ProtoMessage, ) error
• func WithNamespace(ctx context.Context) context.Context

Functions ¶

func AlphaReqToV1Req ¶

func AlphaReqToV1Req(
	alphar protoreflect.ProtoMessage,
	v1r interface{ Unmarshal(_ []byte) error },
) error

func DeepCopy ¶

func DeepCopy(dst interface{}, src interface{}) error

DeepCopy makes a deep copy from src into dst.

func DeferContext ¶

func DeferContext() (context.Context, context.CancelFunc)

DeferContext returns a context for containerd cleanup operations in defer. A default timeout is applied to avoid cleanup operation pending forever.

func GenerateID ¶

func GenerateID() string

GenerateID generates a random unique id.

func InStringSlice ¶

func InStringSlice(ss []string, str string) bool

InStringSlice checks whether a string is inside a string slice. Comparison is case insensitive.

func MergeStringSlices ¶

func MergeStringSlices(a []string, b []string) []string

MergeStringSlices merges 2 string slices into one and remove duplicated elements.

func NamespacedContext ¶

func NamespacedContext() context.Context

NamespacedContext returns a context with kubernetes namespace set.

func SubtractStringSlice ¶

func SubtractStringSlice(ss []string, str string) []string

SubtractStringSlice subtracts string from string slice. Comparison is case insensitive.

func V1RespToAlphaResp ¶

func V1RespToAlphaResp(
	v1res interface{ Marshal() ([]byte, error) },
	alphares protoreflect.ProtoMessage,
) error

func WithNamespace ¶

func WithNamespace(ctx context.Context) context.Context

WithNamespace adds kubernetes namespace to the context.

Source Files ¶

alpha.go deep_copy.go id.go strings.go util.go