Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
OneDiscoveryCyclePerServerErr = errors.New("Only one discovery cycle is allowed per server")
)
Functions ¶
This section is empty.
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 Resources ¶
type Resources struct {
// contains filtered or unexported fields
}
func NewResources ¶
func NewResources(logger *zap.SugaredLogger) *Resources
func (*Resources) ApplyService ¶
func (*Resources) DoSnapshot ¶
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
Source Files
Click to show internal directories.
Click to hide internal directories.