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
  • func (s *DRPCTestUnimplementedServer) TestStream2(*StreamMessage, DRPCTest_TestStream2Stream) error
• type DRPCTest_TestStream2Client
• type DRPCTest_TestStream2Stream
• type DRPCTest_TestStreamClient
• type DRPCTest_TestStreamStream
• type StreamMessage
  • func (*StreamMessage) Descriptor() ([]byte, []int)
  • func (x *StreamMessage) GetRepeat() int64
  • func (x *StreamMessage) GetReqData() string
  • func (m *StreamMessage) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *StreamMessage) MarshalToVT(dAtA []byte) (int, error)
  • func (m *StreamMessage) MarshalVT() (dAtA []byte, err error)
  • func (*StreamMessage) ProtoMessage()
  • func (x *StreamMessage) ProtoReflect() protoreflect.Message
  • func (x *StreamMessage) Reset()
  • func (m *StreamMessage) SizeVT() (n int)
  • func (x *StreamMessage) String() string
  • func (m *StreamMessage) UnmarshalVT(dAtA []byte) error

Variables

var File_net_streampool_testservice_protos_testservice_proto protoreflect.FileDescriptor

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)
	TestStream2(ctx context.Context, in *StreamMessage) (DRPCTest_TestStream2Client, 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
	TestStream2(*StreamMessage, DRPCTest_TestStream2Stream) error
}

type DRPCTestUnimplementedServer

type DRPCTestUnimplementedServer struct{}

func (*DRPCTestUnimplementedServer) TestStream

func (s *DRPCTestUnimplementedServer) TestStream(DRPCTest_TestStreamStream) error

func (*DRPCTestUnimplementedServer) TestStream2

func (s *DRPCTestUnimplementedServer) TestStream2(*StreamMessage, DRPCTest_TestStream2Stream) error

type DRPCTest_TestStream2Client

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

type DRPCTest_TestStream2Stream

type DRPCTest_TestStream2Stream interface {
	drpc.Stream
	Send(*StreamMessage) 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"`
	Repeat  int64  `protobuf:"varint,2,opt,name=repeat,proto3" json:"repeat,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamMessage) Descriptor

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

Deprecated: Use StreamMessage.ProtoReflect.Descriptor instead.

func (*StreamMessage) GetRepeat

func (x *StreamMessage) GetRepeat() int64

func (*StreamMessage) GetReqData

func (x *StreamMessage) GetReqData() string

func (*StreamMessage) MarshalToSizedBufferVT

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

func (*StreamMessage) MarshalToVT

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

func (*StreamMessage) MarshalVT

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

func (*StreamMessage) ProtoMessage

func (*StreamMessage) ProtoMessage()

func (*StreamMessage) ProtoReflect

func (x *StreamMessage) ProtoReflect() protoreflect.Message

func (*StreamMessage) Reset

func (x *StreamMessage) Reset()

func (*StreamMessage) SizeVT

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

func (*StreamMessage) String

func (x *StreamMessage) String() string

func (*StreamMessage) UnmarshalVT

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