peering

package
v0.1.2 Latest Latest
Warning

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

Go to latest
Published: Aug 3, 2021 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_peering_proto protoreflect.FileDescriptor
View Source
var Node_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mcc.fred.peering.Node",
	HandlerType: (*NodeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateKeygroup",
			Handler:    _Node_CreateKeygroup_Handler,
		},
		{
			MethodName: "DeleteKeygroup",
			Handler:    _Node_DeleteKeygroup_Handler,
		},
		{
			MethodName: "PutItem",
			Handler:    _Node_PutItem_Handler,
		},
		{
			MethodName: "AppendItem",
			Handler:    _Node_AppendItem_Handler,
		},
		{
			MethodName: "GetItem",
			Handler:    _Node_GetItem_Handler,
		},
		{
			MethodName: "GetAllItems",
			Handler:    _Node_GetAllItems_Handler,
		},
		{
			MethodName: "DeleteItem",
			Handler:    _Node_DeleteItem_Handler,
		},
		{
			MethodName: "AddReplica",
			Handler:    _Node_AddReplica_Handler,
		},
		{
			MethodName: "RemoveReplica",
			Handler:    _Node_RemoveReplica_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "peering.proto",
}

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

Functions

func RegisterNodeServer

func RegisterNodeServer(s grpc.ServiceRegistrar, srv NodeServer)

Types

type AddReplicaRequest

type AddReplicaRequest struct {
	NodeId   string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	Keygroup string `protobuf:"bytes,2,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Expiry   int64  `protobuf:"varint,3,opt,name=expiry,proto3" json:"expiry,omitempty"`
	// contains filtered or unexported fields
}

func (*AddReplicaRequest) Descriptor deprecated

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

Deprecated: Use AddReplicaRequest.ProtoReflect.Descriptor instead.

func (*AddReplicaRequest) GetExpiry

func (x *AddReplicaRequest) GetExpiry() int64

func (*AddReplicaRequest) GetKeygroup

func (x *AddReplicaRequest) GetKeygroup() string

func (*AddReplicaRequest) GetNodeId

func (x *AddReplicaRequest) GetNodeId() string

func (*AddReplicaRequest) ProtoMessage

func (*AddReplicaRequest) ProtoMessage()

func (*AddReplicaRequest) ProtoReflect

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

func (*AddReplicaRequest) Reset

func (x *AddReplicaRequest) Reset()

func (*AddReplicaRequest) String

func (x *AddReplicaRequest) String() string

type AppendItemRequest

type AppendItemRequest struct {
	Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Id       string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Data     string `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendItemRequest) Descriptor deprecated

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

Deprecated: Use AppendItemRequest.ProtoReflect.Descriptor instead.

func (*AppendItemRequest) GetData

func (x *AppendItemRequest) GetData() string

func (*AppendItemRequest) GetId

func (x *AppendItemRequest) GetId() string

func (*AppendItemRequest) GetKeygroup

func (x *AppendItemRequest) GetKeygroup() string

func (*AppendItemRequest) ProtoMessage

func (*AppendItemRequest) ProtoMessage()

func (*AppendItemRequest) ProtoReflect

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

func (*AppendItemRequest) Reset

func (x *AppendItemRequest) Reset()

func (*AppendItemRequest) String

func (x *AppendItemRequest) String() string

type CreateKeygroupRequest

type CreateKeygroupRequest struct {
	Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Expiry   int64  `protobuf:"varint,2,opt,name=expiry,proto3" json:"expiry,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateKeygroupRequest) Descriptor deprecated

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

Deprecated: Use CreateKeygroupRequest.ProtoReflect.Descriptor instead.

func (*CreateKeygroupRequest) GetExpiry

func (x *CreateKeygroupRequest) GetExpiry() int64

func (*CreateKeygroupRequest) GetKeygroup

func (x *CreateKeygroupRequest) GetKeygroup() string

func (*CreateKeygroupRequest) ProtoMessage

func (*CreateKeygroupRequest) ProtoMessage()

func (*CreateKeygroupRequest) ProtoReflect

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

func (*CreateKeygroupRequest) Reset

func (x *CreateKeygroupRequest) Reset()

func (*CreateKeygroupRequest) String

func (x *CreateKeygroupRequest) String() string

type Data

type Data struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Data string `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Data) Descriptor deprecated

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

Deprecated: Use Data.ProtoReflect.Descriptor instead.

func (*Data) GetData

func (x *Data) GetData() string

func (*Data) GetId

func (x *Data) GetId() string

