coordination

package

v0.0.0-...-6f38258 Latest Latest Go to latest Published: Mar 21, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type CommanderServer struct {
	sync.WaitGroup
	pb.UnimplementedCommandManagerServer
	DB *sql.DB
	CO *Coordinator
	ID string
}

func (c *CommanderServer) GetNodes(ctx context.Context, in *pb.NodeQuery) (*pb.NodeQueryResponse, error)

func (c *CommanderServer) SendCommandToNodes(ctx context.Context, cmd *pb.CommanderRequest) (*pb.AggregateResponses, error)

func (c *CommanderServer) SendCommandToNodesStream(cmd *commands.CommanderRequest, stream pb.CommandManager_SendCommandToNodesStreamServer) error

type Coordinator struct {
	connections.Tailnet
	services.DataManagement

	ID string
	// contains filtered or unexported fields
}

Coordinator holds the runtime variables for the coordination server

func (co *Coordinator) NewCoordinator(ctx context.Context, opts ...Option) error

NewCoordinator Create a new coordinator instance and set the provided options

func (co *Coordinator) StartDatabase(ctx context.Context) error

func (co *Coordinator) StartPingService(ctx context.Context)

func (co *Coordinator) StartRPCCoordinationServer(ctx context.Context) error

StartRPCCoordinationServer Register the gRPC server endpoints and start the server

func (co *Coordinator) WithDevMode(mode bool) Option

WithDevMode enable the server to run in dev mode

type Option func(co *Coordinator) error

Options defines the configuration options function for configuration injection

type RegistrationServer struct {
	pb.UnimplementedRegistrationServer
	DevMode  bool
	ID       string
	Hostname string
	DB       *sql.DB
}

RegistrationServer struct to contain proto for gRPC

func (r *RegistrationServer) Register(ctx context.Context, in *pb.NodeRegistrationRequest) (*pb.NodeRegistrationResponse, error)

Register registers a node with the database when a node sends a request. Returns the server id so the node can verify further requests