simple

package
v0.0.0-...-ec16f60 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 15, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterSimpleServiceServer

func RegisterSimpleServiceServer(s *grpc.Server, srv SimpleServiceServer)

Types

type SimpleInputData

type SimpleInputData struct {
	Msg                  string   `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Delay                int64    `protobuf:"varint,2,opt,name=delay,proto3" json:"delay,omitempty"`
	TotalMessages        int64    `protobuf:"varint,3,opt,name=totalMessages,proto3" json:"totalMessages,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SimpleInputData) Descriptor

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

func (*SimpleInputData) GetDelay

func (m *SimpleInputData) GetDelay() int64

func (*SimpleInputData) GetMsg

func (m *SimpleInputData) GetMsg() string

func (*SimpleInputData) GetTotalMessages

func (m *SimpleInputData) GetTotalMessages() int64

func (*SimpleInputData) ProtoMessage

func (*SimpleInputData) ProtoMessage()

func (*SimpleInputData) Reset

func (m *SimpleInputData) Reset()

func (*SimpleInputData) String

func (m *SimpleInputData) String() string

func (*SimpleInputData) XXX_DiscardUnknown

func (m *SimpleInputData) XXX_DiscardUnknown()

func (*SimpleInputData) XXX_Marshal

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

func (*SimpleInputData) XXX_Merge

func (dst *SimpleInputData) XXX_Merge(src proto.Message)

func (*SimpleInputData) XXX_Size

func (m *SimpleInputData) XXX_Size() int

func (*SimpleInputData) XXX_Unmarshal

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

type SimpleOutputData

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

func (*SimpleOutputData) Descriptor

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

func (*SimpleOutputData) GetMsg

func (m *SimpleOutputData) GetMsg() string

func (*SimpleOutputData) ProtoMessage

func (*SimpleOutputData) ProtoMessage()

func (*SimpleOutputData) Reset

func (m *SimpleOutputData) Reset()

func (*SimpleOutputData) String

func (m *SimpleOutputData) String() string

func (*SimpleOutputData) XXX_DiscardUnknown

func (m *SimpleOutputData) XXX_DiscardUnknown()

func (*SimpleOutputData) XXX_Marshal

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

func (*SimpleOutputData) XXX_Merge

func (dst *SimpleOutputData) XXX_Merge(src proto.Message)

func (*SimpleOutputData) XXX_Size

func (m *SimpleOutputData) XXX_Size() int

func (*SimpleOutputData) XXX_Unmarshal

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

type SimpleServiceClient

type SimpleServiceClient interface {
	UnaryRPCExample(ctx context.Context, in *SimpleInputData, opts ...grpc.CallOption) (*SimpleOutputData, error)
	ServerStreamingRPC(ctx context.Context, in *SimpleInputData, opts ...grpc.CallOption) (SimpleService_ServerStreamingRPCClient, error)
	ClientStreamingRPC(ctx context.Context, opts ...grpc.CallOption) (SimpleService_ClientStreamingRPCClient, error)
	BidirectionalStreamingRPC(ctx context.Context, opts ...grpc.CallOption) (SimpleService_BidirectionalStreamingRPCClient, error)
}

SimpleServiceClient is the client API for SimpleService service.

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

func NewSimpleServiceClient

func NewSimpleServiceClient(cc *grpc.ClientConn) SimpleServiceClient

type SimpleServiceServer

type SimpleServiceServer interface {
	UnaryRPCExample(context.Context, *SimpleInputData) (*SimpleOutputData, error)
	ServerStreamingRPC(*SimpleInputData, SimpleService_ServerStreamingRPCServer) error
	ClientStreamingRPC(SimpleService_ClientStreamingRPCServer) error
	BidirectionalStreamingRPC(SimpleService_BidirectionalStreamingRPCServer) error
}

SimpleServiceServer is the server API for SimpleService service.

type SimpleService_BidirectionalStreamingRPCClient

type SimpleService_BidirectionalStreamingRPCClient interface {
	Send(*SimpleInputData) error
	Recv() (*SimpleOutputData, error)
	grpc.ClientStream
}

type SimpleService_BidirectionalStreamingRPCServer

type SimpleService_BidirectionalStreamingRPCServer interface {
	Send(*SimpleOutputData) error
	Recv() (*SimpleInputData, error)
	grpc.ServerStream
}

type SimpleService_ClientStreamingRPCClient

type SimpleService_ClientStreamingRPCClient interface {
	Send(*SimpleInputData) error
	CloseAndRecv() (*SimpleOutputData, error)
	grpc.ClientStream
}

type SimpleService_ClientStreamingRPCServer

type SimpleService_ClientStreamingRPCServer interface {
	SendAndClose(*SimpleOutputData) error
	Recv() (*SimpleInputData, error)
	grpc.ServerStream
}

type SimpleService_ServerStreamingRPCClient

type SimpleService_ServerStreamingRPCClient interface {
	Recv() (*SimpleOutputData, error)
	grpc.ClientStream
}

type SimpleService_ServerStreamingRPCServer

type SimpleService_ServerStreamingRPCServer interface {
	Send(*SimpleOutputData) error
	grpc.ServerStream
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL