providers

package
v0.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 29, 2024 License: GPL-3.0 Imports: 21 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.