pb

Documentation

Index

• func RegisterP2PServiceServer(s *grpc.Server, srv P2PServiceServer)
• type BHMsg
  • func (*BHMsg) Descriptor() ([]byte, []int)
  • func (m *BHMsg) GetPayload() []byte
  • func (m *BHMsg) GetSignature() []byte
  • func (m *BHMsg) GetType() uint32
  • func (*BHMsg) ProtoMessage()
  • func (m *BHMsg) Reset()
  • func (m *BHMsg) String() string
  • func (m *BHMsg) XXX_DiscardUnknown()
  • func (m *BHMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *BHMsg) XXX_Merge(src proto.Message)
  • func (m *BHMsg) XXX_Size() int
  • func (m *BHMsg) XXX_Unmarshal(b []byte) error
• type P2PServiceClient
  • func NewP2PServiceClient(cc *grpc.ClientConn) P2PServiceClient
• type P2PServiceServer
• type P2PService_CommunicateClient
• type P2PService_CommunicateServer
• type UnimplementedP2PServiceServer
  • func (*UnimplementedP2PServiceServer) Communicate(srv P2PService_CommunicateServer) error

Functions

func RegisterP2PServiceServer

func RegisterP2PServiceServer(s *grpc.Server, srv P2PServiceServer)

Types

type BHMsg

type BHMsg struct {
	Signature            []byte   `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
	Payload              []byte   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Type                 uint32   `protobuf:"varint,3,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BHMsg) Descriptor

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

func (*BHMsg) GetPayload

func (m *BHMsg) GetPayload() []byte

func (*BHMsg) GetSignature

func (m *BHMsg) GetSignature() []byte

func (*BHMsg) GetType

func (m *BHMsg) GetType() uint32

func (*BHMsg) ProtoMessage

func (*BHMsg) ProtoMessage()

func (*BHMsg) Reset

func (m *BHMsg) Reset()

func (*BHMsg) String

func (m *BHMsg) String() string

func (*BHMsg) XXX_DiscardUnknown

func (m *BHMsg) XXX_DiscardUnknown()

func (*BHMsg) XXX_Marshal

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

func (*BHMsg) XXX_Merge

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

func (*BHMsg) XXX_Size

func (m *BHMsg) XXX_Size() int

func (*BHMsg) XXX_Unmarshal

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

type P2PServiceClient

type P2PServiceClient interface {
	Communicate(ctx context.Context, opts ...grpc.CallOption) (P2PService_CommunicateClient, error)
}

P2PServiceClient is the client API for P2PService service.

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

func NewP2PServiceClient

func NewP2PServiceClient(cc *grpc.ClientConn) P2PServiceClient

type P2PServiceServer

type P2PServiceServer interface {
	Communicate(P2PService_CommunicateServer) error
}

P2PServiceServer is the server API for P2PService service.

type P2PService_CommunicateClient

type P2PService_CommunicateClient interface {
	Send(*BHMsg) error
	Recv() (*BHMsg, error)
	grpc.ClientStream
}

type P2PService_CommunicateServer

type P2PService_CommunicateServer interface {
	Send(*BHMsg) error
	Recv() (*BHMsg, error)
	grpc.ServerStream
}

type UnimplementedP2PServiceServer

type UnimplementedP2PServiceServer struct {
}

UnimplementedP2PServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedP2PServiceServer) Communicate

func (*UnimplementedP2PServiceServer) Communicate(srv P2PService_CommunicateServer) error