service_sync

Documentation

Index

• Constants
• type ServiceSync
  • func NewServiceSync(origin string, ttl time.Duration, version string, ...) *ServiceSync
  • func (c *ServiceSync) LocalDefinitionsUpdated(definitions map[string]types.ServiceInterface)
  • func (c *ServiceSync) Start(stopCh <-chan struct{})
• type ServiceUpdate
• type UpdateHandler

Constants

const (
	ServiceSyncAddress string = "mc/$skupper-service-sync"
)

const (
	ServiceSyncEvent string = "ServiceSyncEvent"
)

Types

type ServiceSync

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

func NewServiceSync

func NewServiceSync(origin string, ttl time.Duration, version string, connectionFactory messaging.ConnectionFactory, handler UpdateHandler, eventHandler event.EventHandlerInterface) *ServiceSync

func (*ServiceSync) LocalDefinitionsUpdated

func (c *ServiceSync) LocalDefinitionsUpdated(definitions map[string]types.ServiceInterface)

func (*ServiceSync) Start

func (c *ServiceSync) Start(stopCh <-chan struct{})

type ServiceUpdate

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

type UpdateHandler

type UpdateHandler func(changed []types.ServiceInterface, deleted []string, origin string) error