rpctest

Documentation

Index

• func RegisterFooBarServer(s *grpc.Server, srv FooBarServer)
• type Bar
  • func (*Bar) Descriptor() ([]byte, []int)
  • func (m *Bar) GetMessage() string
  • func (*Bar) ProtoMessage()
  • func (m *Bar) Reset()
  • func (m *Bar) String() string
  • func (m *Bar) XXX_DiscardUnknown()
  • func (m *Bar) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Bar) XXX_Merge(src proto.Message)
  • func (m *Bar) XXX_Size() int
  • func (m *Bar) XXX_Unmarshal(b []byte) error
• type Foo
  • func (*Foo) Descriptor() ([]byte, []int)
  • func (m *Foo) GetMessage() string
  • func (*Foo) ProtoMessage()
  • func (m *Foo) Reset()
  • func (m *Foo) String() string
  • func (m *Foo) XXX_DiscardUnknown()
  • func (m *Foo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Foo) XXX_Merge(src proto.Message)
  • func (m *Foo) XXX_Size() int
  • func (m *Foo) XXX_Unmarshal(b []byte) error
• type FooBarClient
  • func NewFooBarClient(cc *grpc.ClientConn) FooBarClient
• type FooBarExampleServer
  • func (s *FooBarExampleServer) BidiStream(stream FooBar_BidiStreamServer) error
  • func (s *FooBarExampleServer) ClientStream(stream FooBar_ClientStreamServer) error
  • func (s *FooBarExampleServer) ServerStream(foo *Foo, stream FooBar_ServerStreamServer) error
  • func (s *FooBarExampleServer) Unary(ctx context.Context, foo *Foo) (*Bar, error)
• type FooBarServer
• type FooBar_BidiStreamClient
• type FooBar_BidiStreamServer
• type FooBar_ClientStreamClient
• type FooBar_ClientStreamServer
• type FooBar_ServerStreamClient
• type FooBar_ServerStreamServer
• type UnimplementedFooBarServer
  • func (*UnimplementedFooBarServer) BidiStream(srv FooBar_BidiStreamServer) error
  • func (*UnimplementedFooBarServer) ClientStream(srv FooBar_ClientStreamServer) error
  • func (*UnimplementedFooBarServer) ServerStream(req *Foo, srv FooBar_ServerStreamServer) error
  • func (*UnimplementedFooBarServer) Unary(ctx context.Context, req *Foo) (*Bar, error)

Functions

func RegisterFooBarServer

func RegisterFooBarServer(s *grpc.Server, srv FooBarServer)

Types

type Bar

type Bar struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Bar) Descriptor

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

func (*Bar) GetMessage

func (m *Bar) GetMessage() string

func (*Bar) ProtoMessage

func (*Bar) ProtoMessage()

func (*Bar) Reset

func (m *Bar) Reset()

func (*Bar) String

func (m *Bar) String() string

func (*Bar) XXX_DiscardUnknown

func (m *Bar) XXX_DiscardUnknown()

func (*Bar) XXX_Marshal

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

func (*Bar) XXX_Merge

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

func (*Bar) XXX_Size

func (m *Bar) XXX_Size() int

func (*Bar) XXX_Unmarshal

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

type Foo

type Foo struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Foo) Descriptor

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

func (*Foo) GetMessage

func (m *Foo) GetMessage() string

func (*Foo) ProtoMessage

func (*Foo) ProtoMessage()

func (*Foo) Reset

func (m *Foo) Reset()

func (*Foo) String

func (m *Foo) String() string

func (*Foo) XXX_DiscardUnknown

func (m *Foo) XXX_DiscardUnknown()

func (*Foo) XXX_Marshal

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

func (*Foo) XXX_Merge

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

func (*Foo) XXX_Size

func (m *Foo) XXX_Size() int

func (*Foo) XXX_Unmarshal

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

type FooBarClient

type FooBarClient interface {
	Unary(ctx context.Context, in *Foo, opts ...grpc.CallOption) (*Bar, error)
	ClientStream(ctx context.Context, opts ...grpc.CallOption) (FooBar_ClientStreamClient, error)
	ServerStream(ctx context.Context, in *Foo, opts ...grpc.CallOption) (FooBar_ServerStreamClient, error)
	BidiStream(ctx context.Context, opts ...grpc.CallOption) (FooBar_BidiStreamClient, error)
}

FooBarClient is the client API for FooBar service.

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

func NewFooBarClient

func NewFooBarClient(cc *grpc.ClientConn) FooBarClient

type FooBarExampleServer

type FooBarExampleServer struct{}

The FooBarExampleServer is an example/test server

func (*FooBarExampleServer) BidiStream

func (s *FooBarExampleServer) BidiStream(stream FooBar_BidiStreamServer) error

BidiStream RPC example

func (*FooBarExampleServer) ClientStream

func (s *FooBarExampleServer) ClientStream(stream FooBar_ClientStreamServer) error

ClientStream RPC example

func (*FooBarExampleServer) ServerStream

func (s *FooBarExampleServer) ServerStream(foo *Foo, stream FooBar_ServerStreamServer) error

ServerStream RPC example

func (*FooBarExampleServer) Unary

func (s *FooBarExampleServer) Unary(ctx context.Context, foo *Foo) (*Bar, error)

Unary RPC example

type FooBarServer

type FooBarServer interface {
	Unary(context.Context, *Foo) (*Bar, error)
	ClientStream(FooBar_ClientStreamServer) error
	ServerStream(*Foo, FooBar_ServerStreamServer) error
	BidiStream(FooBar_BidiStreamServer) error
}

FooBarServer is the server API for FooBar service.

type FooBar_BidiStreamClient

type FooBar_BidiStreamClient interface {
	Send(*Foo) error
	Recv() (*Bar, error)
	grpc.ClientStream
}

type FooBar_BidiStreamServer

type FooBar_BidiStreamServer interface {
	Send(*Bar) error
	Recv() (*Foo, error)
	grpc.ServerStream
}

type FooBar_ClientStreamClient

type FooBar_ClientStreamClient interface {
	Send(*Foo) error
	CloseAndRecv() (*Bar, error)
	grpc.ClientStream
}

type FooBar_ClientStreamServer

type FooBar_ClientStreamServer interface {
	SendAndClose(*Bar) error
	Recv() (*Foo, error)
	grpc.ServerStream
}

type FooBar_ServerStreamClient

type FooBar_ServerStreamClient interface {
	Recv() (*Bar, error)
	grpc.ClientStream
}

type FooBar_ServerStreamServer

type FooBar_ServerStreamServer interface {
	Send(*Bar) error
	grpc.ServerStream
}

type UnimplementedFooBarServer

type UnimplementedFooBarServer struct {
}

UnimplementedFooBarServer can be embedded to have forward compatible implementations.

func (*UnimplementedFooBarServer) BidiStream

func (*UnimplementedFooBarServer) BidiStream(srv FooBar_BidiStreamServer) error

func (*UnimplementedFooBarServer) ClientStream

func (*UnimplementedFooBarServer) ClientStream(srv FooBar_ClientStreamServer) error

func (*UnimplementedFooBarServer) ServerStream

func (*UnimplementedFooBarServer) ServerStream(req *Foo, srv FooBar_ServerStreamServer) error

func (*UnimplementedFooBarServer) Unary

func (*UnimplementedFooBarServer) Unary(ctx context.Context, req *Foo) (*Bar, error)