func (*Data) ProtoMessage

func (*Data) ProtoMessage()

func (*Data) ProtoReflect

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

func (*Data) Reset

func (x *Data) Reset()

func (*Data) String

func (x *Data) String() string

type DeleteItemRequest

type DeleteItemRequest struct {
	Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Id       string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteItemRequest) Descriptor deprecated

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

Deprecated: Use DeleteItemRequest.ProtoReflect.Descriptor instead.

func (*DeleteItemRequest) GetId

func (x *DeleteItemRequest) GetId() string

func (*DeleteItemRequest) GetKeygroup

func (x *DeleteItemRequest) GetKeygroup() string

func (*DeleteItemRequest) ProtoMessage

func (*DeleteItemRequest) ProtoMessage()

func (*DeleteItemRequest) ProtoReflect

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

func (*DeleteItemRequest) Reset

func (x *DeleteItemRequest) Reset()

func (*DeleteItemRequest) String

func (x *DeleteItemRequest) String() string

type DeleteKeygroupRequest

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

func (*DeleteKeygroupRequest) Descriptor deprecated

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

Deprecated: Use DeleteKeygroupRequest.ProtoReflect.Descriptor instead.

func (*DeleteKeygroupRequest) GetKeygroup

func (x *DeleteKeygroupRequest) GetKeygroup() string

func (*DeleteKeygroupRequest) ProtoMessage

func (*DeleteKeygroupRequest) ProtoMessage()

func (*DeleteKeygroupRequest) ProtoReflect

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

func (*DeleteKeygroupRequest) Reset

func (x *DeleteKeygroupRequest) Reset()

func (*DeleteKeygroupRequest) String

func (x *DeleteKeygroupRequest) String() string

type Empty

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

func (*Empty) Descriptor deprecated

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect

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

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) String

func (x *Empty) String() string

type GetAllItemsRequest

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

func (*GetAllItemsRequest) Descriptor deprecated

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

Deprecated: Use GetAllItemsRequest.ProtoReflect.Descriptor instead.

func (*GetAllItemsRequest) GetKeygroup

func (x *GetAllItemsRequest) GetKeygroup() string

func (*GetAllItemsRequest) ProtoMessage

func (*GetAllItemsRequest) ProtoMessage()

func (*GetAllItemsRequest) ProtoReflect

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

func (*GetAllItemsRequest) Reset

func (x *GetAllItemsRequest) Reset()

func (*GetAllItemsRequest) String

func (x *GetAllItemsRequest) String() string

type GetAllItemsResponse

type GetAllItemsResponse struct {
	Data []*Data `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAllItemsResponse) Descriptor deprecated

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

Deprecated: Use GetAllItemsResponse.ProtoReflect.Descriptor instead.

func (*GetAllItemsResponse) GetData

func (x *GetAllItemsResponse) GetData() []*Data

func (*GetAllItemsResponse) ProtoMessage

func (*GetAllItemsResponse) ProtoMessage()

func (*GetAllItemsResponse) ProtoReflect

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

func (*GetAllItemsResponse) Reset

func (x *GetAllItemsResponse) Reset()

func (*GetAllItemsResponse) String

func (x *GetAllItemsResponse) String() string

type GetItemRequest

type GetItemRequest struct {
	Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Id       string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetItemRequest) Descriptor deprecated

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

Deprecated: Use GetItemRequest.ProtoReflect.Descriptor instead.

func (*GetItemRequest) GetId

func (x *GetItemRequest) GetId() string

func (*GetItemRequest) GetKeygroup

func (x *GetItemRequest) GetKeygroup() string

func (*GetItemRequest) ProtoMessage

func (*GetItemRequest) ProtoMessage()

func (*GetItemRequest) ProtoReflect

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

func (*GetItemRequest) Reset

func (x *GetItemRequest) Reset()

func (*GetItemRequest) String

func (x *GetItemRequest) String() string

type GetItemResponse

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

func (*GetItemResponse) Descriptor deprecated

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

Deprecated: Use GetItemResponse.ProtoReflect.Descriptor instead.

func (*GetItemResponse) GetData

func (x *GetItemResponse) GetData() string

func (*GetItemResponse) ProtoMessage

func (*GetItemResponse) ProtoMessage()

func (*GetItemResponse) ProtoReflect

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

func (*GetItemResponse) Reset

func (x *GetItemResponse) Reset()

func (*GetItemResponse) String

func (x *GetItemResponse) String() string

type NodeClient

type NodeClient interface {
	CreateKeygroup(ctx context.Context, in *CreateKeygroupRequest, opts ...grpc.CallOption) (*Empty, error)
	DeleteKeygroup(ctx context.Context, in *DeleteKeygroupRequest, opts ...grpc.CallOption) (*Empty, error)
	PutItem(ctx context.Context, in *PutItemRequest, opts ...grpc.CallOption) (*Empty, error)
	AppendItem(ctx context.Context, in *AppendItemRequest, opts ...grpc.CallOption) (*Empty, error)
	GetItem(ctx context.Context, in *GetItemRequest, opts ...grpc.CallOption) (*GetItemResponse, error)
	GetAllItems(ctx context.Context, in *GetAllItemsRequest, opts ...grpc.CallOption) (*GetAllItemsResponse, error)
	DeleteItem(ctx context.Context, in *DeleteItemRequest, opts ...grpc.CallOption) (*Empty, error)
	AddReplica(ctx context.Context, in *AddReplicaRequest, opts ...grpc.CallOption) (*Empty, error)
	RemoveReplica(ctx context.Context, in *RemoveReplicaRequest, opts ...grpc.CallOption) (*Empty, error)
}

NodeClient is the client API for Node 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 NewNodeClient

func NewNodeClient(cc grpc.ClientConnInterface) NodeClient

type NodeServer

NodeServer is the server API for Node service. All implementations should embed UnimplementedNodeServer for forward compatibility

type PutItemRequest

type PutItemRequest struct {
	Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Id       string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Data     string `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PutItemRequest) Descriptor deprecated

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

