fds

Documentation

Index

• type ExportedServicesGenerator
  • func NewExportedServicesGenerator(cfg config.Federation, serviceLister v1.ServiceLister) *ExportedServicesGenerator
  • func (g *ExportedServicesGenerator) GenerateResponse() ([]*anypb.Any, error)
  • func (g *ExportedServicesGenerator) GetTypeUrl() string
• type ImportedServiceHandler
  • func NewImportedServiceHandler(store *ImportedServiceStore, pushRequests chan<- xds.PushRequest) *ImportedServiceHandler
  • func (h *ImportedServiceHandler) Handle(source string, resources []*anypb.Any) error
• type ImportedServiceStore
  • func NewImportedServiceStore() *ImportedServiceStore
  • func (s *ImportedServiceStore) From(remote config.Remote) []*v1alpha1.ExportedService
  • func (s *ImportedServiceStore) Update(importedServices map[string][]*v1alpha1.ExportedService)

Types

type ExportedServicesGenerator

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

func NewExportedServicesGenerator

func NewExportedServicesGenerator(cfg config.Federation, serviceLister v1.ServiceLister) *ExportedServicesGenerator

func (*ExportedServicesGenerator) GenerateResponse

func (g *ExportedServicesGenerator) GenerateResponse() ([]*anypb.Any, error)

func (*ExportedServicesGenerator) GetTypeUrl

func (g *ExportedServicesGenerator) GetTypeUrl() string

type ImportedServiceHandler

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

func NewImportedServiceHandler

func NewImportedServiceHandler(store *ImportedServiceStore, pushRequests chan<- xds.PushRequest) *ImportedServiceHandler

func (*ImportedServiceHandler) Handle

func (h *ImportedServiceHandler) Handle(source string, resources []*anypb.Any) error

type ImportedServiceStore

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

ImportedServiceStore is a thread-safe wrapper for current state of imported services

func NewImportedServiceStore

func NewImportedServiceStore() *ImportedServiceStore

func (*ImportedServiceStore) From

func (s *ImportedServiceStore) From(remote config.Remote) []*v1alpha1.ExportedService

From returns copy of all services exported from given remote peer.

func (*ImportedServiceStore) Update

func (s *ImportedServiceStore) Update(importedServices map[string][]*v1alpha1.ExportedService)