sds

Documentation

Index

• type Handler
  • func NewHandler(config HandlerConfig) *Handler
  • func (h *Handler) DeltaSecrets(discovery_v2.SecretDiscoveryService_DeltaSecretsServer) error
  • func (h *Handler) FetchSecrets(ctx context.Context, req *api_v2.DiscoveryRequest) (*api_v2.DiscoveryResponse, error)
  • func (h *Handler) StreamSecrets(stream discovery_v2.SecretDiscoveryService_StreamSecretsServer) error
• type HandlerConfig
• type Manager

Types

type Handler

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

func NewHandler

func NewHandler(config HandlerConfig) *Handler

func (*Handler) DeltaSecrets

func (h *Handler) DeltaSecrets(discovery_v2.SecretDiscoveryService_DeltaSecretsServer) error

func (*Handler) FetchSecrets

func (h *Handler) FetchSecrets(ctx context.Context, req *api_v2.DiscoveryRequest) (*api_v2.DiscoveryResponse, error)

func (*Handler) StreamSecrets

func (h *Handler) StreamSecrets(stream discovery_v2.SecretDiscoveryService_StreamSecretsServer) error

type HandlerConfig

type HandlerConfig struct {
	Attestor          attestor.Attestor
	Manager           Manager
	Metrics           telemetry.Metrics
	Log               logrus.FieldLogger
	DefaultBundleName string
	DefaultSVIDName   string
}

type Manager

type Manager interface {
	SubscribeToCacheChanges(key cache.Selectors) cache.Subscriber
	FetchWorkloadUpdate(selectors []*common.Selector) *cache.WorkloadUpdate
}