sds

Documentation

Index

• func CreateSdsStreamClient(config interface{}) (sds.SdsStreamClient, error)
• type SdsStreamClientImpl
  • func (sc *SdsStreamClientImpl) AckResponse(resp interface{})
  • func (sc *SdsStreamClientImpl) Fetch(ctx context.Context, name string) (*types.SdsSecret, error)
  • func (sc *SdsStreamClientImpl) Recv(provider types.SecretProvider, callback func()) error
  • func (sc *SdsStreamClientImpl) Send(name string) error
  • func (sc *SdsStreamClientImpl) Stop()
• type SdsStreamConfig
  • func ConvertConfig(config interface{}) (SdsStreamConfig, error)

Functions

func CreateSdsStreamClient

func CreateSdsStreamClient(config interface{}) (sds.SdsStreamClient, error)

Types

type SdsStreamClientImpl

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

func (*SdsStreamClientImpl) AckResponse

func (sc *SdsStreamClientImpl) AckResponse(resp interface{})

func (*SdsStreamClientImpl) Fetch

func (sc *SdsStreamClientImpl) Fetch(ctx context.Context, name string) (*types.SdsSecret, error)

Fetch wraps a discovery request construct and will send a grpc request without grpc options.

func (*SdsStreamClientImpl) Recv

func (sc *SdsStreamClientImpl) Recv(provider types.SecretProvider, callback func()) error

func (*SdsStreamClientImpl) Send

func (sc *SdsStreamClientImpl) Send(name string) error

func (*SdsStreamClientImpl) Stop

func (sc *SdsStreamClientImpl) Stop()

type SdsStreamConfig

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

func ConvertConfig

func ConvertConfig(config interface{}) (SdsStreamConfig, error)