rpcapi

package
v0.0.0-...-856de4a Latest Latest
Warning

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

 Go to latest Published: Oct 27, 2020 License: MIT Imports: 7 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterRPCBalancerServer 

func RegisterRPCBalancerServer(s *grpc.Server, srv RPCBalancerServer)

func RegisterRPCCapacityServer 

func RegisterRPCCapacityServer(s *grpc.Server, srv RPCCapacityServer)

func RegisterRPCNodeServer 

func RegisterRPCNodeServer(s *grpc.Server, srv RPCNodeServer)

Types

type Capacity 

type Capacity struct {
	Capacity             float64  `protobuf:"fixed64,1,opt,name=Capacity,proto3" json:"Capacity,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Capacity) Descriptor 

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

func (*Capacity) GetCapacity 

func (m *Capacity) GetCapacity() float64

func (*Capacity) ProtoMessage 

func (*Capacity) ProtoMessage()

func (*Capacity) Reset 

func (m *Capacity) Reset()

func (*Capacity) String 

func (m *Capacity) String() string

func (*Capacity) XXX_DiscardUnknown 

func (m *Capacity) XXX_DiscardUnknown()

func (*Capacity) XXX_Marshal 

func (m *Capacity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Capacity) XXX_Merge 

func (m *Capacity) XXX_Merge(src proto.Message)

func (*Capacity) XXX_Size 

func (m *Capacity) XXX_Size() int

func (*Capacity) XXX_Unmarshal 

func (m *Capacity) XXX_Unmarshal(b []byte) error

type DataItem 

type DataItem struct {
	ID                   []byte   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Size                 uint64   `protobuf:"varint,2,opt,name=Size,proto3" json:"Size,omitempty"`
	Geo                  *GeoData `protobuf:"bytes,3,opt,name=Geo,proto3" json:"Geo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataItem) Descriptor 

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

func (*DataItem) GetGeo 

func (m *DataItem) GetGeo() *GeoData

func (*DataItem) GetID 

func (m *DataItem) GetID() []byte

func (*DataItem) GetSize 

func (m *DataItem) GetSize() uint64

func (*DataItem) ProtoMessage 

func (*DataItem) ProtoMessage()

func (*DataItem) Reset 

func (m *DataItem) Reset()

func (*DataItem) String 

func (m *DataItem) String() string

func (*DataItem) XXX_DiscardUnknown 

func (m *DataItem) XXX_DiscardUnknown()

func (*DataItem) XXX_Marshal 

func (m *DataItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataItem) XXX_Merge 

func (m *DataItem) XXX_Merge(src proto.Message)

func (*DataItem) XXX_Size 

func (m *DataItem) XXX_Size() int

func (*DataItem) XXX_Unmarshal 

func (m *DataItem) XXX_Unmarshal(b []byte) error

type DataItems 

type DataItems struct {
	DIs                  []*DataItem `protobuf:"bytes,1,rep,name=DIs,proto3" json:"DIs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*DataItems) Descriptor 

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

func (*DataItems) GetDIs 

func (m *DataItems) GetDIs() []*DataItem

func (*DataItems) ProtoMessage 

func (*DataItems) ProtoMessage()

func (*DataItems) Reset 

func (m *DataItems) Reset()

func (*DataItems) String 

func (m *DataItems) String() string

func (*DataItems) XXX_DiscardUnknown 

func (m *DataItems) XXX_DiscardUnknown()

func (*DataItems) XXX_Marshal 

func (m *DataItems) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataItems) XXX_Merge 

func (m *DataItems) XXX_Merge(src proto.Message)

func (*DataItems) XXX_Size 

func (m *DataItems) XXX_Size() int

func (*DataItems) XXX_Unmarshal 

func (m *DataItems) XXX_Unmarshal(b []byte) error

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Empty) XXX_Merge 

func (m *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

func (m *Empty) XXX_Unmarshal(b []byte) error

type GeoData 

type GeoData struct {
	Longitude            float64  `protobuf:"fixed64,1,opt,name=Longitude,proto3" json:"Longitude,omitempty"`
	Latitude             float64  `protobuf:"fixed64,2,opt,name=Latitude,proto3" json:"Latitude,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GeoData) Descriptor 

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

func (*GeoData) GetLatitude 

func (m *GeoData) GetLatitude() float64

func (*GeoData) GetLongitude 

func (m *GeoData) GetLongitude() float64

func (*GeoData) ProtoMessage 

func (*GeoData) ProtoMessage()

func (*GeoData) Reset 

func (m *GeoData) Reset()

func (*GeoData) String 

func (m *GeoData) String() string

func (*GeoData) XXX_DiscardUnknown 

func (m *GeoData) XXX_DiscardUnknown()

func (*GeoData) XXX_Marshal 

func (m *GeoData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GeoData) XXX_Merge 

func (m *GeoData) XXX_Merge(src proto.Message)

func (*GeoData) XXX_Size 

func (m *GeoData) XXX_Size() int

func (*GeoData) XXX_Unmarshal 

func (m *GeoData) XXX_Unmarshal(b []byte) error

type HealthCheck 

type HealthCheck struct {
	Timeout                        string   `protobuf:"bytes,1,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	DeregisterCriticalServiceAfter string   `protobuf:"bytes,2,opt,name=DeregisterCriticalServiceAfter,proto3" json:"DeregisterCriticalServiceAfter,omitempty"`
	XXX_NoUnkeyedLiteral           struct{} `json:"-"`
	XXX_unrecognized               []byte   `json:"-"`
	XXX_sizecache                  int32    `json:"-"`
}

func (*HealthCheck) Descriptor 

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

func (*HealthCheck) GetDeregisterCriticalServiceAfter 

func (m *HealthCheck) GetDeregisterCriticalServiceAfter() string

func (*HealthCheck) GetTimeout 

func (m *HealthCheck) GetTimeout() string

func (*HealthCheck) ProtoMessage 

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) Reset 

func (m *HealthCheck) Reset()

func (*HealthCheck) String 

func (m *HealthCheck) String() string

func (*HealthCheck) XXX_DiscardUnknown 

func (m *HealthCheck) XXX_DiscardUnknown()

func (*HealthCheck) XXX_Marshal 

func (m *HealthCheck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheck) XXX_Merge 

func (m *HealthCheck) XXX_Merge(src proto.Message)

func (*HealthCheck) XXX_Size 

func (m *HealthCheck) XXX_Size() int

func (*HealthCheck) XXX_Unmarshal 

func (m *HealthCheck) XXX_Unmarshal(b []byte) error

type KeyList 

type KeyList struct {
	Node                 *NodeMeta  `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"`
	Keys                 *DataItems `protobuf:"bytes,2,opt,name=Keys,proto3" json:"Keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*KeyList) Descriptor 

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

func (*KeyList) GetKeys 

func (m *KeyList) GetKeys() *DataItems

func (*KeyList) GetNode 

func (m *KeyList) GetNode() *NodeMeta

func (*KeyList) ProtoMessage 

func (*KeyList) ProtoMessage()

func (*KeyList) Reset 

func (m *KeyList) Reset()

func (*KeyList) String 

func (m *KeyList) String() string

func (*KeyList) XXX_DiscardUnknown 

func (m *KeyList) XXX_DiscardUnknown()

func (*KeyList) XXX_Marshal 

func (m *KeyList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyList) XXX_Merge 

func (m *KeyList) XXX_Merge(src proto.Message)

func (*KeyList) XXX_Size 

func (m *KeyList) XXX_Size() int

func (*KeyList) XXX_Unmarshal 

func (m *KeyList) XXX_Unmarshal(b []byte) error

type KeyReq 

type KeyReq struct {
	Keys                 [][]byte `protobuf:"bytes,1,rep,name=Keys,proto3" json:"Keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeyReq) Descriptor 

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

func (*KeyReq) GetKeys 

func (m *KeyReq) GetKeys() [][]byte

func (*KeyReq) ProtoMessage 

func (*KeyReq) ProtoMessage()

func (*KeyReq) Reset 

func (m *KeyReq) Reset()

func (*KeyReq) String 

func (m *KeyReq) String() string

func (*KeyReq) XXX_DiscardUnknown 

func (m *KeyReq) XXX_DiscardUnknown()

func (*KeyReq) XXX_Marshal 

func (m *KeyReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyReq) XXX_Merge 

func (m *KeyReq) XXX_Merge(src proto.Message)

func (*KeyReq) XXX_Size 

func (m *KeyReq) XXX_Size() int

func (*KeyReq) XXX_Unmarshal 

func (m *KeyReq) XXX_Unmarshal(b []byte) error

type KeyValue 

type KeyValue struct {
	Key                  *DataItem `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Value                []byte    `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	Found                bool      `protobuf:"varint,3,opt,name=Found,proto3" json:"Found,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*KeyValue) Descriptor 

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

func (*KeyValue) GetFound 

func (m *KeyValue) GetFound() bool

func (*KeyValue) GetKey 

func (m *KeyValue) GetKey() *DataItem

func (*KeyValue) GetValue 

func (m *KeyValue) GetValue() []byte

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) Reset 

func (m *KeyValue) Reset()

func (*KeyValue) String 

func (m *KeyValue) String() string

func (*KeyValue) XXX_DiscardUnknown 

func (m *KeyValue) XXX_DiscardUnknown()

func (*KeyValue) XXX_Marshal 

func (m *KeyValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyValue) XXX_Merge 

func (m *KeyValue) XXX_Merge(src proto.Message)

func (*KeyValue) XXX_Size 

func (m *KeyValue) XXX_Size() int

func (*KeyValue) XXX_Unmarshal 

func (m *KeyValue) XXX_Unmarshal(b []byte) error

type KeyValues 

type KeyValues struct {
	KVs                  []*KeyValue `protobuf:"bytes,1,rep,name=KVs,proto3" json:"KVs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*KeyValues) Descriptor 

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

func (*KeyValues) GetKVs 

func (m *KeyValues) GetKVs() []*KeyValue

func (*KeyValues) ProtoMessage 

func (*KeyValues) ProtoMessage()

func (*KeyValues) Reset 

func (m *KeyValues) Reset()

func (*KeyValues) String 

func (m *KeyValues) String() string

func (*KeyValues) XXX_DiscardUnknown 

func (m *KeyValues) XXX_DiscardUnknown()

func (*KeyValues) XXX_Marshal 

func (m *KeyValues) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyValues) XXX_Merge 

func (m *KeyValues) XXX_Merge(src proto.Message)

func (*KeyValues) XXX_Size 

func (m *KeyValues) XXX_Size() int

func (*KeyValues) XXX_Unmarshal 

func (m *KeyValues) XXX_Unmarshal(b []byte) error

type MoveReq 

type MoveReq struct {
	KLs                  []*KeyList `protobuf:"bytes,1,rep,name=KLs,proto3" json:"KLs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*MoveReq) Descriptor 

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

func (*MoveReq) GetKLs 

func (m *MoveReq) GetKLs() []*KeyList

func (*MoveReq) ProtoMessage 

func (*MoveReq) ProtoMessage()

func (*MoveReq) Reset 

func (m *MoveReq) Reset()

func (*MoveReq) String 

func (m *MoveReq) String() string

func (*MoveReq) XXX_DiscardUnknown 

func (m *MoveReq) XXX_DiscardUnknown()

func (*MoveReq) XXX_Marshal 

func (m *MoveReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MoveReq) XXX_Merge 

func (m *MoveReq) XXX_Merge(src proto.Message)

func (*MoveReq) XXX_Size 

func (m *MoveReq) XXX_Size() int

func (*MoveReq) XXX_Unmarshal 

func (m *MoveReq) XXX_Unmarshal(b []byte) error

type NodeMeta 

type NodeMeta struct {
	ID                   string       `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Address              string       `protobuf:"bytes,2,opt,name=Address,proto3" json:"Address,omitempty"`
	RPCAddress           string       `protobuf:"bytes,3,opt,name=RPCAddress,proto3" json:"RPCAddress,omitempty"`
	Power                float64      `protobuf:"fixed64,4,opt,name=Power,proto3" json:"Power,omitempty"`
	Capacity             float64      `protobuf:"fixed64,6,opt,name=Capacity,proto3" json:"Capacity,omitempty"`
	Check                *HealthCheck `protobuf:"bytes,7,opt,name=Check,proto3" json:"Check,omitempty"`
	Geo                  *GeoData     `protobuf:"bytes,8,opt,name=Geo,proto3" json:"Geo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*NodeMeta) Descriptor 

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

func (*NodeMeta) GetAddress 

func (m *NodeMeta) GetAddress() string

func (*NodeMeta) GetCapacity 

func (m *NodeMeta) GetCapacity() float64

func (*NodeMeta) GetCheck 

func (m *NodeMeta) GetCheck() *HealthCheck

func (*NodeMeta) GetGeo 

func (m *NodeMeta) GetGeo() *GeoData

func (*NodeMeta) GetID 

func (m *NodeMeta) GetID() string

func (*NodeMeta) GetPower 

func (m *NodeMeta) GetPower() float64

func (*NodeMeta) GetRPCAddress 

func (m *NodeMeta) GetRPCAddress() string

func (*NodeMeta) ProtoMessage 

func (*NodeMeta) ProtoMessage()

func (*NodeMeta) Reset 

func (m *NodeMeta) Reset()

func (*NodeMeta) String 

func (m *NodeMeta) String() string

func (*NodeMeta) XXX_DiscardUnknown 

func (m *NodeMeta) XXX_DiscardUnknown()

func (*NodeMeta) XXX_Marshal 

func (m *NodeMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeMeta) XXX_Merge 

func (m *NodeMeta) XXX_Merge(src proto.Message)

func (*NodeMeta) XXX_Size 

func (m *NodeMeta) XXX_Size() int

func (*NodeMeta) XXX_Unmarshal 

func (m *NodeMeta) XXX_Unmarshal(b []byte) error

type NodeMetas 

type NodeMetas struct {
	Metas                []*NodeMeta `protobuf:"bytes,1,rep,name=Metas,proto3" json:"Metas,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*NodeMetas) Descriptor 

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

func (*NodeMetas) GetMetas 

func (m *NodeMetas) GetMetas() []*NodeMeta

func (*NodeMetas) ProtoMessage 

func (*NodeMetas) ProtoMessage()

func (*NodeMetas) Reset 

func (m *NodeMetas) Reset()

func (*NodeMetas) String 

func (m *NodeMetas) String() string

func (*NodeMetas) XXX_DiscardUnknown 

func (m *NodeMetas) XXX_DiscardUnknown()

func (*NodeMetas) XXX_Marshal 

func (m *NodeMetas) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeMetas) XXX_Merge 

func (m *NodeMetas) XXX_Merge(src proto.Message)

func (*NodeMetas) XXX_Size 

func (m *NodeMetas) XXX_Size() int

func (*NodeMetas) XXX_Unmarshal 

func (m *NodeMetas) XXX_Unmarshal(b []byte) error

type Ping 

type Ping struct {
	NodeID               string   `protobuf:"bytes,1,opt,name=NodeID,proto3" json:"NodeID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Ping) Descriptor 

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

func (*Ping) GetNodeID 

func (m *Ping) GetNodeID() string

func (*Ping) ProtoMessage 

func (*Ping) ProtoMessage()

func (*Ping) Reset 

func (m *Ping) Reset()

func (*Ping) String 

func (m *Ping) String() string

func (*Ping) XXX_DiscardUnknown 

func (m *Ping) XXX_DiscardUnknown()

func (*Ping) XXX_Marshal 

func (m *Ping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ping) XXX_Merge 

func (m *Ping) XXX_Merge(src proto.Message)

func (*Ping) XXX_Size 

func (m *Ping) XXX_Size() int

func (*Ping) XXX_Unmarshal 

func (m *Ping) XXX_Unmarshal(b []byte) error

type RPCBalancerClient 

type RPCBalancerClient interface {
	RPCRegister(ctx context.Context, in *NodeMeta, opts ...grpc.CallOption) (*Empty, error)
	RPCHeartbeat(ctx context.Context, in *Ping, opts ...grpc.CallOption) (*Empty, error)
}

RPCBalancerClient is the client API for RPCBalancer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRPCBalancerClient 

func NewRPCBalancerClient(cc grpc.ClientConnInterface) RPCBalancerClient

type RPCBalancerServer 

type RPCBalancerServer interface {
	RPCRegister(context.Context, *NodeMeta) (*Empty, error)
	RPCHeartbeat(context.Context, *Ping) (*Empty, error)
}

RPCBalancerServer is the server API for RPCBalancer service.

type RPCCapacityClient 

type RPCCapacityClient interface {
	RPCGet(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Capacity, error)
}

RPCCapacityClient is the client API for RPCCapacity service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRPCCapacityClient 

func NewRPCCapacityClient(cc grpc.ClientConnInterface) RPCCapacityClient

type RPCCapacityServer 

type RPCCapacityServer interface {
	RPCGet(context.Context, *Empty) (*Capacity, error)
}

RPCCapacityServer is the server API for RPCCapacity service.

type RPCNodeClient 

type RPCNodeClient interface {
	RPCStore(ctx context.Context, in *KeyValue, opts ...grpc.CallOption) (*DataItem, error)
	RPCStorePairs(ctx context.Context, in *KeyValues, opts ...grpc.CallOption) (*DataItems, error)
	RPCReceive(ctx context.Context, in *DataItems, opts ...grpc.CallOption) (*KeyValues, error)
	RPCRemove(ctx context.Context, in *DataItems, opts ...grpc.CallOption) (*DataItems, error)
	RPCExplore(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DataItems, error)
	RPCMeta(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*NodeMeta, error)
	RPCMove(ctx context.Context, in *MoveReq, opts ...grpc.CallOption) (*Empty, error)
}

RPCNodeClient is the client API for RPCNode service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRPCNodeClient 

func NewRPCNodeClient(cc grpc.ClientConnInterface) RPCNodeClient

type RPCNodeServer 

type RPCNodeServer interface {
	RPCStore(context.Context, *KeyValue) (*DataItem, error)
	RPCStorePairs(context.Context, *KeyValues) (*DataItems, error)
	RPCReceive(context.Context, *DataItems) (*KeyValues, error)
	RPCRemove(context.Context, *DataItems) (*DataItems, error)
	RPCExplore(context.Context, *Empty) (*DataItems, error)
	RPCMeta(context.Context, *Empty) (*NodeMeta, error)
	RPCMove(context.Context, *MoveReq) (*Empty, error)
}

RPCNodeServer is the server API for RPCNode service.

type UnimplementedRPCBalancerServer 

type UnimplementedRPCBalancerServer struct {
}

UnimplementedRPCBalancerServer can be embedded to have forward compatible implementations.

func (*UnimplementedRPCBalancerServer) RPCHeartbeat 

func (*UnimplementedRPCBalancerServer) RPCHeartbeat(ctx context.Context, req *Ping) (*Empty, error)

func (*UnimplementedRPCBalancerServer) RPCRegister 

func (*UnimplementedRPCBalancerServer) RPCRegister(ctx context.Context, req *NodeMeta) (*Empty, error)

type UnimplementedRPCCapacityServer 

type UnimplementedRPCCapacityServer struct {
}

UnimplementedRPCCapacityServer can be embedded to have forward compatible implementations.

func (*UnimplementedRPCCapacityServer) RPCGet 

func (*UnimplementedRPCCapacityServer) RPCGet(ctx context.Context, req *Empty) (*Capacity, error)

type UnimplementedRPCNodeServer 

type UnimplementedRPCNodeServer struct {
}

UnimplementedRPCNodeServer can be embedded to have forward compatible implementations.

func (*UnimplementedRPCNodeServer) RPCExplore 

func (*UnimplementedRPCNodeServer) RPCExplore(ctx context.Context, req *Empty) (*DataItems, error)

func (*UnimplementedRPCNodeServer) RPCMeta 

func (*UnimplementedRPCNodeServer) RPCMeta(ctx context.Context, req *Empty) (*NodeMeta, error)

func (*UnimplementedRPCNodeServer) RPCMove 

func (*UnimplementedRPCNodeServer) RPCMove(ctx context.Context, req *MoveReq) (*Empty, error)

func (*UnimplementedRPCNodeServer) RPCReceive 

func (*UnimplementedRPCNodeServer) RPCReceive(ctx context.Context, req *DataItems) (*KeyValues, error)

func (*UnimplementedRPCNodeServer) RPCRemove 

func (*UnimplementedRPCNodeServer) RPCRemove(ctx context.Context, req *DataItems) (*DataItems, error)

func (*UnimplementedRPCNodeServer) RPCStore 

func (*UnimplementedRPCNodeServer) RPCStore(ctx context.Context, req *KeyValue) (*DataItem, error)

func (*UnimplementedRPCNodeServer) RPCStorePairs 

func (*UnimplementedRPCNodeServer) RPCStorePairs(ctx context.Context, req *KeyValues) (*DataItems, error)

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.