pb

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Mar 7, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Envelope_Type_name = map[int32]string{
	0: "REQUEST_PEERINFO",
	2: "RESPONSE_PEERINFO",
	3: "NORMAL",
}
View Source
var Envelope_Type_value = map[string]int32{
	"REQUEST_PEERINFO":  0,
	"RESPONSE_PEERINFO": 2,
	"NORMAL":            3,
}

Functions

func RegisterStreamServiceServer

func RegisterStreamServiceServer(s *grpc.Server, srv StreamServiceServer)

Types

type Envelope

type Envelope struct {
	// marshalled Message
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// signed Message
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// sender's public key
	Pubkey []byte `protobuf:"bytes,3,opt,name=pubkey,proto3" json:"pubkey,omitempty"`
	// message protocol
	Protocol             string        `protobuf:"bytes,4,opt,name=protocol" json:"protocol,omitempty"`
	Type                 Envelope_Type `protobuf:"varint,5,opt,name=type,enum=pb.Envelope_Type" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Envelope) Descriptor

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

func (*Envelope) GetPayload

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

func (*Envelope) GetProtocol

func (m *Envelope) GetProtocol() string

func (*Envelope) GetPubkey

func (m *Envelope) GetPubkey() []byte

func (*Envelope) GetSignature

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

func (*Envelope) GetType

func (m *Envelope) GetType() Envelope_Type

func (*Envelope) ProtoMessage

func (*Envelope) ProtoMessage()

func (*Envelope) Reset

func (m *Envelope) Reset()

func (*Envelope) String

func (m *Envelope) String() string

func (*Envelope) XXX_DiscardUnknown

func (m *Envelope) XXX_DiscardUnknown()

func (*Envelope) XXX_Marshal

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

func (*Envelope) XXX_Merge

func (dst *Envelope) XXX_Merge(src proto.Message)

func (*Envelope) XXX_Size

func (m *Envelope) XXX_Size() int

func (*Envelope) XXX_Unmarshal

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

type Envelope_Type

type Envelope_Type int32
const (
	Envelope_REQUEST_PEERINFO  Envelope_Type = 0
	Envelope_RESPONSE_PEERINFO Envelope_Type = 2
	Envelope_NORMAL            Envelope_Type = 3
)

func (Envelope_Type) EnumDescriptor

func (Envelope_Type) EnumDescriptor() ([]byte, []int)

func (Envelope_Type) String

func (x Envelope_Type) String() string

type StreamServiceClient

type StreamServiceClient interface {
	BifrostStream(ctx context.Context, opts ...grpc.CallOption) (StreamService_BifrostStreamClient, error)
}

func NewStreamServiceClient

func NewStreamServiceClient(cc *grpc.ClientConn) StreamServiceClient

type StreamServiceServer

type StreamServiceServer interface {
	BifrostStream(StreamService_BifrostStreamServer) error
}

type StreamService_BifrostStreamClient

type StreamService_BifrostStreamClient interface {
	Send(*Envelope) error
	Recv() (*Envelope, error)
	grpc.ClientStream
}

type StreamService_BifrostStreamServer

type StreamService_BifrostStreamServer interface {
	Send(*Envelope) error
	Recv() (*Envelope, error)
	grpc.ServerStream
}

Jump to

Keyboard shortcuts

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