reconciler

type AsyncCommandNotificationStore interface {
	GetCommandResult(srcName types.NamespacedName, pod string, command message.AsyncCommand) *message.AsyncCommandResult
	CleanPodsNotifications(srcName types.NamespacedName)
	CleanPodNotification(srcName types.NamespacedName, pod string)
	MessageHandler(srcName types.NamespacedName, pod string) control.MessageHandler
}

type ControlPlaneConnectionPool interface {
	GetConnectedHosts(key string) []string
	GetServices(key string) map[string]control.Service
	ResolveControlInterface(key string, host string) (string, control.Service)
	RemoveConnection(ctx context.Context, key string, host string)
	RemoveAllConnections(ctx context.Context, key string)
	Close(ctx context.Context)
	ReconcileConnections(ctx context.Context, key string, wantConnections []string, newServiceCb func(string, control.Service), oldServiceCb func(string)) (map[string]control.Service, error)
	DialControlService(ctx context.Context, key string, host string) (string, control.Service, error)
}

type ControlPlaneConnectionPoolOption func(*controlPlaneConnectionPoolImpl)

type ListerCertificateGetter struct {
	// contains filtered or unexported fields
}

type NotificationStore struct {
	// contains filtered or unexported fields
}

type PayloadParser func([]byte) (interface{}, error)

type PodIpGetter struct {
	Lister v1.PodLister
}

type TLSDialerFactory interface {
	GenerateTLSDialer(baseDialOptions *net.Dialer) (*tls.Dialer, error)
}

type ValueMerger func(old interface{}, new interface{}) interface{}