server

Documentation

Index

• type Callbacks
  • func NewCallbacks(s *subscription.Subscriber, l log.Logger) *Callbacks
  • func (cb *Callbacks) OnDeltaStreamClosed(id int64)
  • func (cb *Callbacks) OnDeltaStreamOpen(_ context.Context, id int64, typ string) error
  • func (cb *Callbacks) OnFetchRequest(_ context.Context, req *discovery.DiscoveryRequest) error
  • func (cb *Callbacks) OnFetchResponse(*discovery.DiscoveryRequest, *discovery.DiscoveryResponse)
  • func (cb *Callbacks) OnStreamClosed(id int64)
  • func (cb *Callbacks) OnStreamDeltaRequest(id int64, req *discovery.DeltaDiscoveryRequest) error
  • func (cb *Callbacks) OnStreamDeltaResponse(id int64, req *discovery.DeltaDiscoveryRequest, ...)
  • func (cb *Callbacks) OnStreamOpen(_ context.Context, id int64, typ string) error
  • func (cb *Callbacks) OnStreamRequest(id int64, req *discovery.DiscoveryRequest) error
  • func (cb *Callbacks) OnStreamResponse(context.Context, int64, *discovery.DiscoveryRequest, ...)
  • func (cb *Callbacks) Report()
  • func (cb *Callbacks) Stop()
• type SdsServer
  • func NewServer(awsRegion string, awsEndpoint string, l log.Logger) (*SdsServer, error)
  • func (s *SdsServer) Run(socketPath string) error

Types

type Callbacks

type Callbacks struct {
	Logger         log.Logger
	Signal         chan struct{}
	Fetches        int
	Requests       int
	DeltaRequests  int
	DeltaResponses int
	// contains filtered or unexported fields
}

func NewCallbacks

func NewCallbacks(s *subscription.Subscriber, l log.Logger) *Callbacks

func (*Callbacks) OnDeltaStreamClosed

func (cb *Callbacks) OnDeltaStreamClosed(id int64)

func (*Callbacks) OnDeltaStreamOpen

func (cb *Callbacks) OnDeltaStreamOpen(_ context.Context, id int64, typ string) error

func (*Callbacks) OnFetchRequest

func (cb *Callbacks) OnFetchRequest(_ context.Context, req *discovery.DiscoveryRequest) error

func (*Callbacks) OnFetchResponse

func (cb *Callbacks) OnFetchResponse(*discovery.DiscoveryRequest, *discovery.DiscoveryResponse)

func (*Callbacks) OnStreamClosed

func (cb *Callbacks) OnStreamClosed(id int64)

func (*Callbacks) OnStreamDeltaRequest

func (cb *Callbacks) OnStreamDeltaRequest(id int64, req *discovery.DeltaDiscoveryRequest) error

func (*Callbacks) OnStreamDeltaResponse

func (cb *Callbacks) OnStreamDeltaResponse(id int64, req *discovery.DeltaDiscoveryRequest, res *discovery.DeltaDiscoveryResponse)

func (*Callbacks) OnStreamOpen

func (cb *Callbacks) OnStreamOpen(_ context.Context, id int64, typ string) error

func (*Callbacks) OnStreamRequest

func (cb *Callbacks) OnStreamRequest(id int64, req *discovery.DiscoveryRequest) error

func (*Callbacks) OnStreamResponse

func (cb *Callbacks) OnStreamResponse(context.Context, int64, *discovery.DiscoveryRequest, *discovery.DiscoveryResponse)

func (*Callbacks) Report

func (cb *Callbacks) Report()

func (*Callbacks) Stop

func (cb *Callbacks) Stop()

type SdsServer

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

func NewServer

func NewServer(awsRegion string, awsEndpoint string, l log.Logger) (*SdsServer, error)

func (*SdsServer) Run

func (s *SdsServer) Run(socketPath string) error