adsc

Documentation

Index

• type ADSC
  • func New(opts *ADSCConfig) (*ADSC, error)
  • func (a *ADSC) Restart(ctx context.Context)
  • func (a *ADSC) Run(ctx context.Context) error
• type ADSCConfig
• type ResponseHandler

Types

type ADSC

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

func New

func New(opts *ADSCConfig) (*ADSC, error)

func (*ADSC) Restart

func (a *ADSC) Restart(ctx context.Context)

func (*ADSC) Run

func (a *ADSC) Run(ctx context.Context) error

type ADSCConfig

type ADSCConfig struct {
	PeerName                 string
	DiscoveryAddr            string
	Authority                string
	InitialDiscoveryRequests []*discovery.DiscoveryRequest
	Handlers                 map[string]ResponseHandler
	ReconnectDelay           time.Duration
}

type ResponseHandler

type ResponseHandler interface {
	Handle(source string, resources []*anypb.Any) error
}

ResponseHandler handles response received from an XDS server.