k8s

Documentation

Index

• Variables
• type ConnectionConfig
• type ContainerClient
  • func NewContainerClient(config ConnectionConfig, logger *slog.Logger) (*ContainerClient, error)
  • func (c *ContainerClient) Listener(ctx context.Context) (<-chan clients.ContainerImage, error)

Variables

var (
	ErrInformerCacheSync = errors.New("failed to synchronize informer cache")
)

Types

type ConnectionConfig

type ConnectionConfig struct {
	InClusterConfig        bool
	InformerResyncInterval time.Duration
	ImageCheckInterval     time.Duration
}

type ContainerClient

type ContainerClient struct {
	Config ConnectionConfig
	// contains filtered or unexported fields
}

func NewContainerClient

func NewContainerClient(config ConnectionConfig, logger *slog.Logger) (*ContainerClient, error)

func (*ContainerClient) Listener

func (c *ContainerClient) Listener(ctx context.Context) (<-chan clients.ContainerImage, error)