Deprecated: Use PutItemRequest.ProtoReflect.Descriptor instead.

func (*PutItemRequest) GetData

func (x *PutItemRequest) GetData() string

func (*PutItemRequest) GetId

func (x *PutItemRequest) GetId() string

func (*PutItemRequest) GetKeygroup

func (x *PutItemRequest) GetKeygroup() string

func (*PutItemRequest) ProtoMessage

func (*PutItemRequest) ProtoMessage()

func (*PutItemRequest) ProtoReflect

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

func (*PutItemRequest) Reset

func (x *PutItemRequest) Reset()

func (*PutItemRequest) String

func (x *PutItemRequest) String() string

type RemoveReplicaRequest

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

func (*RemoveReplicaRequest) Descriptor deprecated

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

Deprecated: Use RemoveReplicaRequest.ProtoReflect.Descriptor instead.

func (*RemoveReplicaRequest) GetKeygroup

func (x *RemoveReplicaRequest) GetKeygroup() string

func (*RemoveReplicaRequest) GetNodeId

func (x *RemoveReplicaRequest) GetNodeId() string

func (*RemoveReplicaRequest) ProtoMessage

func (*RemoveReplicaRequest) ProtoMessage()

func (*RemoveReplicaRequest) ProtoReflect

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

func (*RemoveReplicaRequest) Reset

func (x *RemoveReplicaRequest) Reset()

func (*RemoveReplicaRequest) String

func (x *RemoveReplicaRequest) String() string

type UnimplementedNodeServer

type UnimplementedNodeServer struct {
}

UnimplementedNodeServer should be embedded to have forward compatible implementations.

func (UnimplementedNodeServer) AddReplica

func (UnimplementedNodeServer) AppendItem

func (UnimplementedNodeServer) CreateKeygroup

func (UnimplementedNodeServer) DeleteItem

func (UnimplementedNodeServer) DeleteKeygroup

func (UnimplementedNodeServer) GetAllItems

func (UnimplementedNodeServer) GetItem

func (UnimplementedNodeServer) PutItem

func (UnimplementedNodeServer) RemoveReplica

type UnsafeNodeServer

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

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

type UpdateItemRequest

type UpdateItemRequest struct {
	Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Id       string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Data     string `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateItemRequest) Descriptor deprecated

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

Deprecated: Use UpdateItemRequest.ProtoReflect.Descriptor instead.

func (*UpdateItemRequest) GetData

func (x *UpdateItemRequest) GetData() string

func (*UpdateItemRequest) GetId

func (x *UpdateItemRequest) GetId() string

func (*UpdateItemRequest) GetKeygroup

func (x *UpdateItemRequest) GetKeygroup() string

func (*UpdateItemRequest) ProtoMessage

func (*UpdateItemRequest) ProtoMessage()

func (*UpdateItemRequest) ProtoReflect

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

func (*UpdateItemRequest) Reset

func (x *UpdateItemRequest) Reset()

func (*UpdateItemRequest) String

func (x *UpdateItemRequest) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL