api

package
v0.0.0-...-3e5077d Latest Latest
Warning

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

 Go to latest Published: May 2, 2024 License: MIT Imports: 14 Imported by: 8

Documentation

Index

Constants

View Source 
const (
	RegistrationSubject = "magnetar.registration"
)

Variables

View Source 
var (
	Value_ValueTYpe_name = map[int32]string{
		0: "Bool",
		1: "Float64",
		2: "String",
	}
	Value_ValueTYpe_value = map[string]int32{
		"Bool":    0,
		"Float64": 1,
		"String":  2,
	}
)

Enum value maps for Value_ValueTYpe.

View Source 
var File_magnetar_model_proto protoreflect.FileDescriptor
View Source 
var File_magnetar_proto protoreflect.FileDescriptor
View Source 
var File_registration_proto protoreflect.FileDescriptor
View Source 
var Magnetar_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Magnetar",
	HandlerType: (*MagnetarServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetFromNodePool",
			Handler:    _Magnetar_GetFromNodePool_Handler,
		},
		{
			MethodName: "GetFromOrg",
			Handler:    _Magnetar_GetFromOrg_Handler,
		},
		{
			MethodName: "ClaimOwnership",
			Handler:    _Magnetar_ClaimOwnership_Handler,
		},
		{
			MethodName: "ListNodePool",
			Handler:    _Magnetar_ListNodePool_Handler,
		},
		{
			MethodName: "ListOrgOwnedNodes",
			Handler:    _Magnetar_ListOrgOwnedNodes_Handler,
		},
		{
			MethodName: "QueryNodePool",
			Handler:    _Magnetar_QueryNodePool_Handler,
		},
		{
			MethodName: "QueryOrgOwnedNodes",
			Handler:    _Magnetar_QueryOrgOwnedNodes_Handler,
		},
		{
			MethodName: "PutBoolLabel",
			Handler:    _Magnetar_PutBoolLabel_Handler,
		},
		{
			MethodName: "PutFloat64Label",
			Handler:    _Magnetar_PutFloat64Label_Handler,
		},
		{
			MethodName: "PutStringLabel",
			Handler:    _Magnetar_PutStringLabel_Handler,
		},
		{
			MethodName: "DeleteLabel",
			Handler:    _Magnetar_DeleteLabel_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "magnetar.proto",
}

Magnetar_ServiceDesc is the grpc.ServiceDesc for Magnetar service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMagnetarServer 

func RegisterMagnetarServer(s grpc.ServiceRegistrar, srv MagnetarServer)

Types

type BoolLabel 

type BoolLabel struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value bool   `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*BoolLabel) Descriptor deprecated 

func (*BoolLabel) Descriptor() ([]byte, []int)

Deprecated: Use BoolLabel.ProtoReflect.Descriptor instead.

func (*BoolLabel) GetKey 

func (x *BoolLabel) GetKey() string

func (*BoolLabel) GetValue 

func (x *BoolLabel) GetValue() bool

func (*BoolLabel) ProtoMessage 

func (*BoolLabel) ProtoMessage()

func (*BoolLabel) ProtoReflect 

func (x *BoolLabel) ProtoReflect() protoreflect.Message

func (*BoolLabel) Reset 

func (x *BoolLabel) Reset()

func (*BoolLabel) String 

func (x *BoolLabel) String() string

type BoolValue 

type BoolValue struct {
	Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*BoolValue) Descriptor deprecated 

func (*BoolValue) Descriptor() ([]byte, []int)

Deprecated: Use BoolValue.ProtoReflect.Descriptor instead.

func (*BoolValue) GetValue 

func (x *BoolValue) GetValue() bool

func (*BoolValue) ProtoMessage 

func (*BoolValue) ProtoMessage()

func (*BoolValue) ProtoReflect 

func (x *BoolValue) ProtoReflect() protoreflect.Message

func (*BoolValue) Reset 

func (x *BoolValue) Reset()

func (*BoolValue) String 

func (x *BoolValue) String() string

type ClaimOwnershipReq 

type ClaimOwnershipReq struct {
	Query []*Selector `protobuf:"bytes,1,rep,name=query,proto3" json:"query,omitempty"`
	Org   string      `protobuf:"bytes,2,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

func (*ClaimOwnershipReq) Descriptor deprecated 

func (*ClaimOwnershipReq) Descriptor() ([]byte, []int)

Deprecated: Use ClaimOwnershipReq.ProtoReflect.Descriptor instead.

func (*ClaimOwnershipReq) GetOrg 

func (x *ClaimOwnershipReq) GetOrg() string

func (*ClaimOwnershipReq) GetQuery 

func (x *ClaimOwnershipReq) GetQuery() []*Selector

func (*ClaimOwnershipReq) ProtoMessage 

func (*ClaimOwnershipReq) ProtoMessage()

func (*ClaimOwnershipReq) ProtoReflect 

func (x *ClaimOwnershipReq) ProtoReflect() protoreflect.Message

func (*ClaimOwnershipReq) Reset 

func (x *ClaimOwnershipReq) Reset()

func (*ClaimOwnershipReq) String 

func (x *ClaimOwnershipReq) String() string

type ClaimOwnershipResp 

