node

package

v0.0.12 Latest Latest Go to latest Published: Jan 16, 2026 License: Apache-2.0 Imports: 24 Imported by: 0

Details

Package node

View Source

const Version string = "node/v1"

This section is empty.

This section is empty.

type NewServiceOption func(s *NodeService)

func WithExchange(e *events.Exchange) NewServiceOption

func WithLogger(l logger.Logger) NewServiceOption

type NodeService struct {
	nodesv1.UnimplementedNodeServiceServer
	// contains filtered or unexported fields
}

func NewService(repo repository.NodeRepository, opts ...NewServiceOption) *NodeService

func (n *NodeService) Connect(stream nodesv1.NodeService_ConnectServer) error

func (n *NodeService) Create(ctx context.Context, req *nodesv1.CreateRequest) (*nodesv1.CreateResponse, error)

func (n *NodeService) Delete(ctx context.Context, req *nodesv1.DeleteRequest) (*nodesv1.DeleteResponse, error)

func (n *NodeService) Forget(ctx context.Context, req *nodesv1.ForgetRequest) (*nodesv1.ForgetResponse, error)

func (n *NodeService) Get(ctx context.Context, req *nodesv1.GetRequest) (*nodesv1.GetResponse, error)

func (n *NodeService) Join(ctx context.Context, req *nodesv1.JoinRequest) (*nodesv1.JoinResponse, error)

func (n *NodeService) List(ctx context.Context, req *nodesv1.ListRequest) (*nodesv1.ListResponse, error)

func (n *NodeService) Patch(ctx context.Context, req *nodesv1.PatchRequest) (*nodesv1.PatchResponse, error)

func (n *NodeService) Register(server *grpc.Server) error

func (n *NodeService) Update(ctx context.Context, req *nodesv1.UpdateRequest) (*nodesv1.UpdateResponse, error)

func (n *NodeService) UpdateStatus(ctx context.Context, req *nodesv1.UpdateStatusRequest) (*nodesv1.UpdateStatusResponse, error)

func (n *NodeService) Upgrade(ctx context.Context, req *nodesv1.UpgradeRequest) (*nodesv1.UpgradeResponse, error)