sds

Documentation

Index

• Variables
• func CloseSdsClient()
• func NewSdsClientSingleton(config *auth.SdsSecretConfig) types.SdsClient
• func SetSdsPostCallback(fc func())
• type SdsClientImpl
  • func (client *SdsClientImpl) AddUpdateCallback(sdsConfig *auth.SdsSecretConfig, callback types.SdsUpdateCallbackFunc) error
  • func (client *SdsClientImpl) DeleteUpdateCallback(sdsConfig *auth.SdsSecretConfig) error
  • func (client *SdsClientImpl) SetSecret(name string, secret *auth.Secret)
• type SdsStreamClient
• type SdsStreamConfig
• type SdsSubscriber
  • func NewSdsSubscriber(provider types.SecretProvider, sdsConfig *core.ConfigSource, ...) *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()

CloseSdsClientImpl used only mosn exit

func NewSdsClientSingleton

func NewSdsClientSingleton(config *auth.SdsSecretConfig) types.SdsClient

NewSdsClientSingleton use by tls module , when get sds config from xds

func SetSdsPostCallback

func SetSdsPostCallback(fc func())

SetPostCallback

Types

type SdsClientImpl

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

func (*SdsClientImpl) AddUpdateCallback

func (client *SdsClientImpl) AddUpdateCallback(sdsConfig *auth.SdsSecretConfig, callback types.SdsUpdateCallbackFunc) error

func (*SdsClientImpl) DeleteUpdateCallback

func (client *SdsClientImpl) DeleteUpdateCallback(sdsConfig *auth.SdsSecretConfig) error

DeleteUpdateCallback

func (*SdsClientImpl) SetSecret

func (client *SdsClientImpl) SetSecret(name string, secret *auth.Secret)

SetSecret invoked when sds subscriber get secret response

type SdsStreamClient

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

type SdsStreamConfig

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

type SdsSubscriber

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

func NewSdsSubscriber

func NewSdsSubscriber(provider types.SecretProvider, sdsConfig *core.ConfigSource, serviceNode string, serviceCluster string) *SdsSubscriber

func (*SdsSubscriber) SendSdsRequest

func (subscribe *SdsSubscriber) SendSdsRequest(name string)

func (*SdsSubscriber) Start

func (subscribe *SdsSubscriber) Start()

func (*SdsSubscriber) Stop

func (subscribe *SdsSubscriber) Stop()