endpoint

Documentation

Index

• type Manager
  • func NewManager(networkID int64, endpointID ksuid.KSUID, endpointName string, ...) *Manager
  • func NewManagerSimple() (*Manager, error)
  • func (m *Manager) EndpointID() ksuid.KSUID
  • func (m *Manager) EndpointName() string
  • func (m *Manager) Publish(topicName string, topicType string, expiry time.Duration, payload []byte) error
  • func (m *Manager) Start()
  • func (m *Manager) Stop()
  • func (m *Manager) Subscribe(topicName string, topicType string, onReceive func(*topics.Message)) error
  • func (m *Manager) Unsubscribe(topicName string) error

Types

type Manager

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

func NewManager

func NewManager(
	networkID int64,
	endpointID ksuid.KSUID,
	endpointName string,
	listenAddress *net.UDPAddr,
	discoveryListenAddress *net.UDPAddr,
	discoveryTargetAddress *net.UDPAddr,
	listenInterface string,
	discoveryRate time.Duration,
	discoveryRateTimeoutMultiplier float64,
	onAdded func(*types.Container),
	onRemoved func(*types.Container),
) *Manager

func NewManagerSimple

func NewManagerSimple() (*Manager, error)

func (*Manager) EndpointID

func (m *Manager) EndpointID() ksuid.KSUID

func (*Manager) EndpointName

func (m *Manager) EndpointName() string

func (*Manager) Publish

func (m *Manager) Publish(
	topicName string,
	topicType string,
	expiry time.Duration,
	payload []byte,
) error

func (*Manager) Start

func (m *Manager) Start()

func (*Manager) Stop

func (m *Manager) Stop()

func (*Manager) Subscribe

func (m *Manager) Subscribe(
	topicName string,
	topicType string,
	onReceive func(*topics.Message),
) error

func (*Manager) Unsubscribe

func (m *Manager) Unsubscribe(
	topicName string,
) error