type ClaimOwnershipResp struct {
	Node []*NodeStringified `protobuf:"bytes,1,rep,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*ClaimOwnershipResp) Descriptor deprecated 

func (*ClaimOwnershipResp) Descriptor() ([]byte, []int)

Deprecated: Use ClaimOwnershipResp.ProtoReflect.Descriptor instead.

func (*ClaimOwnershipResp) GetNode 

func (x *ClaimOwnershipResp) GetNode() []*NodeStringified

func (*ClaimOwnershipResp) ProtoMessage 

func (*ClaimOwnershipResp) ProtoMessage()

func (*ClaimOwnershipResp) ProtoReflect 

func (x *ClaimOwnershipResp) ProtoReflect() protoreflect.Message

func (*ClaimOwnershipResp) Reset 

func (x *ClaimOwnershipResp) Reset()

func (*ClaimOwnershipResp) String 

func (x *ClaimOwnershipResp) String() string

type DeleteLabelReq 

type DeleteLabelReq struct {
	NodeId   string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	LabelKey string `protobuf:"bytes,2,opt,name=labelKey,proto3" json:"labelKey,omitempty"`
	Org      string `protobuf:"bytes,3,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteLabelReq) Descriptor deprecated 

func (*DeleteLabelReq) Descriptor() ([]byte, []int)

Deprecated: Use DeleteLabelReq.ProtoReflect.Descriptor instead.

func (*DeleteLabelReq) GetLabelKey 

func (x *DeleteLabelReq) GetLabelKey() string

func (*DeleteLabelReq) GetNodeId 

func (x *DeleteLabelReq) GetNodeId() string

func (*DeleteLabelReq) GetOrg 

func (x *DeleteLabelReq) GetOrg() string

func (*DeleteLabelReq) ProtoMessage 

func (*DeleteLabelReq) ProtoMessage()

func (*DeleteLabelReq) ProtoReflect 

func (x *DeleteLabelReq) ProtoReflect() protoreflect.Message

func (*DeleteLabelReq) Reset 

func (x *DeleteLabelReq) Reset()

func (*DeleteLabelReq) String 

func (x *DeleteLabelReq) String() string

type DeleteLabelResp 

type DeleteLabelResp struct {
	Node *NodeStringified `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteLabelResp) Descriptor deprecated 

func (*DeleteLabelResp) Descriptor() ([]byte, []int)

Deprecated: Use DeleteLabelResp.ProtoReflect.Descriptor instead.

func (*DeleteLabelResp) GetNode 

func (x *DeleteLabelResp) GetNode() *NodeStringified

func (*DeleteLabelResp) ProtoMessage 

func (*DeleteLabelResp) ProtoMessage()

func (*DeleteLabelResp) ProtoReflect 

func (x *DeleteLabelResp) ProtoReflect() protoreflect.Message

func (*DeleteLabelResp) Reset 

func (x *DeleteLabelResp) Reset()

func (*DeleteLabelResp) String 

func (x *DeleteLabelResp) String() string

type Float64Label 

type Float64Label struct {
	Key   string  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Float64Label) Descriptor deprecated 

func (*Float64Label) Descriptor() ([]byte, []int)

Deprecated: Use Float64Label.ProtoReflect.Descriptor instead.

func (*Float64Label) GetKey 

func (x *Float64Label) GetKey() string

func (*Float64Label) GetValue 

func (x *Float64Label) GetValue() float64

func (*Float64Label) ProtoMessage 

func (*Float64Label) ProtoMessage()

func (*Float64Label) ProtoReflect 

func (x *Float64Label) ProtoReflect() protoreflect.Message

func (*Float64Label) Reset 

func (x *Float64Label) Reset()

func (*Float64Label) String 

func (x *Float64Label) String() string

type Float64Value 

type Float64Value struct {
	Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Float64Value) Descriptor deprecated 

func (*Float64Value) Descriptor() ([]byte, []int)

Deprecated: Use Float64Value.ProtoReflect.Descriptor instead.

func (*Float64Value) GetValue 

func (x *Float64Value) GetValue() float64

func (*Float64Value) ProtoMessage 

func (*Float64Value) ProtoMessage()

func (*Float64Value) ProtoReflect 

func (x *Float64Value) ProtoReflect() protoreflect.Message

func (*Float64Value) Reset 

func (x *Float64Value) Reset()

func (*Float64Value) String 

func (x *Float64Value) String() string

type GetFromNodePoolReq 

type GetFromNodePoolReq struct {
	NodeId string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFromNodePoolReq) Descriptor deprecated 

func (*GetFromNodePoolReq) Descriptor() ([]byte, []int)

Deprecated: Use GetFromNodePoolReq.ProtoReflect.Descriptor instead.

func (*GetFromNodePoolReq) GetNodeId 

func (x *GetFromNodePoolReq) GetNodeId() string

func (*GetFromNodePoolReq) ProtoMessage 

func (*GetFromNodePoolReq) ProtoMessage()

func (*GetFromNodePoolReq) ProtoReflect 

func (x *GetFromNodePoolReq) ProtoReflect() protoreflect.Message

func (*GetFromNodePoolReq) Reset 

func (x *GetFromNodePoolReq) Reset()

func (*GetFromNodePoolReq) String 

func (x *GetFromNodePoolReq) String() string

type GetFromNodePoolResp 

type GetFromNodePoolResp struct {
	Node *NodeStringified `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFromNodePoolResp) Descriptor deprecated 

func (*GetFromNodePoolResp) Descriptor() ([]byte, []int)

Deprecated: Use GetFromNodePoolResp.ProtoReflect.Descriptor instead.

func (*GetFromNodePoolResp) GetNode 

func (x *GetFromNodePoolResp) GetNode() *NodeStringified

func (*GetFromNodePoolResp) ProtoMessage 

func (*GetFromNodePoolResp) ProtoMessage()

func (*GetFromNodePoolResp) ProtoReflect 

func (x *GetFromNodePoolResp) ProtoReflect() protoreflect.Message

func (*GetFromNodePoolResp) Reset 

func (x *GetFromNodePoolResp) Reset()

func (*GetFromNodePoolResp) String 

func (x *GetFromNodePoolResp) String() string

type GetFromOrgReq 

type GetFromOrgReq struct {
	NodeId string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	Org    string `protobuf:"bytes,2,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFromOrgReq) Descriptor deprecated 

func (*GetFromOrgReq) Descriptor() ([]byte, []int)

Deprecated: Use GetFromOrgReq.ProtoReflect.Descriptor instead.

func (*GetFromOrgReq) GetNodeId 

func (x *GetFromOrgReq) GetNodeId() string

func (*GetFromOrgReq) GetOrg 

func (x *GetFromOrgReq) GetOrg() string

func (*GetFromOrgReq) ProtoMessage 

func (*GetFromOrgReq) ProtoMessage()

func (*GetFromOrgReq) ProtoReflect 

func (x *GetFromOrgReq) ProtoReflect() protoreflect.Message

func (*GetFromOrgReq) Reset 

func (x *GetFromOrgReq) Reset()

func (*GetFromOrgReq) String 

func (x *GetFromOrgReq) String() string

type GetFromOrgResp 

type GetFromOrgResp struct {
	Node *NodeStringified `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFromOrgResp) Descriptor deprecated 

func (*GetFromOrgResp) Descriptor() ([]byte, []int)

Deprecated: Use GetFromOrgResp.ProtoReflect.Descriptor instead.

func (*GetFromOrgResp) GetNode 

func (x *GetFromOrgResp) GetNode() *NodeStringified

func (*GetFromOrgResp) ProtoMessage 

func (*GetFromOrgResp) ProtoMessage()

func (*GetFromOrgResp) ProtoReflect 

func (x *GetFromOrgResp) ProtoReflect() protoreflect.Message

func (*GetFromOrgResp) Reset 

func (x *GetFromOrgResp) Reset()

func (*GetFromOrgResp) String 

func (x *GetFromOrgResp) String() string

type Label 

type Label struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Label) Descriptor deprecated 

