service

package

v0.2.0 Latest Latest Go to latest Published: Oct 12, 2018 License: MIT Imports: 13 Imported by: 0

Documentation ¶

Index ¶

func ConsulPollLoop()
type DefaultPushService
- func GetDefaultPushService() *DefaultPushService
type V2HelperService
- func (v *V2HelperService) GetTopicFor(typeUrl string) string
- func (v *V2HelperService) GetTypeUrlFor(topic string) string
type XDSStreamServer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ConsulPollLoop ¶ added in v0.2.0

func ConsulPollLoop()

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) DeleteSubscriber ¶ added in v0.2.0

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

RemoveSubscriber Delete entry

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) IsOutdated2 ¶ added in v0.2.0

func (c *DefaultPushService) IsOutdated2(subscribedTopic string, lastVersion string) bool

func (*DefaultPushService) RegisterEnvoy ¶

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

RegisterEnvoy register & subscribe new envoy instance

func (*DefaultPushService) RegisterEnvoyADS ¶ added in v0.2.0

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

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

XDSStreamServer common data type for xDS stream

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL