sds

Documentation

Index

• Variables
• func CloseSdsClient()
• func NewSdsClientSingleton(cfg interface{}) types.SdsClient
• func RegisterSdsStreamClientFactory(f func(config interface{}) (SdsStreamClient, error))
• func SetSdsPostCallback(fc func())
• type SdsClientImpl
  • func (client *SdsClientImpl) AddUpdateCallback(name string, callback types.SdsUpdateCallbackFunc) error
  • func (client *SdsClientImpl) DeleteUpdateCallback(name string) error
  • func (client *SdsClientImpl) SetSecret(name string, secret *types.SdsSecret)
• type SdsStreamClient
  • func GetSdsStreamClient(config interface{}) (SdsStreamClient, error)
• type SdsSubscriber
  • func NewSdsSubscriber(provider types.SecretProvider, sdsConfig interface{}) *SdsSubscriber
  • func (subscribe *SdsSubscriber) SendSdsRequest(name string)
  • func (subscribe *SdsSubscriber) Start()
  • func (subscribe *SdsSubscriber) Stop()

Variables

var ErrSdsClientNotInit = errors.New("sds client not init")

var SubscriberRetryPeriod = 3 * time.Second

Functions

func CloseSdsClient

func CloseSdsClient()

func NewSdsClientSingleton

func NewSdsClientSingleton(cfg interface{}) types.SdsClient

TODO: support sds client index instead of singleton

func RegisterSdsStreamClientFactory

func RegisterSdsStreamClientFactory(f func(config interface{}) (SdsStreamClient, error))

func SetSdsPostCallback

func SetSdsPostCallback(fc func())

SetPostCallback

Types

type SdsClientImpl

type SdsClientImpl struct {
	SdsCallbackMap map[string]types.SdsUpdateCallbackFunc
	// contains filtered or unexported fields
}

func (*SdsClientImpl) AddUpdateCallback

func (client *SdsClientImpl) AddUpdateCallback(name string, callback types.SdsUpdateCallbackFunc) error

func (*SdsClientImpl) DeleteUpdateCallback

func (client *SdsClientImpl) DeleteUpdateCallback(name string) error

DeleteUpdateCallback

func (*SdsClientImpl) SetSecret

func (client *SdsClientImpl) SetSecret(name string, secret *types.SdsSecret)

SetSecret invoked when sds subscriber get secret response

type SdsStreamClient

type SdsStreamClient interface {
	// Send creates a secret discovery request with name, and send it to server
	Send(name string) error
	// Recv receive a secret discovert response, handle it and send a ack response
	Recv(provider types.SecretProvider, callback func()) error
	// Stop stops a stream client
	Stop()
}

func GetSdsStreamClient

func GetSdsStreamClient(config interface{}) (SdsStreamClient, error)

type SdsSubscriber

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

func NewSdsSubscriber

func NewSdsSubscriber(provider types.SecretProvider, sdsConfig interface{}) *SdsSubscriber

func (*SdsSubscriber) SendSdsRequest

func (subscribe *SdsSubscriber) SendSdsRequest(name string)

func (*SdsSubscriber) Start

func (subscribe *SdsSubscriber) Start()

func (*SdsSubscriber) Stop

func (subscribe *SdsSubscriber) Stop()