func (*Label) Descriptor() ([]byte, []int)

Deprecated: Use Label.ProtoReflect.Descriptor instead.

func (*Label) GetKey 

func (x *Label) GetKey() string

func (*Label) GetValue 

func (x *Label) GetValue() *Value

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) ProtoReflect 

func (x *Label) ProtoReflect() protoreflect.Message

func (*Label) Reset 

func (x *Label) Reset()

func (*Label) String 

func (x *Label) String() string

type LabelStringified 

type LabelStringified struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*LabelStringified) Descriptor deprecated 

func (*LabelStringified) Descriptor() ([]byte, []int)

Deprecated: Use LabelStringified.ProtoReflect.Descriptor instead.

func (*LabelStringified) GetKey 

func (x *LabelStringified) GetKey() string

func (*LabelStringified) GetValue 

func (x *LabelStringified) GetValue() string

func (*LabelStringified) ProtoMessage 

func (*LabelStringified) ProtoMessage()

func (*LabelStringified) ProtoReflect 

func (x *LabelStringified) ProtoReflect() protoreflect.Message

func (*LabelStringified) Reset 

func (x *LabelStringified) Reset()

func (*LabelStringified) String 

func (x *LabelStringified) String() string

type ListNodePoolReq 

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

func (*ListNodePoolReq) Descriptor deprecated 

func (*ListNodePoolReq) Descriptor() ([]byte, []int)

Deprecated: Use ListNodePoolReq.ProtoReflect.Descriptor instead.

func (*ListNodePoolReq) ProtoMessage 

func (*ListNodePoolReq) ProtoMessage()

func (*ListNodePoolReq) ProtoReflect 

func (x *ListNodePoolReq) ProtoReflect() protoreflect.Message

func (*ListNodePoolReq) Reset 

func (x *ListNodePoolReq) Reset()

func (*ListNodePoolReq) String 

func (x *ListNodePoolReq) String() string

type ListNodePoolResp 

