service

Documentation

Index

• type DefaultPushService
  • func GetDefaultPushService() *DefaultPushService
  • func (c *DefaultPushService) HandleACK(subscriber *model.EnvoySubscriber, req *v2.DiscoveryRequest)
  • func (c *DefaultPushService) IsOutdated(en *model.EnvoySubscriber) bool
  • func (c *DefaultPushService) RegisterEnvoy(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 XDSStreamServer

Types

type DefaultPushService

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

DefaultPushService a service class for cluster specific functionalities

func GetDefaultPushService

func GetDefaultPushService() *DefaultPushService

GetDefaultPushService get a singleton instance

func (*DefaultPushService) HandleACK

func (c *DefaultPushService) 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

func (*DefaultPushService) IsOutdated

func (c *DefaultPushService) IsOutdated(en *model.EnvoySubscriber) bool

IsOutdated check if the last dispatched config is outdated

func (*DefaultPushService) RegisterEnvoy

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

RegisterEnvoy register & subscribe new envoy instance

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 XDSStreamServer

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

XDSStreamServer common data type for xDS stream