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) 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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) 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
Source Files
Click to show internal directories.
Click to hide internal directories.