providers

Documentation

Index

• type Blueprint
• type CBLEServer
  • func NewServer(entClient *ent.Client, providersConfig *config.ProvidersConfig) *CBLEServer
  • func (ps *CBLEServer) Listen(ctx context.Context, wg *sync.WaitGroup)
  • func (ps *CBLEServer) QueueLoadProvider(id string)
  • func (ps *CBLEServer) QueueUnloadProvider(id string) error
  • func (ps *CBLEServer) RegisterProvider(ctx context.Context, request *cbleGRPC.RegistrationRequest) (*cbleGRPC.RegistrationReply, error)
  • func (ps *CBLEServer) RunAllProviders(ctx context.Context) error
  • func (ps *CBLEServer) RunProviderClients(ctx context.Context, wg *sync.WaitGroup)
  • func (ps *CBLEServer) RunProviderServers(ctx context.Context, wg *sync.WaitGroup)
  • func (ps *CBLEServer) UnregisterProvider(ctx context.Context, request *cbleGRPC.UnregistrationRequest) (*cbleGRPC.UnregistrationReply, error)
• type Object
• type RegisteredProvider

Types

type Blueprint

type Blueprint struct {
	Version string `yaml:"version"`
}

type CBLEServer

type CBLEServer struct {
	cbleGRPC.DefaultCBLEServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(entClient *ent.Client, providersConfig *config.ProvidersConfig) *CBLEServer

func (*CBLEServer) Listen

func (ps *CBLEServer) Listen(ctx context.Context, wg *sync.WaitGroup)

Listens on configured port. Runs in a go routine

func (*CBLEServer) QueueLoadProvider

func (ps *CBLEServer) QueueLoadProvider(id string)

func (*CBLEServer) QueueUnloadProvider

func (ps *CBLEServer) QueueUnloadProvider(id string) error

func (*CBLEServer) RegisterProvider

func (ps *CBLEServer) RegisterProvider(ctx context.Context, request *cbleGRPC.RegistrationRequest) (*cbleGRPC.RegistrationReply, error)

func (*CBLEServer) RunAllProviders

func (ps *CBLEServer) RunAllProviders(ctx context.Context) error

func (*CBLEServer) RunProviderClients

func (ps *CBLEServer) RunProviderClients(ctx context.Context, wg *sync.WaitGroup)

Runs all provider clients queued to connect. Runs in a go routine

func (*CBLEServer) RunProviderServers

func (ps *CBLEServer) RunProviderServers(ctx context.Context, wg *sync.WaitGroup)

Runs all provider servers queued to start. Runs in a go routine

func (*CBLEServer) UnregisterProvider

func (ps *CBLEServer) UnregisterProvider(ctx context.Context, request *cbleGRPC.UnregistrationRequest) (*cbleGRPC.UnregistrationReply, error)

type Object

type Object struct {
	Resource   string    `yaml:"resource"`
	Config     yaml.Node `yaml:"config"`
	DependsOn  []string  `yaml:"depends_on,omitempty"`
	RequiredBy []string  `yaml:"-"`
}

type RegisteredProvider

type RegisteredProvider struct {
	ID       string
	SocketID string
	Features *cbleGRPC.ProviderFeatures
}