service

Documentation

Overview

Package service is a testing service for the integration tests.

Index

• Variables
• func DRPCRegisterService(mux drpc.Mux, impl DRPCServiceServer) error
• func Equal(a, b drpc.Message) bool
• type DRPCServiceClient
  • func NewDRPCServiceClient(cc drpc.Conn) DRPCServiceClient
• type DRPCServiceDescription
  • func (DRPCServiceDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)
  • func (DRPCServiceDescription) NumMethods() int
• type DRPCServiceServer
• type DRPCServiceUnimplementedServer
  • func (s *DRPCServiceUnimplementedServer) Method1(context.Context, *In) (*Out, error)
  • func (s *DRPCServiceUnimplementedServer) Method2(DRPCService_Method2Stream) error
  • func (s *DRPCServiceUnimplementedServer) Method3(*In, DRPCService_Method3Stream) error
  • func (s *DRPCServiceUnimplementedServer) Method4(DRPCService_Method4Stream) error
• type DRPCService_Method1Stream
• type DRPCService_Method2Client
• type DRPCService_Method2Stream
• type DRPCService_Method3Client
• type DRPCService_Method3Stream
• type DRPCService_Method4Client
• type DRPCService_Method4Stream
• type In
  • func (*In) Descriptor() ([]byte, []int)
  • func (x *In) GetData() []byte
  • func (x *In) GetIn() int64
  • func (*In) ProtoMessage()
  • func (x *In) ProtoReflect() protoreflect.Message
  • func (x *In) Reset()
  • func (x *In) String() string
• type Out
  • func (*Out) Descriptor() ([]byte, []int)
  • func (x *Out) GetData() []byte
  • func (x *Out) GetOut() int64
  • func (*Out) ProtoMessage()
  • func (x *Out) ProtoReflect() protoreflect.Message
  • func (x *Out) Reset()
  • func (x *Out) String() string

Variables

var Encoding drpcEncoding_File_service_proto

Encoding is the drpc.Encoding used for this service.

var File_service_proto protoreflect.FileDescriptor

Functions

func DRPCRegisterService

func DRPCRegisterService(mux drpc.Mux, impl DRPCServiceServer) error

func Equal

func Equal(a, b drpc.Message) bool

Equal returns true if the two messages are equal.

Types

type DRPCServiceClient

type DRPCServiceClient interface {
	DRPCConn() drpc.Conn

	Method1(ctx context.Context, in *In) (*Out, error)
	Method2(ctx context.Context) (DRPCService_Method2Client, error)
	Method3(ctx context.Context, in *In) (DRPCService_Method3Client, error)
	Method4(ctx context.Context) (DRPCService_Method4Client, error)
}

func NewDRPCServiceClient

func NewDRPCServiceClient(cc drpc.Conn) DRPCServiceClient

type DRPCServiceDescription

type DRPCServiceDescription struct{}

func (DRPCServiceDescription) Method

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

func (DRPCServiceDescription) NumMethods

func (DRPCServiceDescription) NumMethods() int

type DRPCServiceServer

type DRPCServiceServer interface {
	Method1(context.Context, *In) (*Out, error)
	Method2(DRPCService_Method2Stream) error
	Method3(*In, DRPCService_Method3Stream) error
	Method4(DRPCService_Method4Stream) error
}

type DRPCServiceUnimplementedServer

type DRPCServiceUnimplementedServer struct{}

func (*DRPCServiceUnimplementedServer) Method1

func (s *DRPCServiceUnimplementedServer) Method1(context.Context, *In) (*Out, error)

func (*DRPCServiceUnimplementedServer) Method2

func (s *DRPCServiceUnimplementedServer) Method2(DRPCService_Method2Stream) error

func (*DRPCServiceUnimplementedServer) Method3

func (s *DRPCServiceUnimplementedServer) Method3(*In, DRPCService_Method3Stream) error

func (*DRPCServiceUnimplementedServer) Method4

func (s *DRPCServiceUnimplementedServer) Method4(DRPCService_Method4Stream) error

type DRPCService_Method1Stream

type DRPCService_Method1Stream interface {
	drpc.Stream
	SendAndClose(*Out) error
}

type DRPCService_Method2Client

type DRPCService_Method2Client interface {
	drpc.Stream
	Send(*In) error
	CloseAndRecv() (*Out, error)
}

type DRPCService_Method2Stream

type DRPCService_Method2Stream interface {
	drpc.Stream
	SendAndClose(*Out) error
	Recv() (*In, error)
}

type DRPCService_Method3Client

type DRPCService_Method3Client interface {
	drpc.Stream
	Recv() (*Out, error)
}

type DRPCService_Method3Stream

type DRPCService_Method3Stream interface {
	drpc.Stream
	Send(*Out) error
}

type DRPCService_Method4Client

type DRPCService_Method4Client interface {
	drpc.Stream
	Send(*In) error
	Recv() (*Out, error)
}

type DRPCService_Method4Stream

type DRPCService_Method4Stream interface {
	drpc.Stream
	Send(*Out) error
	Recv() (*In, error)
}

type In

type In struct {
	In   int64  `protobuf:"varint,1,opt,name=in,proto3" json:"in,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*In) Descriptor

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

Deprecated: Use In.ProtoReflect.Descriptor instead.

func (*In) GetData

func (x *In) GetData() []byte

func (*In) GetIn

func (x *In) GetIn() int64

func (*In) ProtoMessage

func (*In) ProtoMessage()

func (*In) ProtoReflect

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

func (*In) Reset

func (x *In) Reset()

func (*In) String

func (x *In) String() string

type Out

type Out struct {
	Out  int64  `protobuf:"varint,1,opt,name=out,proto3" json:"out,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Out) Descriptor

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

Deprecated: Use Out.ProtoReflect.Descriptor instead.

func (*Out) GetData

func (x *Out) GetData() []byte

func (*Out) GetOut

func (x *Out) GetOut() int64

func (*Out) ProtoMessage

func (*Out) ProtoMessage()

func (*Out) ProtoReflect

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

func (*Out) Reset

func (x *Out) Reset()

func (*Out) String

func (x *Out) String() string