gcgrpc

Documentation

Index

• Variables
• func RegisterPeerServer(s *grpc.Server, srv PeerServer)
• type Ack
  • func (*Ack) Descriptor() ([]byte, []int)
  • func (*Ack) ProtoMessage()
  • func (x *Ack) ProtoReflect() protoreflect.Message
  • func (x *Ack) Reset()
  • func (x *Ack) String() string
• type DeleteRequest
  • func (*DeleteRequest) Descriptor() ([]byte, []int)
  • func (x *DeleteRequest) GetGroup() string
  • func (x *DeleteRequest) GetKey() string
  • func (*DeleteRequest) ProtoMessage()
  • func (x *DeleteRequest) ProtoReflect() protoreflect.Message
  • func (x *DeleteRequest) Reset()
  • func (x *DeleteRequest) String() string
• type PeerClient
  • func NewPeerClient(cc grpc.ClientConnInterface) PeerClient
• type PeerServer
• type Peers
  • func (*Peers) Descriptor() ([]byte, []int)
  • func (x *Peers) GetPeerAddr() []string
  • func (*Peers) ProtoMessage()
  • func (x *Peers) ProtoReflect() protoreflect.Message
  • func (x *Peers) Reset()
  • func (x *Peers) String() string
• type RetrieveRequest
  • func (*RetrieveRequest) Descriptor() ([]byte, []int)
  • func (x *RetrieveRequest) GetGroup() string
  • func (x *RetrieveRequest) GetKey() string
  • func (*RetrieveRequest) ProtoMessage()
  • func (x *RetrieveRequest) ProtoReflect() protoreflect.Message
  • func (x *RetrieveRequest) Reset()
  • func (x *RetrieveRequest) String() string
• type RetrieveResponse
  • func (*RetrieveResponse) Descriptor() ([]byte, []int)
  • func (x *RetrieveResponse) GetValue() []byte
  • func (*RetrieveResponse) ProtoMessage()
  • func (x *RetrieveResponse) ProtoReflect() protoreflect.Message
  • func (x *RetrieveResponse) Reset()
  • func (x *RetrieveResponse) String() string
• type UnimplementedPeerServer
  • func (*UnimplementedPeerServer) AddPeers(context.Context, *Peers) (*Ack, error)
  • func (*UnimplementedPeerServer) Delete(context.Context, *DeleteRequest) (*Ack, error)
  • func (*UnimplementedPeerServer) RemovePeers(context.Context, *Peers) (*Ack, error)
  • func (*UnimplementedPeerServer) Retrieve(context.Context, *RetrieveRequest) (*RetrieveResponse, error)
  • func (*UnimplementedPeerServer) SetPeers(context.Context, *Peers) (*Ack, error)

Variables

var File_gcgrpc_proto protoreflect.FileDescriptor

Functions

func RegisterPeerServer

func RegisterPeerServer(s *grpc.Server, srv PeerServer)

Types

type Ack

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

func (*Ack) Descriptor

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

Deprecated: Use Ack.ProtoReflect.Descriptor instead.

func (*Ack) ProtoMessage

func (*Ack) ProtoMessage()

func (*Ack) ProtoReflect

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

func (*Ack) Reset

func (x *Ack) Reset()

func (*Ack) String

func (x *Ack) String() string

type DeleteRequest

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

func (*DeleteRequest) Descriptor

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetGroup

func (x *DeleteRequest) GetGroup() string

func (*DeleteRequest) GetKey

func (x *DeleteRequest) GetKey() string

func (*DeleteRequest) ProtoMessage

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect

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

func (*DeleteRequest) Reset

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String

func (x *DeleteRequest) String() string

type PeerClient

type PeerClient interface {
	Retrieve(ctx context.Context, in *RetrieveRequest, opts ...grpc.CallOption) (*RetrieveResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*Ack, error)
	AddPeers(ctx context.Context, in *Peers, opts ...grpc.CallOption) (*Ack, error)
	RemovePeers(ctx context.Context, in *Peers, opts ...grpc.CallOption) (*Ack, error)
	SetPeers(ctx context.Context, in *Peers, opts ...grpc.CallOption) (*Ack, error)
}

PeerClient is the client API for Peer service.

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

func NewPeerClient

func NewPeerClient(cc grpc.ClientConnInterface) PeerClient

type PeerServer

type PeerServer interface {
	Retrieve(context.Context, *RetrieveRequest) (*RetrieveResponse, error)
	Delete(context.Context, *DeleteRequest) (*Ack, error)
	AddPeers(context.Context, *Peers) (*Ack, error)
	RemovePeers(context.Context, *Peers) (*Ack, error)
	SetPeers(context.Context, *Peers) (*Ack, error)
}

PeerServer is the server API for Peer service.

type Peers

type Peers struct {
	PeerAddr []string `protobuf:"bytes,1,rep,name=peerAddr,proto3" json:"peerAddr,omitempty"`
	// contains filtered or unexported fields
}

func (*Peers) Descriptor

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

Deprecated: Use Peers.ProtoReflect.Descriptor instead.

func (*Peers) GetPeerAddr

func (x *Peers) GetPeerAddr() []string

func (*Peers) ProtoMessage

func (*Peers) ProtoMessage()

func (*Peers) ProtoReflect

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

func (*Peers) Reset

func (x *Peers) Reset()

func (*Peers) String

func (x *Peers) String() string

type RetrieveRequest

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

func (*RetrieveRequest) Descriptor

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

Deprecated: Use RetrieveRequest.ProtoReflect.Descriptor instead.

func (*RetrieveRequest) GetGroup

func (x *RetrieveRequest) GetGroup() string

func (*RetrieveRequest) GetKey

func (x *RetrieveRequest) GetKey() string

func (*RetrieveRequest) ProtoMessage

func (*RetrieveRequest) ProtoMessage()

func (*RetrieveRequest) ProtoReflect

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

func (*RetrieveRequest) Reset

func (x *RetrieveRequest) Reset()

func (*RetrieveRequest) String

func (x *RetrieveRequest) String() string

type RetrieveResponse

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

func (*RetrieveResponse) Descriptor

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

Deprecated: Use RetrieveResponse.ProtoReflect.Descriptor instead.

func (*RetrieveResponse) GetValue

func (x *RetrieveResponse) GetValue() []byte

func (*RetrieveResponse) ProtoMessage

func (*RetrieveResponse) ProtoMessage()

func (*RetrieveResponse) ProtoReflect

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

func (*RetrieveResponse) Reset

func (x *RetrieveResponse) Reset()

func (*RetrieveResponse) String

func (x *RetrieveResponse) String() string

type UnimplementedPeerServer

type UnimplementedPeerServer struct {
}

UnimplementedPeerServer can be embedded to have forward compatible implementations.

func (*UnimplementedPeerServer) AddPeers

func (*UnimplementedPeerServer) AddPeers(context.Context, *Peers) (*Ack, error)

func (*UnimplementedPeerServer) Delete

func (*UnimplementedPeerServer) Delete(context.Context, *DeleteRequest) (*Ack, error)

func (*UnimplementedPeerServer) RemovePeers

func (*UnimplementedPeerServer) RemovePeers(context.Context, *Peers) (*Ack, error)

func (*UnimplementedPeerServer) Retrieve

func (*UnimplementedPeerServer) Retrieve(context.Context, *RetrieveRequest) (*RetrieveResponse, error)

func (*UnimplementedPeerServer) SetPeers

func (*UnimplementedPeerServer) SetPeers(context.Context, *Peers) (*Ack, error)