middleware_test

Documentation

Index

• Variables
• func RegisterEchoServerServer(s *grpc.Server, srv EchoServerServer)
• type EchoServerClient
  • func NewEchoServerClient(cc *grpc.ClientConn) EchoServerClient
• type EchoServerServer
• type EchoServer_ProcessClient
• type EchoServer_ProcessServer
• type Msg
  • func (*Msg) Descriptor() ([]byte, []int)
  • func (this *Msg) Equal(that interface{}) bool
  • func (m *Msg) GetBody() []byte
  • func (this *Msg) GoString() string
  • func (m *Msg) Marshal() (dAtA []byte, err error)
  • func (m *Msg) MarshalTo(dAtA []byte) (int, error)
  • func (m *Msg) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Msg) ProtoMessage()
  • func (m *Msg) Reset()
  • func (m *Msg) Size() (n int)
  • func (this *Msg) String() string
  • func (m *Msg) Unmarshal(dAtA []byte) error
  • func (m *Msg) XXX_DiscardUnknown()
  • func (m *Msg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Msg) XXX_Merge(src proto.Message)
  • func (m *Msg) XXX_Size() int
  • func (m *Msg) XXX_Unmarshal(b []byte) error
• type UnimplementedEchoServerServer
  • func (*UnimplementedEchoServerServer) Process(srv EchoServer_ProcessServer) error

Variables

var (
	ErrInvalidLengthEchoServer = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEchoServer   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterEchoServerServer

func RegisterEchoServerServer(s *grpc.Server, srv EchoServerServer)

Types

type EchoServerClient

type EchoServerClient interface {
	Process(ctx context.Context, opts ...grpc.CallOption) (EchoServer_ProcessClient, error)
}

EchoServerClient is the client API for EchoServer service.

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

func NewEchoServerClient

func NewEchoServerClient(cc *grpc.ClientConn) EchoServerClient

type EchoServerServer

type EchoServerServer interface {
	Process(EchoServer_ProcessServer) error
}

EchoServerServer is the server API for EchoServer service.

type EchoServer_ProcessClient

type EchoServer_ProcessClient interface {
	Send(*Msg) error
	Recv() (*Msg, error)
	grpc.ClientStream
}

type EchoServer_ProcessServer

type EchoServer_ProcessServer interface {
	Send(*Msg) error
	Recv() (*Msg, error)
	grpc.ServerStream
}

type Msg

type Msg struct {
	Body []byte `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
}

func (*Msg) Descriptor

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

func (*Msg) Equal

func (this *Msg) Equal(that interface{}) bool

func (*Msg) GetBody

func (m *Msg) GetBody() []byte

func (*Msg) GoString

func (this *Msg) GoString() string

func (*Msg) Marshal

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

func (*Msg) MarshalTo

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

func (*Msg) MarshalToSizedBuffer

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

func (*Msg) ProtoMessage

func (*Msg) ProtoMessage()

func (*Msg) Reset

func (m *Msg) Reset()

func (*Msg) Size

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

func (*Msg) String

func (this *Msg) String() string

func (*Msg) Unmarshal

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

func (*Msg) XXX_DiscardUnknown

func (m *Msg) XXX_DiscardUnknown()

func (*Msg) XXX_Marshal

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

func (*Msg) XXX_Merge

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

func (*Msg) XXX_Size

func (m *Msg) XXX_Size() int

func (*Msg) XXX_Unmarshal

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

type UnimplementedEchoServerServer

type UnimplementedEchoServerServer struct {
}

UnimplementedEchoServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedEchoServerServer) Process

func (*UnimplementedEchoServerServer) Process(srv EchoServer_ProcessServer) error