criwrapper

Documentation

Index

• Variables
• type CriClient
  • func (rc *CriClient) Close()
  • func (rc *CriClient) Connect(ctx context.Context) error
  • func (rc *CriClient) GetContainerEnvVars(ctx context.Context, containerID string) (map[string]string, error)
  • func (rc *CriClient) GetContainerEnvVarsList(ctx context.Context, envVarKeys []string, containerID string) ([]odigosv1.EnvVar, error)
  • func (rc *CriClient) GetContainerInfo(ctx context.Context, containerID string) (map[string]string, error)

Variables

var (
	ErrDetectingCRIEndpoint          = errors.New("Unable to detect CRI runtime endpoint")
	ErrFailedToValidateCRIConnection = errors.New("Failed to validate CRI runtime connection")
)

Types

type CriClient

type CriClient struct {
	Logger logr.Logger
	// contains filtered or unexported fields
}

func (*CriClient) Close

func (rc *CriClient) Close()

Close closes the gRPC connection.

func (*CriClient) Connect

func (rc *CriClient) Connect(ctx context.Context) error

Connect attempts to establish a connection to a CRI runtime.

func (*CriClient) GetContainerEnvVars

func (rc *CriClient) GetContainerEnvVars(ctx context.Context, containerID string) (map[string]string, error)

func (*CriClient) GetContainerEnvVarsList

func (rc *CriClient) GetContainerEnvVarsList(ctx context.Context, envVarKeys []string, containerID string) ([]odigosv1.EnvVar, error)

func (*CriClient) GetContainerInfo

func (rc *CriClient) GetContainerInfo(ctx context.Context, containerID string) (map[string]string, error)

GetContainerInfo retrieves the "info" field of the specified container.