testproto

Documentation

Index

• func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer)
• type Bytes
  • func (*Bytes) Descriptor() ([]byte, []int)
  • func (m *Bytes) GetData() []byte
  • func (*Bytes) ProtoMessage()
  • func (m *Bytes) Reset()
  • func (m *Bytes) String() string
  • func (m *Bytes) XXX_DiscardUnknown()
  • func (m *Bytes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *Bytes) XXX_Merge(src proto.Message)
  • func (m *Bytes) XXX_Size() int
  • func (m *Bytes) XXX_Unmarshal(b []byte) error
• type TestServiceClient
  • func NewTestServiceClient(cc *grpc.ClientConn) TestServiceClient
• type TestServiceServer
• type TestService_StreamClient
• type TestService_StreamServer

Functions

func RegisterTestServiceServer

func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer)

Types

type Bytes

type Bytes struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Bytes) Descriptor

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

func (*Bytes) GetData

func (m *Bytes) GetData() []byte

func (*Bytes) ProtoMessage

func (*Bytes) ProtoMessage()

func (*Bytes) Reset

func (m *Bytes) Reset()

func (*Bytes) String

func (m *Bytes) String() string

func (*Bytes) XXX_DiscardUnknown

func (m *Bytes) XXX_DiscardUnknown()

func (*Bytes) XXX_Marshal

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

func (*Bytes) XXX_Merge

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

func (*Bytes) XXX_Size

func (m *Bytes) XXX_Size() int

func (*Bytes) XXX_Unmarshal

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

type TestServiceClient

type TestServiceClient interface {
	Stream(ctx context.Context, opts ...grpc.CallOption) (TestService_StreamClient, error)
}

TestServiceClient is the client API for TestService service.

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

func NewTestServiceClient

func NewTestServiceClient(cc *grpc.ClientConn) TestServiceClient

type TestServiceServer

type TestServiceServer interface {
	Stream(TestService_StreamServer) error
}

TestServiceServer is the server API for TestService service.

type TestService_StreamClient

type TestService_StreamClient interface {
	Send(*Bytes) error
	Recv() (*Bytes, error)
	grpc.ClientStream
}

type TestService_StreamServer

type TestService_StreamServer interface {
	Send(*Bytes) error
	Recv() (*Bytes, error)
	grpc.ServerStream
}