type ListNodePoolResp struct {
	Nodes []*NodeStringified `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNodePoolResp) Descriptor deprecated 

func (*ListNodePoolResp) Descriptor() ([]byte, []int)

Deprecated: Use ListNodePoolResp.ProtoReflect.Descriptor instead.

func (*ListNodePoolResp) GetNodes 

func (x *ListNodePoolResp) GetNodes() []*NodeStringified

func (*ListNodePoolResp) ProtoMessage 

func (*ListNodePoolResp) ProtoMessage()

func (*ListNodePoolResp) ProtoReflect 

func (x *ListNodePoolResp) ProtoReflect() protoreflect.Message

func (*ListNodePoolResp) Reset 

func (x *ListNodePoolResp) Reset()

func (*ListNodePoolResp) String 

func (x *ListNodePoolResp) String() string

type ListOrgOwnedNodesReq 

type ListOrgOwnedNodesReq struct {
	Org string `protobuf:"bytes,1,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

func (*ListOrgOwnedNodesReq) Descriptor deprecated 

func (*ListOrgOwnedNodesReq) Descriptor() ([]byte, []int)

Deprecated: Use ListOrgOwnedNodesReq.ProtoReflect.Descriptor instead.

func (*ListOrgOwnedNodesReq) GetOrg 

func (x *ListOrgOwnedNodesReq) GetOrg() string

func (*ListOrgOwnedNodesReq) ProtoMessage 

func (*ListOrgOwnedNodesReq) ProtoMessage()

func (*ListOrgOwnedNodesReq) ProtoReflect 

func (x *ListOrgOwnedNodesReq) ProtoReflect() protoreflect.Message

func (*ListOrgOwnedNodesReq) Reset 

func (x *ListOrgOwnedNodesReq) Reset()

func (*ListOrgOwnedNodesReq) String 

func (x *ListOrgOwnedNodesReq) String() string

type ListOrgOwnedNodesResp 

type ListOrgOwnedNodesResp struct {
	Nodes []*NodeStringified `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*ListOrgOwnedNodesResp) Descriptor deprecated 

func (*ListOrgOwnedNodesResp) Descriptor() ([]byte, []int)

Deprecated: Use ListOrgOwnedNodesResp.ProtoReflect.Descriptor instead.

func (*ListOrgOwnedNodesResp) GetNodes 

func (x *ListOrgOwnedNodesResp) GetNodes() []*NodeStringified

func (*ListOrgOwnedNodesResp) ProtoMessage 

func (*ListOrgOwnedNodesResp) ProtoMessage()

func (*ListOrgOwnedNodesResp) ProtoReflect 

func (x *ListOrgOwnedNodesResp) ProtoReflect() protoreflect.Message

func (*ListOrgOwnedNodesResp) Reset 

func (x *ListOrgOwnedNodesResp) Reset()

func (*ListOrgOwnedNodesResp) String 

func (x *ListOrgOwnedNodesResp) String() string

type MagnetarClient 

type MagnetarClient interface {
	GetFromNodePool(ctx context.Context, in *GetFromNodePoolReq, opts ...grpc.CallOption) (*GetFromNodePoolResp, error)
	GetFromOrg(ctx context.Context, in *GetFromOrgReq, opts ...grpc.CallOption) (*GetFromOrgResp, error)
	ClaimOwnership(ctx context.Context, in *ClaimOwnershipReq, opts ...grpc.CallOption) (*ClaimOwnershipResp, error)
	ListNodePool(ctx context.Context, in *ListNodePoolReq, opts ...grpc.CallOption) (*ListNodePoolResp, error)
	ListOrgOwnedNodes(ctx context.Context, in *ListOrgOwnedNodesReq, opts ...grpc.CallOption) (*ListOrgOwnedNodesResp, error)
	QueryNodePool(ctx context.Context, in *QueryNodePoolReq, opts ...grpc.CallOption) (*QueryNodePoolResp, error)
	QueryOrgOwnedNodes(ctx context.Context, in *QueryOrgOwnedNodesReq, opts ...grpc.CallOption) (*QueryOrgOwnedNodesResp, error)
	PutBoolLabel(ctx context.Context, in *PutBoolLabelReq, opts ...grpc.CallOption) (*PutLabelResp, error)
	PutFloat64Label(ctx context.Context, in *PutFloat64LabelReq, opts ...grpc.CallOption) (*PutLabelResp, error)
	PutStringLabel(ctx context.Context, in *PutStringLabelReq, opts ...grpc.CallOption) (*PutLabelResp, error)
	DeleteLabel(ctx context.Context, in *DeleteLabelReq, opts ...grpc.CallOption) (*DeleteLabelResp, error)
}

MagnetarClient is the client API for Magnetar service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMagnetarClient 

func NewMagnetarClient(cc grpc.ClientConnInterface) MagnetarClient

type MagnetarServer 

type MagnetarServer interface {
	GetFromNodePool(context.Context, *GetFromNodePoolReq) (*GetFromNodePoolResp, error)
	GetFromOrg(context.Context, *GetFromOrgReq) (*GetFromOrgResp, error)
	ClaimOwnership(context.Context, *ClaimOwnershipReq) (*ClaimOwnershipResp, error)
	ListNodePool(context.Context, *ListNodePoolReq) (*ListNodePoolResp, error)
	ListOrgOwnedNodes(context.Context, *ListOrgOwnedNodesReq) (*ListOrgOwnedNodesResp, error)
	QueryNodePool(context.Context, *QueryNodePoolReq) (*QueryNodePoolResp, error)
	QueryOrgOwnedNodes(context.Context, *QueryOrgOwnedNodesReq) (*QueryOrgOwnedNodesResp, error)
	PutBoolLabel(context.Context, *PutBoolLabelReq) (*PutLabelResp, error)
	PutFloat64Label(context.Context, *PutFloat64LabelReq) (*PutLabelResp, error)
	PutStringLabel(context.Context, *PutStringLabelReq) (*PutLabelResp, error)
	DeleteLabel(context.Context, *DeleteLabelReq) (*DeleteLabelResp, error)
	// contains filtered or unexported methods
}

MagnetarServer is the server API for Magnetar service. All implementations must embed UnimplementedMagnetarServer for forward compatibility

type Node 

type Node struct {
	Id     string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Org    string   `protobuf:"bytes,2,opt,name=org,proto3" json:"org,omitempty"`
	Labels []*Label `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated 

func (*Node) Descriptor() ([]byte, []int)

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetId 

func (x *Node) GetId() string

func (*Node) GetLabels 

func (x *Node) GetLabels() []*Label

func (*Node) GetOrg 

func (x *Node) GetOrg() string

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

func (x *Node) ProtoReflect() protoreflect.Message

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type NodeStringified 

type NodeStringified struct {
	Id     string              `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Org    string              `protobuf:"bytes,2,opt,name=org,proto3" json:"org,omitempty"`
	Labels []*LabelStringified `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeStringified) Descriptor deprecated 

func (*NodeStringified) Descriptor() ([]byte, []int)

Deprecated: Use NodeStringified.ProtoReflect.Descriptor instead.

func (*NodeStringified) GetId 

func (x *NodeStringified) GetId() string

func (*NodeStringified) GetLabels 

func (x *NodeStringified) GetLabels() []*LabelStringified

func (*NodeStringified) GetOrg 

func (x *NodeStringified) GetOrg() string

func (*NodeStringified) ProtoMessage 

func (*NodeStringified) ProtoMessage()

func (*NodeStringified) ProtoReflect 

func (x *NodeStringified) ProtoReflect() protoreflect.Message

func (*NodeStringified) Reset 

func (x *NodeStringified) Reset()

func (*NodeStringified) String 

func (x *NodeStringified) String() string

type PutBoolLabelReq 

type PutBoolLabelReq struct {
	NodeId string     `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	Label  *BoolLabel `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Org    string     `protobuf:"bytes,3,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

func (*PutBoolLabelReq) Descriptor deprecated 

func (*PutBoolLabelReq) Descriptor() ([]byte, []int)

Deprecated: Use PutBoolLabelReq.ProtoReflect.Descriptor instead.

func (*PutBoolLabelReq) GetLabel 

func (x *PutBoolLabelReq) GetLabel() *BoolLabel

func (*PutBoolLabelReq) GetNodeId 

func (x *PutBoolLabelReq) GetNodeId() string

func (*PutBoolLabelReq) GetOrg 

func (x *PutBoolLabelReq) GetOrg() string

func (*PutBoolLabelReq) ProtoMessage 

func (*PutBoolLabelReq) ProtoMessage()

func (*PutBoolLabelReq) ProtoReflect 

func (x *PutBoolLabelReq) ProtoReflect() protoreflect.Message

func (*PutBoolLabelReq) Reset 

func (x *PutBoolLabelReq) Reset()

func (*PutBoolLabelReq) String 

func (x *PutBoolLabelReq) String() string

type PutFloat64LabelReq 

type PutFloat64LabelReq struct {
	NodeId string        `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	Label  *Float64Label `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Org    string        `protobuf:"bytes,3,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

func (*PutFloat64LabelReq) Descriptor deprecated 

func (*PutFloat64LabelReq) Descriptor() ([]byte, []int)

Deprecated: Use PutFloat64LabelReq.ProtoReflect.Descriptor instead.

func (*PutFloat64LabelReq) GetLabel 

func (x *PutFloat64LabelReq) GetLabel() *Float64Label

func (*PutFloat64LabelReq) GetNodeId 

func (x *PutFloat64LabelReq) GetNodeId() string

func (*PutFloat64LabelReq) GetOrg 

func (x *PutFloat64LabelReq) GetOrg() string

func (*PutFloat64LabelReq) ProtoMessage 

func (*PutFloat64LabelReq) ProtoMessage()

func (*PutFloat64LabelReq) ProtoReflect 

func (x *PutFloat64LabelReq) ProtoReflect() protoreflect.Message

func (*PutFloat64LabelReq) Reset 

func (x *PutFloat64LabelReq) Reset()

func (*PutFloat64LabelReq) String 

func (x *PutFloat64LabelReq) String() string

type PutLabelResp 

type PutLabelResp struct {
	Node *NodeStringified `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*PutLabelResp) Descriptor deprecated 

func (*PutLabelResp) Descriptor() ([]byte, []int)

Deprecated: Use PutLabelResp.ProtoReflect.Descriptor instead.

func (*PutLabelResp) GetNode 

func (x *PutLabelResp) GetNode() *NodeStringified

func (*PutLabelResp) ProtoMessage 

func (*PutLabelResp) ProtoMessage()

func (*PutLabelResp) ProtoReflect 

func (x *PutLabelResp) ProtoReflect() protoreflect.Message

func (*PutLabelResp) Reset 

func (x *PutLabelResp) Reset()

func (*PutLabelResp) String 

func (x *PutLabelResp) String() string

type PutStringLabelReq 

type PutStringLabelReq struct {
	NodeId string       `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	Label  *StringLabel `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Org    string       `protobuf:"bytes,3,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

func (*PutStringLabelReq) Descriptor deprecated 

func (*PutStringLabelReq) Descriptor() ([]byte, []int)

Deprecated: Use PutStringLabelReq.ProtoReflect.Descriptor instead.

func (*PutStringLabelReq) GetLabel 

func (x *PutStringLabelReq) GetLabel() *StringLabel

func (*PutStringLabelReq) GetNodeId 

func (x *PutStringLabelReq) GetNodeId() string

func (*PutStringLabelReq) GetOrg 

func (x *PutStringLabelReq) GetOrg() string

func (*PutStringLabelReq) ProtoMessage 

func (*PutStringLabelReq) ProtoMessage()

func (*PutStringLabelReq) ProtoReflect 

func (x *PutStringLabelReq) ProtoReflect() protoreflect.Message

func (*PutStringLabelReq) Reset 

func (x *PutStringLabelReq) Reset()

func (*PutStringLabelReq) String 

func (x *PutStringLabelReq) String() string

type QueryNodePoolReq 

type QueryNodePoolReq struct {
	Query []*Selector `protobuf:"bytes,1,rep,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryNodePoolReq) Descriptor deprecated 

func (*QueryNodePoolReq) Descriptor() ([]byte, []int)

Deprecated: Use QueryNodePoolReq.ProtoReflect.Descriptor instead.

func (*QueryNodePoolReq) GetQuery 

func (x *QueryNodePoolReq) GetQuery() []*Selector

func (*QueryNodePoolReq) ProtoMessage 

func (*QueryNodePoolReq) ProtoMessage()

func (*QueryNodePoolReq) ProtoReflect 

func (x *QueryNodePoolReq) ProtoReflect() protoreflect.Message

func (*QueryNodePoolReq) Reset 

func (x *QueryNodePoolReq) Reset()

func (*QueryNodePoolReq) String 

func (x *QueryNodePoolReq) String() string

type QueryNodePoolResp 

type QueryNodePoolResp struct {
	Nodes []*NodeStringified `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryNodePoolResp) Descriptor deprecated 

func (*QueryNodePoolResp) Descriptor() ([]byte, []int)

Deprecated: Use QueryNodePoolResp.ProtoReflect.Descriptor instead.

func (*QueryNodePoolResp) GetNodes 

func (x *QueryNodePoolResp) GetNodes() []*NodeStringified

func (*QueryNodePoolResp) ProtoMessage 

func (*QueryNodePoolResp) ProtoMessage()

func (*QueryNodePoolResp) ProtoReflect 

func (x *QueryNodePoolResp) ProtoReflect() protoreflect.Message

func (*QueryNodePoolResp) Reset 

func (x *QueryNodePoolResp) Reset()

func (*QueryNodePoolResp) String 

func (x *QueryNodePoolResp) String() string

type QueryOrgOwnedNodesReq 

type QueryOrgOwnedNodesReq struct {
	Query []*Selector `protobuf:"bytes,1,rep,name=query,proto3" json:"query,omitempty"`
	Org   string      `protobuf:"bytes,2,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryOrgOwnedNodesReq) Descriptor deprecated 

func (*QueryOrgOwnedNodesReq) Descriptor() ([]byte, []int)

Deprecated: Use QueryOrgOwnedNodesReq.ProtoReflect.Descriptor instead.

func (*QueryOrgOwnedNodesReq) GetOrg 

func (x *QueryOrgOwnedNodesReq) GetOrg() string

func (*QueryOrgOwnedNodesReq) GetQuery 

func (x *QueryOrgOwnedNodesReq) GetQuery() []*Selector

func (*QueryOrgOwnedNodesReq) ProtoMessage 

func (*QueryOrgOwnedNodesReq) ProtoMessage()

func (*QueryOrgOwnedNodesReq) ProtoReflect 

func (x *QueryOrgOwnedNodesReq) ProtoReflect() protoreflect.Message

func (*QueryOrgOwnedNodesReq) Reset 

func (x *QueryOrgOwnedNodesReq) Reset()

func (*QueryOrgOwnedNodesReq) String 

func (x *QueryOrgOwnedNodesReq) String() string

type QueryOrgOwnedNodesResp 

type QueryOrgOwnedNodesResp struct {
	Nodes []*NodeStringified `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryOrgOwnedNodesResp) Descriptor deprecated 

func (*QueryOrgOwnedNodesResp) Descriptor() ([]byte, []int)

Deprecated: Use QueryOrgOwnedNodesResp.ProtoReflect.Descriptor instead.

func (*QueryOrgOwnedNodesResp) GetNodes 

func (x *QueryOrgOwnedNodesResp) GetNodes() []*NodeStringified

func (*QueryOrgOwnedNodesResp) ProtoMessage 

func (*QueryOrgOwnedNodesResp) ProtoMessage()

func (*QueryOrgOwnedNodesResp) ProtoReflect 

func (x *QueryOrgOwnedNodesResp) ProtoReflect() protoreflect.Message

func (*QueryOrgOwnedNodesResp) Reset 

func (x *QueryOrgOwnedNodesResp) Reset()

func (*QueryOrgOwnedNodesResp) String 

func (x *QueryOrgOwnedNodesResp) String() string

type RegistrationAsyncClient 

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

func NewRegistrationAsyncClient 

func NewRegistrationAsyncClient(natsAddress string) (*RegistrationAsyncClient, error)

func (*RegistrationAsyncClient) Register 

func (n *RegistrationAsyncClient) Register(req *RegistrationReq, callback RegistrationCallback) error

type RegistrationCallback 

type RegistrationCallback func(resp *RegistrationResp)

type RegistrationReq 

type RegistrationReq struct {
	Labels []*Label `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

func (*RegistrationReq) Descriptor deprecated 

func (*RegistrationReq) Descriptor() ([]byte, []int)

Deprecated: Use RegistrationReq.ProtoReflect.Descriptor instead.

func (*RegistrationReq) GetLabels 

func (x *RegistrationReq) GetLabels() []*Label

func (*RegistrationReq) Marshal 

func (x *RegistrationReq) Marshal() ([]byte, error)

func (*RegistrationReq) ProtoMessage 

func (*RegistrationReq) ProtoMessage()

func (*RegistrationReq) ProtoReflect 

func (x *RegistrationReq) ProtoReflect() protoreflect.Message

func (*RegistrationReq) Reset 

func (x *RegistrationReq) Reset()

func (*RegistrationReq) String 

func (x *RegistrationReq) String() string

func (*RegistrationReq) Unmarshal 

func (x *RegistrationReq) Unmarshal(marshalled []byte) error

type RegistrationReqBuilder 

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

func NewRegistrationReqBuilder 

func NewRegistrationReqBuilder() RegistrationReqBuilder

func (RegistrationReqBuilder) AddBoolLabel 

func (r RegistrationReqBuilder) AddBoolLabel(key string, value bool) RegistrationReqBuilder

func (RegistrationReqBuilder) AddFloat64Label 

func (r RegistrationReqBuilder) AddFloat64Label(key string, value float64) RegistrationReqBuilder

func (RegistrationReqBuilder) AddStringLabel 

func (r RegistrationReqBuilder) AddStringLabel(key string, value string) RegistrationReqBuilder

func (RegistrationReqBuilder) Clear 

func (r RegistrationReqBuilder) Clear() RegistrationReqBuilder

func (RegistrationReqBuilder) Request 

func (r RegistrationReqBuilder) Request() *RegistrationReq

type RegistrationResp 

type RegistrationResp struct {
	NodeId string `protobuf:"bytes,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*RegistrationResp) Descriptor deprecated 

func (*RegistrationResp) Descriptor() ([]byte, []int)

Deprecated: Use RegistrationResp.ProtoReflect.Descriptor instead.

func (*RegistrationResp) GetNodeId 

func (x *RegistrationResp) GetNodeId() string

func (*RegistrationResp) Marshal 

func (x *RegistrationResp) Marshal() ([]byte, error)

func (*RegistrationResp) ProtoMessage 

func (*RegistrationResp) ProtoMessage()

func (*RegistrationResp) ProtoReflect 

func (x *RegistrationResp) ProtoReflect() protoreflect.Message

func (*RegistrationResp) Reset 

func (x *RegistrationResp) Reset()

func (*RegistrationResp) String 

func (x *RegistrationResp) String() string

func (*RegistrationResp) Unmarshal 

func (x *RegistrationResp) Unmarshal(marshalled []byte) error

type Selector 

type Selector struct {
	LabelKey string `protobuf:"bytes,3,opt,name=labelKey,proto3" json:"labelKey,omitempty"`
	ShouldBe string `protobuf:"bytes,2,opt,name=shouldBe,proto3" json:"shouldBe,omitempty"`
	Value    string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Selector) Descriptor deprecated 

func (*Selector) Descriptor() ([]byte, []int)

Deprecated: Use Selector.ProtoReflect.Descriptor instead.

func (*Selector) GetLabelKey 

func (x *Selector) GetLabelKey() string

func (*Selector) GetShouldBe 

func (x *Selector) GetShouldBe() string

func (*Selector) GetValue 

func (x *Selector) GetValue() string

func (*Selector) ProtoMessage 

func (*Selector) ProtoMessage()

func (*Selector) ProtoReflect 

func (x *Selector) ProtoReflect() protoreflect.Message

func (*Selector) Reset 

func (x *Selector) Reset()

func (*Selector) String 

func (x *Selector) String() string

type StringLabel 

type StringLabel struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*StringLabel) Descriptor deprecated 

func (*StringLabel) Descriptor() ([]byte, []int)

Deprecated: Use StringLabel.ProtoReflect.Descriptor instead.

func (*StringLabel) GetKey 

func (x *StringLabel) GetKey() string

func (*StringLabel) GetValue 

func (x *StringLabel) GetValue() string

func (*StringLabel) ProtoMessage 

func (*StringLabel) ProtoMessage()

func (*StringLabel) ProtoReflect 

func (x *StringLabel) ProtoReflect() protoreflect.Message

func (*StringLabel) Reset 

func (x *StringLabel) Reset()

func (*StringLabel) String 

func (x *StringLabel) String() string

type StringValue 

type StringValue struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*StringValue) Descriptor deprecated 

func (*StringValue) Descriptor() ([]byte, []int)

Deprecated: Use StringValue.ProtoReflect.Descriptor instead.

func (*StringValue) GetValue 

func (x *StringValue) GetValue() string

func (*StringValue) ProtoMessage 

func (*StringValue) ProtoMessage()

func (*StringValue) ProtoReflect 

func (x *StringValue) ProtoReflect() protoreflect.Message

func (*StringValue) Reset 

func (x *StringValue) Reset()

func (*StringValue) String 

func (x *StringValue) String() string

type UnimplementedMagnetarServer 

type UnimplementedMagnetarServer struct {
}

UnimplementedMagnetarServer must be embedded to have forward compatible implementations.

func (UnimplementedMagnetarServer) ClaimOwnership 

func (UnimplementedMagnetarServer) ClaimOwnership(context.Context, *ClaimOwnershipReq) (*ClaimOwnershipResp, error)

func (UnimplementedMagnetarServer) DeleteLabel 

func (UnimplementedMagnetarServer) DeleteLabel(context.Context, *DeleteLabelReq) (*DeleteLabelResp, error)

func (UnimplementedMagnetarServer) GetFromNodePool 

func (UnimplementedMagnetarServer) GetFromNodePool(context.Context, *GetFromNodePoolReq) (*GetFromNodePoolResp, error)

func (UnimplementedMagnetarServer) GetFromOrg 

func (UnimplementedMagnetarServer) GetFromOrg(context.Context, *GetFromOrgReq) (*GetFromOrgResp, error)

func (UnimplementedMagnetarServer) ListNodePool 

func (UnimplementedMagnetarServer) ListNodePool(context.Context, *ListNodePoolReq) (*ListNodePoolResp, error)

func (UnimplementedMagnetarServer) ListOrgOwnedNodes 

func (UnimplementedMagnetarServer) ListOrgOwnedNodes(context.Context, *ListOrgOwnedNodesReq) (*ListOrgOwnedNodesResp, error)

func (UnimplementedMagnetarServer) PutBoolLabel 

func (UnimplementedMagnetarServer) PutBoolLabel(context.Context, *PutBoolLabelReq) (*PutLabelResp, error)

func (UnimplementedMagnetarServer) PutFloat64Label 

func (UnimplementedMagnetarServer) PutFloat64Label(context.Context, *PutFloat64LabelReq) (*PutLabelResp, error)

func (UnimplementedMagnetarServer) PutStringLabel 

func (UnimplementedMagnetarServer) PutStringLabel(context.Context, *PutStringLabelReq) (*PutLabelResp, error)

func (UnimplementedMagnetarServer) QueryNodePool 

func (UnimplementedMagnetarServer) QueryNodePool(context.Context, *QueryNodePoolReq) (*QueryNodePoolResp, error)

func (UnimplementedMagnetarServer) QueryOrgOwnedNodes 

func (UnimplementedMagnetarServer) QueryOrgOwnedNodes(context.Context, *QueryOrgOwnedNodesReq) (*QueryOrgOwnedNodesResp, error)

type UnsafeMagnetarServer 

type UnsafeMagnetarServer interface {
	// contains filtered or unexported methods
}

UnsafeMagnetarServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MagnetarServer will result in compilation errors.

type Value 

type Value struct {
	Type       Value_ValueTYpe `protobuf:"varint,1,opt,name=type,proto3,enum=proto.Value_ValueTYpe" json:"type,omitempty"`
	Marshalled []byte          `protobuf:"bytes,2,opt,name=marshalled,proto3" json:"marshalled,omitempty"`
	// contains filtered or unexported fields
}

func (*Value) Descriptor deprecated 

func (*Value) Descriptor() ([]byte, []int)

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetMarshalled 

func (x *Value) GetMarshalled() []byte

func (*Value) GetType 

func (x *Value) GetType() Value_ValueTYpe

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect 

func (x *Value) ProtoReflect() protoreflect.Message

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) String 

func (x *Value) String() string

type Value_ValueTYpe 

type Value_ValueTYpe int32
const (
	Value_Bool    Value_ValueTYpe = 0
	Value_Float64 Value_ValueTYpe = 1
	Value_String  Value_ValueTYpe = 2
)

func (Value_ValueTYpe) Descriptor 

func (Value_ValueTYpe) Descriptor() protoreflect.EnumDescriptor

func (Value_ValueTYpe) Enum 

func (x Value_ValueTYpe) Enum() *Value_ValueTYpe

func (Value_ValueTYpe) EnumDescriptor deprecated 

func (Value_ValueTYpe) EnumDescriptor() ([]byte, []int)

Deprecated: Use Value_ValueTYpe.Descriptor instead.

func (Value_ValueTYpe) Number 

func (x Value_ValueTYpe) Number() protoreflect.EnumNumber

func (Value_ValueTYpe) String 

func (x Value_ValueTYpe) String() string

func (Value_ValueTYpe) Type 

func (Value_ValueTYpe) Type() protoreflect.EnumType

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.