service

Documentation

Index

• func ConsulPollLoop()
• type DispatchService
  • func GetDispatchService() *DispatchService
  • func (c *DispatchService) HandleACK(subscriber *model.EnvoySubscriber, req *v2.DiscoveryRequest)
• type RegisterService
  • func GetRegisterService() *RegisterService
  • func (c *RegisterService) DeleteSubscriber(subscriber *model.EnvoySubscriber)
  • func (c *RegisterService) RegisterEnvoy(ctx context.Context, stream XDSStreamServer, subscriber *model.EnvoySubscriber, ...)
  • func (c *RegisterService) RegisterEnvoyADS(ctx context.Context, stream XDSStreamServer, subscriber *model.EnvoySubscriber, ...)
• type V2HelperService
  • func (v *V2HelperService) GetTopicFor(typeUrl string) string
  • func (v *V2HelperService) GetTypeUrlFor(topic string) string
• type WatchService
  • func GetWatchService() *WatchService
• type XDSStreamServer

Functions

func ConsulPollLoop

func ConsulPollLoop()

Types

type DispatchService

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

func GetDispatchService

func GetDispatchService() *DispatchService

func (*DispatchService) HandleACK

func (c *DispatchService) HandleACK(subscriber *model.EnvoySubscriber, req *v2.DiscoveryRequest)

HandleACK check if the response is an ACK if not ignore if yes update the last updated version

type RegisterService

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

RegisterService a service class for cluster specific functionalities

func GetRegisterService

func GetRegisterService() *RegisterService

GetRegisterService get a singleton instance

func (*RegisterService) DeleteSubscriber

func (c *RegisterService) DeleteSubscriber(subscriber *model.EnvoySubscriber)

RemoveSubscriber Delete entry

func (*RegisterService) RegisterEnvoy

func (c *RegisterService) RegisterEnvoy(ctx context.Context,
	stream XDSStreamServer,
	subscriber *model.EnvoySubscriber, dispatchChannel chan model.ConfigMeta)

RegisterEnvoy register & subscribe new envoy instance

func (*RegisterService) RegisterEnvoyADS

func (c *RegisterService) RegisterEnvoyADS(ctx context.Context,
	stream XDSStreamServer,
	subscriber *model.EnvoySubscriber, dispatchChannel chan model.ConfigMeta)

type V2HelperService

type V2HelperService struct{}

func (*V2HelperService) GetTopicFor

func (v *V2HelperService) GetTopicFor(typeUrl string) string

func (*V2HelperService) GetTypeUrlFor

func (v *V2HelperService) GetTypeUrlFor(topic string) string

type WatchService

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

func GetWatchService

func GetWatchService() *WatchService

WatchService get a singleton instance

type XDSStreamServer

type XDSStreamServer interface {
	Send(*v2.DiscoveryResponse) error
	Recv() (*v2.DiscoveryRequest, error)
	Context() context.Context
}

XDSStreamServer common data type for xDS stream