testservice

Documentation

Index

• Variables
• func DRPCRegisterTest(mux drpc.Mux, impl DRPCTestServer) error
• type DRPCTestClient
  • func NewDRPCTestClient(cc drpc.Conn) DRPCTestClient
• type DRPCTestDescription
  • func (DRPCTestDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)
  • func (DRPCTestDescription) NumMethods() int
• type DRPCTestServer
• type DRPCTestUnimplementedServer
  • func (s *DRPCTestUnimplementedServer) TestStream(DRPCTest_TestStreamStream) error
• type DRPCTest_TestStreamClient
• type DRPCTest_TestStreamStream
• type StreamMessage
  • func (*StreamMessage) Descriptor() ([]byte, []int)
  • func (m *StreamMessage) GetReqData() string
  • func (m *StreamMessage) Marshal() (dAtA []byte, err error)
  • func (m *StreamMessage) MarshalTo(dAtA []byte) (int, error)
  • func (m *StreamMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*StreamMessage) ProtoMessage()
  • func (m *StreamMessage) Reset()
  • func (m *StreamMessage) Size() (n int)
  • func (m *StreamMessage) String() string
  • func (m *StreamMessage) Unmarshal(dAtA []byte) error
  • func (m *StreamMessage) XXX_DiscardUnknown()
  • func (m *StreamMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *StreamMessage) XXX_Merge(src proto.Message)
  • func (m *StreamMessage) XXX_Size() int
  • func (m *StreamMessage) XXX_Unmarshal(b []byte) error

Variables

var (
	ErrInvalidLengthTestservice        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTestservice          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTestservice = fmt.Errorf("proto: unexpected end of group")
)

Functions

func DRPCRegisterTest

func DRPCRegisterTest(mux drpc.Mux, impl DRPCTestServer) error

Types

type DRPCTestClient

type DRPCTestClient interface {
	DRPCConn() drpc.Conn

	TestStream(ctx context.Context) (DRPCTest_TestStreamClient, error)
}

func NewDRPCTestClient

func NewDRPCTestClient(cc drpc.Conn) DRPCTestClient

type DRPCTestDescription

type DRPCTestDescription struct{}

func (DRPCTestDescription) Method

func (DRPCTestDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

func (DRPCTestDescription) NumMethods

func (DRPCTestDescription) NumMethods() int

type DRPCTestServer

type DRPCTestServer interface {
	TestStream(DRPCTest_TestStreamStream) error
}

type DRPCTestUnimplementedServer

type DRPCTestUnimplementedServer struct{}

func (*DRPCTestUnimplementedServer) TestStream

func (s *DRPCTestUnimplementedServer) TestStream(DRPCTest_TestStreamStream) error

type DRPCTest_TestStreamClient

type DRPCTest_TestStreamClient interface {
	drpc.Stream
	Send(*StreamMessage) error
	Recv() (*StreamMessage, error)
}

type DRPCTest_TestStreamStream

type DRPCTest_TestStreamStream interface {
	drpc.Stream
	Send(*StreamMessage) error
	Recv() (*StreamMessage, error)
}

type StreamMessage

type StreamMessage struct {
	ReqData string `protobuf:"bytes,1,opt,name=reqData,proto3" json:"reqData,omitempty"`
}

func (*StreamMessage) Descriptor

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

func (*StreamMessage) GetReqData

func (m *StreamMessage) GetReqData() string

func (*StreamMessage) Marshal

func (m *StreamMessage) Marshal() (dAtA []byte, err error)

func (*StreamMessage) MarshalTo

func (m *StreamMessage) MarshalTo(dAtA []byte) (int, error)

func (*StreamMessage) MarshalToSizedBuffer

func (m *StreamMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamMessage) ProtoMessage

func (*StreamMessage) ProtoMessage()

func (*StreamMessage) Reset

func (m *StreamMessage) Reset()

func (*StreamMessage) Size

func (m *StreamMessage) Size() (n int)

func (*StreamMessage) String

func (m *StreamMessage) String() string

func (*StreamMessage) Unmarshal

func (m *StreamMessage) Unmarshal(dAtA []byte) error

func (*StreamMessage) XXX_DiscardUnknown

func (m *StreamMessage) XXX_DiscardUnknown()

func (*StreamMessage) XXX_Marshal

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

func (*StreamMessage) XXX_Merge

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

func (*StreamMessage) XXX_Size

func (m *StreamMessage) XXX_Size() int

func (*StreamMessage) XXX_Unmarshal

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