peering

package
v0.1.7 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 

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

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) AddReplica(context.Context, *AddReplicaRequest) (*Empty, error)

func (UnimplementedNodeServer) AppendItem 

func (UnimplementedNodeServer) AppendItem(context.Context, *AppendItemRequest) (*Empty, error)

func (UnimplementedNodeServer) CreateKeygroup 

func (UnimplementedNodeServer) CreateKeygroup(context.Context, *CreateKeygroupRequest) (*Empty, error)

func (UnimplementedNodeServer) DeleteItem 

func (UnimplementedNodeServer) DeleteItem(context.Context, *DeleteItemRequest) (*Empty, error)

func (UnimplementedNodeServer) DeleteKeygroup 

func (UnimplementedNodeServer) DeleteKeygroup(context.Context, *DeleteKeygroupRequest) (*Empty, error)

func (UnimplementedNodeServer) GetAllItems 

func (UnimplementedNodeServer) GetAllItems(context.Context, *GetAllItemsRequest) (*GetAllItemsResponse, error)

func (UnimplementedNodeServer) GetItem 

func (UnimplementedNodeServer) GetItem(context.Context, *GetItemRequest) (*GetItemResponse, error)

func (UnimplementedNodeServer) PutItem 

func (UnimplementedNodeServer) PutItem(context.Context, *PutItemRequest) (*Empty, error)

func (UnimplementedNodeServer) RemoveReplica 

func (UnimplementedNodeServer) RemoveReplica(context.Context, *RemoveReplicaRequest) (*Empty, error)

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

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.