registration

Documentation

Index

• type ChoriaFramework
• type Connection
• type Manager
  • func New(c ChoriaFramework, si registration.ServerInfoSource, conn Connection, ...) *Manager
  • func (reg *Manager) RegisterProvider(ctx context.Context, wg *sync.WaitGroup, provider RegistrationDataProvider) error
  • func (reg *Manager) Start(ctx context.Context, wg *sync.WaitGroup) error
• type RegistrationDataProvider
• type Registrator

Types

type ChoriaFramework

type ChoriaFramework interface {
	NewMessage(payload []byte, agent string, collective string, msgType string, request inter.Message) (msg inter.Message, err error)
	Configuration() *config.Config
}

type Connection

type Connection interface {
	Publish(msg inter.Message) error
	IsConnected() bool
}

Connection provides the connection to the middleware

type Manager

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

Manager of registration plugins

func New

func New(c ChoriaFramework, si registration.ServerInfoSource, conn Connection, logger *logrus.Entry) *Manager

New creates a new instance of the registration subsystem manager

func (*Manager) RegisterProvider

func (reg *Manager) RegisterProvider(ctx context.Context, wg *sync.WaitGroup, provider RegistrationDataProvider) error

RegisterProvider creates a publisher for a new provider

func (*Manager) Start

func (reg *Manager) Start(ctx context.Context, wg *sync.WaitGroup) error

Start initializes the fully managed registration plugins and start publishing their data

type RegistrationDataProvider

type RegistrationDataProvider interface {
	StartRegistration(context.Context, *sync.WaitGroup, int, chan *data.RegistrationItem)
}

RegistrationDataProvider is a provider for data that can be registered into a running server instance using AddRegistrationProvider()

type Registrator

type Registrator interface {
	Init(cfg *config.Config, l *logrus.Entry)
	StartRegistration(context.Context, *sync.WaitGroup, int, chan *data.RegistrationItem)
}

Registrator is a full managed registration plugin