test

Documentation

Index

• func RegisterTestServer(s *grpc.Server, srv TestServer)
• type StreamOutputRequest
  • func (*StreamOutputRequest) Descriptor() ([]byte, []int)
  • func (m *StreamOutputRequest) GetBytesToReturn() int32
  • func (*StreamOutputRequest) ProtoMessage()
  • func (m *StreamOutputRequest) Reset()
  • func (m *StreamOutputRequest) String() string
  • func (m *StreamOutputRequest) XXX_DiscardUnknown()
  • func (m *StreamOutputRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *StreamOutputRequest) XXX_Merge(src proto.Message)
  • func (m *StreamOutputRequest) XXX_Size() int
  • func (m *StreamOutputRequest) XXX_Unmarshal(b []byte) error
• type StreamOutputResponse
  • func (*StreamOutputResponse) Descriptor() ([]byte, []int)
  • func (m *StreamOutputResponse) GetMsg() [][]byte
  • func (*StreamOutputResponse) ProtoMessage()
  • func (m *StreamOutputResponse) Reset()
  • func (m *StreamOutputResponse) String() string
  • func (m *StreamOutputResponse) XXX_DiscardUnknown()
  • func (m *StreamOutputResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *StreamOutputResponse) XXX_Merge(src proto.Message)
  • func (m *StreamOutputResponse) XXX_Size() int
  • func (m *StreamOutputResponse) XXX_Unmarshal(b []byte) error
• type TestClient
  • func NewTestClient(cc *grpc.ClientConn) TestClient
• type TestServer
• type Test_StreamOutputClient
• type Test_StreamOutputServer
• type UnimplementedTestServer
  • func (*UnimplementedTestServer) StreamOutput(req *StreamOutputRequest, srv Test_StreamOutputServer) error

Functions

func RegisterTestServer

func RegisterTestServer(s *grpc.Server, srv TestServer)

Types

type StreamOutputRequest

type StreamOutputRequest struct {
	BytesToReturn        int32    `protobuf:"varint,1,opt,name=bytes_to_return,json=bytesToReturn,proto3" json:"bytes_to_return,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamOutputRequest) Descriptor

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

func (*StreamOutputRequest) GetBytesToReturn

func (m *StreamOutputRequest) GetBytesToReturn() int32

func (*StreamOutputRequest) ProtoMessage

func (*StreamOutputRequest) ProtoMessage()

func (*StreamOutputRequest) Reset

func (m *StreamOutputRequest) Reset()

func (*StreamOutputRequest) String

func (m *StreamOutputRequest) String() string

func (*StreamOutputRequest) XXX_DiscardUnknown

func (m *StreamOutputRequest) XXX_DiscardUnknown()

func (*StreamOutputRequest) XXX_Marshal

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

func (*StreamOutputRequest) XXX_Merge

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

func (*StreamOutputRequest) XXX_Size

func (m *StreamOutputRequest) XXX_Size() int

func (*StreamOutputRequest) XXX_Unmarshal

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

type StreamOutputResponse

type StreamOutputResponse struct {
	Msg                  [][]byte `protobuf:"bytes,1,rep,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamOutputResponse) Descriptor

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

func (*StreamOutputResponse) GetMsg

func (m *StreamOutputResponse) GetMsg() [][]byte

func (*StreamOutputResponse) ProtoMessage

func (*StreamOutputResponse) ProtoMessage()

func (*StreamOutputResponse) Reset

func (m *StreamOutputResponse) Reset()

func (*StreamOutputResponse) String

func (m *StreamOutputResponse) String() string

func (*StreamOutputResponse) XXX_DiscardUnknown

func (m *StreamOutputResponse) XXX_DiscardUnknown()

func (*StreamOutputResponse) XXX_Marshal

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

func (*StreamOutputResponse) XXX_Merge

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

func (*StreamOutputResponse) XXX_Size

func (m *StreamOutputResponse) XXX_Size() int

func (*StreamOutputResponse) XXX_Unmarshal

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

type TestClient

type TestClient interface {
	StreamOutput(ctx context.Context, in *StreamOutputRequest, opts ...grpc.CallOption) (Test_StreamOutputClient, error)
}

TestClient is the client API for Test service.

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

func NewTestClient

func NewTestClient(cc *grpc.ClientConn) TestClient

type TestServer

type TestServer interface {
	StreamOutput(*StreamOutputRequest, Test_StreamOutputServer) error
}

TestServer is the server API for Test service.

type Test_StreamOutputClient

type Test_StreamOutputClient interface {
	Recv() (*StreamOutputResponse, error)
	grpc.ClientStream
}

type Test_StreamOutputServer

type Test_StreamOutputServer interface {
	Send(*StreamOutputResponse) error
	grpc.ServerStream
}

type UnimplementedTestServer

type UnimplementedTestServer struct {
}

UnimplementedTestServer can be embedded to have forward compatible implementations.

func (*UnimplementedTestServer) StreamOutput

func (*UnimplementedTestServer) StreamOutput(req *StreamOutputRequest, srv Test_StreamOutputServer) error