servicemesh

Documentation

Index

• Variables
• type EnvoyDiscoveryOptions
  • func (options *EnvoyDiscoveryOptions) NewServer(ctx context.Context, logger *zap.SugaredLogger) (*EnvoyDiscoveryServer, error)
• type EnvoyDiscoveryServer
  • func (e *EnvoyDiscoveryServer) Register(grpcServer *grpc.Server)
  • func (e *EnvoyDiscoveryServer) StartDiscoveryCycle() error
• type EnvoyDiscoveryService
• type Resources
  • func NewResources(logger *zap.SugaredLogger) *Resources
  • func (r *Resources) ApplyService(svc *sdapi.Service)
  • func (r *Resources) DoSnapshot(version int64) (*cache.Snapshot, error)
  • func (r *Resources) Hash() []byte
• type VirtualHostMap
  • func (v VirtualHostMap) MergeRoute(routeCfg *routev3.RouteConfiguration)
  • func (v VirtualHostMap) ToResourceSlice() []types.Resource

Variables

var (
	OneDiscoveryCyclePerServerErr = errors.New("Only one discovery cycle is allowed per server")
)

Types

type EnvoyDiscoveryOptions

type EnvoyDiscoveryOptions struct {
	NodeID                 string
	Services               []EnvoyDiscoveryService
	WatchInterval          time.Duration
	ServiceDiscoverTimeout time.Duration
}

func (*EnvoyDiscoveryOptions) NewServer

func (options *EnvoyDiscoveryOptions) NewServer(ctx context.Context, logger *zap.SugaredLogger) (*EnvoyDiscoveryServer, error)

type EnvoyDiscoveryServer

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

func (*EnvoyDiscoveryServer) Register

func (e *EnvoyDiscoveryServer) Register(grpcServer *grpc.Server)

func (*EnvoyDiscoveryServer) StartDiscoveryCycle

func (e *EnvoyDiscoveryServer) StartDiscoveryCycle() error

type EnvoyDiscoveryService

type EnvoyDiscoveryService interface {
	Discover(ctx context.Context, svcCh chan *sdapi.Service)
}

type Resources

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

func NewResources

func NewResources(logger *zap.SugaredLogger) *Resources

func (*Resources) ApplyService

func (r *Resources) ApplyService(svc *sdapi.Service)

func (*Resources) DoSnapshot

func (r *Resources) DoSnapshot(version int64) (*cache.Snapshot, error)

func (*Resources) Hash

func (r *Resources) Hash() []byte

type VirtualHostMap

type VirtualHostMap map[string]*virtualHost

func (VirtualHostMap) MergeRoute

func (v VirtualHostMap) MergeRoute(routeCfg *routev3.RouteConfiguration)

func (VirtualHostMap) ToResourceSlice

func (v VirtualHostMap) ToResourceSlice() []types.Resource