servers

Documentation

Index

• func GetAuthInterceptor() ...
• func NewMagnetarGrpcServer(nodeService services.NodeService, labelService services.LabelService) (api.MagnetarServer, error)
• type MagnetarGrpcServer
  • func (m *MagnetarGrpcServer) ClaimOwnership(ctx context.Context, req *api.ClaimOwnershipReq) (*api.ClaimOwnershipResp, error)
  • func (m *MagnetarGrpcServer) DeleteLabel(ctx context.Context, req *api.DeleteLabelReq) (*api.DeleteLabelResp, error)
  • func (m *MagnetarGrpcServer) GetFromNodePool(ctx context.Context, req *api.GetFromNodePoolReq) (*api.GetFromNodePoolResp, error)
  • func (m *MagnetarGrpcServer) GetFromOrg(ctx context.Context, req *api.GetFromOrgReq) (*api.GetFromOrgResp, error)
  • func (m *MagnetarGrpcServer) ListAllNodes(ctx context.Context, req *api.ListAllNodesReq) (*api.ListAllNodesResp, error)
  • func (m *MagnetarGrpcServer) ListNodePool(ctx context.Context, req *api.ListNodePoolReq) (*api.ListNodePoolResp, error)
  • func (m *MagnetarGrpcServer) ListOrgOwnedNodes(ctx context.Context, req *api.ListOrgOwnedNodesReq) (*api.ListOrgOwnedNodesResp, error)
  • func (m *MagnetarGrpcServer) PutBoolLabel(ctx context.Context, req *api.PutBoolLabelReq) (*api.PutLabelResp, error)
  • func (m *MagnetarGrpcServer) PutFloat64Label(ctx context.Context, req *api.PutFloat64LabelReq) (*api.PutLabelResp, error)
  • func (m *MagnetarGrpcServer) PutStringLabel(ctx context.Context, req *api.PutStringLabelReq) (*api.PutLabelResp, error)
  • func (m *MagnetarGrpcServer) QueryNodePool(ctx context.Context, req *api.QueryNodePoolReq) (*api.QueryNodePoolResp, error)
  • func (m *MagnetarGrpcServer) QueryOrgOwnedNodes(ctx context.Context, req *api.QueryOrgOwnedNodesReq) (*api.QueryOrgOwnedNodesResp, error)
• type RegistrationAsyncServer
  • func NewRegistrationAsyncServer(subscriber messaging.Subscriber, publisher messaging.Publisher, ...) (*RegistrationAsyncServer, error)
  • func (n *RegistrationAsyncServer) GracefulStop()
  • func (n *RegistrationAsyncServer) Serve() error

Functions

func GetAuthInterceptor

func GetAuthInterceptor() func(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

func NewMagnetarGrpcServer

func NewMagnetarGrpcServer(nodeService services.NodeService, labelService services.LabelService) (api.MagnetarServer, error)

Types

type MagnetarGrpcServer

type MagnetarGrpcServer struct {
	api.UnimplementedMagnetarServer
	// contains filtered or unexported fields
}

func (*MagnetarGrpcServer) ClaimOwnership

func (m *MagnetarGrpcServer) ClaimOwnership(ctx context.Context, req *api.ClaimOwnershipReq) (*api.ClaimOwnershipResp, error)

func (*MagnetarGrpcServer) DeleteLabel

func (m *MagnetarGrpcServer) DeleteLabel(ctx context.Context, req *api.DeleteLabelReq) (*api.DeleteLabelResp, error)

func (*MagnetarGrpcServer) GetFromNodePool

func (m *MagnetarGrpcServer) GetFromNodePool(ctx context.Context, req *api.GetFromNodePoolReq) (*api.GetFromNodePoolResp, error)

func (*MagnetarGrpcServer) GetFromOrg

func (m *MagnetarGrpcServer) GetFromOrg(ctx context.Context, req *api.GetFromOrgReq) (*api.GetFromOrgResp, error)

func (*MagnetarGrpcServer) ListAllNodes

func (m *MagnetarGrpcServer) ListAllNodes(ctx context.Context, req *api.ListAllNodesReq) (*api.ListAllNodesResp, error)

func (*MagnetarGrpcServer) ListNodePool

func (m *MagnetarGrpcServer) ListNodePool(ctx context.Context, req *api.ListNodePoolReq) (*api.ListNodePoolResp, error)

func (*MagnetarGrpcServer) ListOrgOwnedNodes

func (m *MagnetarGrpcServer) ListOrgOwnedNodes(ctx context.Context, req *api.ListOrgOwnedNodesReq) (*api.ListOrgOwnedNodesResp, error)

func (*MagnetarGrpcServer) PutBoolLabel

func (m *MagnetarGrpcServer) PutBoolLabel(ctx context.Context, req *api.PutBoolLabelReq) (*api.PutLabelResp, error)

func (*MagnetarGrpcServer) PutFloat64Label

func (m *MagnetarGrpcServer) PutFloat64Label(ctx context.Context, req *api.PutFloat64LabelReq) (*api.PutLabelResp, error)

func (*MagnetarGrpcServer) PutStringLabel

func (m *MagnetarGrpcServer) PutStringLabel(ctx context.Context, req *api.PutStringLabelReq) (*api.PutLabelResp, error)

func (*MagnetarGrpcServer) QueryNodePool

func (m *MagnetarGrpcServer) QueryNodePool(ctx context.Context, req *api.QueryNodePoolReq) (*api.QueryNodePoolResp, error)

func (*MagnetarGrpcServer) QueryOrgOwnedNodes

func (m *MagnetarGrpcServer) QueryOrgOwnedNodes(ctx context.Context, req *api.QueryOrgOwnedNodesReq) (*api.QueryOrgOwnedNodesResp, error)

type RegistrationAsyncServer

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

func NewRegistrationAsyncServer

func NewRegistrationAsyncServer(subscriber messaging.Subscriber, publisher messaging.Publisher, service services.RegistrationService) (*RegistrationAsyncServer, error)

func (*RegistrationAsyncServer) GracefulStop

func (n *RegistrationAsyncServer) GracefulStop()

func (*RegistrationAsyncServer) Serve

func (n *RegistrationAsyncServer) Serve() error