samplev1

type BarAPIClient interface {
	// Reachability test.
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Pong, error)
	// Health test.
	Health(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HealthResponse, error)
	// Sample request.
	Request(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Response, error)
}

type BarAPIServer interface {
	// Reachability test.
	Ping(context.Context, *emptypb.Empty) (*Pong, error)
	// Health test.
	Health(context.Context, *emptypb.Empty) (*HealthResponse, error)
	// Sample request.
	Request(context.Context, *emptypb.Empty) (*Response, error)
	// contains filtered or unexported methods
}

type DRPCBarAPIClient interface {
	DRPCConn() drpc.Conn

	Ping(ctx context.Context, in *emptypb.Empty) (*Pong, error)
	Health(ctx context.Context, in *emptypb.Empty) (*HealthResponse, error)
	Request(ctx context.Context, in *emptypb.Empty) (*Response, error)
}

type DRPCBarAPIDescription struct{}

type DRPCBarAPIServer interface {
	Ping(context.Context, *emptypb.Empty) (*Pong, error)
	Health(context.Context, *emptypb.Empty) (*HealthResponse, error)
	Request(context.Context, *emptypb.Empty) (*Response, error)
}

type DRPCBarAPIUnimplementedServer struct{}

type DRPCBarAPI_HealthStream interface {
	drpc.Stream
	SendAndClose(*HealthResponse) error
}

type DRPCBarAPI_PingStream interface {
	drpc.Stream
	SendAndClose(*Pong) error
}

type DRPCBarAPI_RequestStream interface {
	drpc.Stream
	SendAndClose(*Response) error
}

type DRPCEchoAPIClient interface {
	DRPCConn() drpc.Conn

	Ping(ctx context.Context, in *emptypb.Empty) (*Pong, error)
	Health(ctx context.Context, in *emptypb.Empty) (*HealthResponse, error)
	Echo(ctx context.Context, in *EchoRequest) (*EchoResponse, error)
	Faulty(ctx context.Context, in *emptypb.Empty) (*DummyResponse, error)
	Slow(ctx context.Context, in *emptypb.Empty) (*DummyResponse, error)
}

type DRPCEchoAPIDescription struct{}

type DRPCEchoAPIServer interface {
	Ping(context.Context, *emptypb.Empty) (*Pong, error)
	Health(context.Context, *emptypb.Empty) (*HealthResponse, error)
	Echo(context.Context, *EchoRequest) (*EchoResponse, error)
	Faulty(context.Context, *emptypb.Empty) (*DummyResponse, error)
	Slow(context.Context, *emptypb.Empty) (*DummyResponse, error)
}

type DRPCEchoAPIUnimplementedServer struct{}

type DRPCEchoAPI_EchoStream interface {
	drpc.Stream
	SendAndClose(*EchoResponse) error
}

type DRPCEchoAPI_FaultyStream interface {
	drpc.Stream
	SendAndClose(*DummyResponse) error
}

type DRPCEchoAPI_HealthStream interface {
	drpc.Stream
	SendAndClose(*HealthResponse) error
}

type DRPCEchoAPI_PingStream interface {
	drpc.Stream
	SendAndClose(*Pong) error
}

type DRPCEchoAPI_SlowStream interface {
	drpc.Stream
	SendAndClose(*DummyResponse) error
}

type DRPCFooAPIClient interface {
	DRPCConn() drpc.Conn

	Ping(ctx context.Context, in *emptypb.Empty) (*Pong, error)
	Health(ctx context.Context, in *emptypb.Empty) (*HealthResponse, error)
	Request(ctx context.Context, in *emptypb.Empty) (*Response, error)
	Faulty(ctx context.Context, in *emptypb.Empty) (*DummyResponse, error)
	Slow(ctx context.Context, in *emptypb.Empty) (*DummyResponse, error)
	OpenServerStream(ctx context.Context, in *emptypb.Empty) (DRPCFooAPI_OpenServerStreamClient, error)
	OpenClientStream(ctx context.Context) (DRPCFooAPI_OpenClientStreamClient, error)
}

type DRPCFooAPIDescription struct{}

type DRPCFooAPIServer interface {
	Ping(context.Context, *emptypb.Empty) (*Pong, error)
	Health(context.Context, *emptypb.Empty) (*HealthResponse, error)
	Request(context.Context, *emptypb.Empty) (*Response, error)
	Faulty(context.Context, *emptypb.Empty) (*DummyResponse, error)
	Slow(context.Context, *emptypb.Empty) (*DummyResponse, error)
	OpenServerStream(*emptypb.Empty, DRPCFooAPI_OpenServerStreamStream) error
	OpenClientStream(DRPCFooAPI_OpenClientStreamStream) error
}

type DRPCFooAPIUnimplementedServer struct{}

type DRPCFooAPI_FaultyStream interface {
	drpc.Stream
	SendAndClose(*DummyResponse) error
}

type DRPCFooAPI_HealthStream interface {
	drpc.Stream
	SendAndClose(*HealthResponse) error
}

type DRPCFooAPI_OpenClientStreamClient interface {
	drpc.Stream
	Send(*OpenClientStreamRequest) error
	CloseAndRecv() (*StreamResult, error)
}

type DRPCFooAPI_OpenClientStreamStream interface {
	drpc.Stream
	SendAndClose(*StreamResult) error
	Recv() (*OpenClientStreamRequest, error)
}

type DRPCFooAPI_OpenServerStreamClient interface {
	drpc.Stream
	Recv() (*GenericStreamChunk, error)
}

type DRPCFooAPI_OpenServerStreamStream interface {
	drpc.Stream
	Send(*GenericStreamChunk) error
}

type DRPCFooAPI_PingStream interface {
	drpc.Stream
	SendAndClose(*Pong) error
}

type DRPCFooAPI_RequestStream interface {
	drpc.Stream
	SendAndClose(*Response) error
}

type DRPCFooAPI_SlowStream interface {
	drpc.Stream
	SendAndClose(*DummyResponse) error
}

type DummyResponse struct {

	// Generic status check, set to 'false' in case of errors.
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

type EchoAPIClient interface {
	// Reachability test.
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Pong, error)
	// Health test.
	Health(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HealthResponse, error)
	// Process an incoming echo request.
	Echo(ctx context.Context, in *EchoRequest, opts ...grpc.CallOption) (*EchoResponse, error)
	// Returns an error roughly about 20% of the time.
	Faulty(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DummyResponse, error)
	// Exhibit a random latency between 10 and 200ms.
	Slow(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DummyResponse, error)
}

type EchoAPIServer interface {
	// Reachability test.
	Ping(context.Context, *emptypb.Empty) (*Pong, error)
	// Health test.
	Health(context.Context, *emptypb.Empty) (*HealthResponse, error)
	// Process an incoming echo request.
	Echo(context.Context, *EchoRequest) (*EchoResponse, error)
	// Returns an error roughly about 20% of the time.
	Faulty(context.Context, *emptypb.Empty) (*DummyResponse, error)
	// Exhibit a random latency between 10 and 200ms.
	Slow(context.Context, *emptypb.Empty) (*DummyResponse, error)
	// contains filtered or unexported methods
}

type EchoHandler struct {
	UnimplementedEchoAPIServer
}

type EchoRequest struct {

	// Payload submitted to the "echo" request.
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type EchoResponse struct {

	// Result generated by the server.
	Result string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

type FaultyError struct {

	// RPC error code. MUST be a valid code value registered in the
	// google.golang.org/grpc/codes package.
	Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// General description of the error.
	Desc string `protobuf:"bytes,2,opt,name=desc,proto3" json:"desc,omitempty"`
	// Custom key/value pairs providing additional details about the error.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

type FooAPIClient interface {
	// Reachability test.
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Pong, error)
	// Health test.
	Health(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HealthResponse, error)
	// Sample request.
	Request(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Response, error)
	// Returns an error roughly about 20% of the time.
	Faulty(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DummyResponse, error)
	// Exhibit a random latency between 10 and 200ms.
	Slow(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DummyResponse, error)
	// Sample server stream request.
	OpenServerStream(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (FooAPI_OpenServerStreamClient, error)
	// Sample client stream request.
	OpenClientStream(ctx context.Context, opts ...grpc.CallOption) (FooAPI_OpenClientStreamClient, error)
}

type FooAPIServer interface {
	// Reachability test.
	Ping(context.Context, *emptypb.Empty) (*Pong, error)
	// Health test.
	Health(context.Context, *emptypb.Empty) (*HealthResponse, error)
	// Sample request.
	Request(context.Context, *emptypb.Empty) (*Response, error)
	// Returns an error roughly about 20% of the time.
	Faulty(context.Context, *emptypb.Empty) (*DummyResponse, error)
	// Exhibit a random latency between 10 and 200ms.
	Slow(context.Context, *emptypb.Empty) (*DummyResponse, error)
	// Sample server stream request.
	OpenServerStream(*emptypb.Empty, FooAPI_OpenServerStreamServer) error
	// Sample client stream request.
	OpenClientStream(FooAPI_OpenClientStreamServer) error
	// contains filtered or unexported methods
}

type FooAPI_OpenClientStreamClient interface {
	Send(*OpenClientStreamRequest) error
	CloseAndRecv() (*StreamResult, error)
	grpc.ClientStream
}

type FooAPI_OpenClientStreamServer interface {
	SendAndClose(*StreamResult) error
	Recv() (*OpenClientStreamRequest, error)
	grpc.ServerStream
}

type FooAPI_OpenServerStreamClient interface {
	Recv() (*GenericStreamChunk, error)
	grpc.ClientStream
}

type FooAPI_OpenServerStreamServer interface {
	Send(*GenericStreamChunk) error
	grpc.ServerStream
}

type GenericStreamChunk struct {

	// Identifier for the endpoint generating the stream message.
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// Message generation UNIX timestamp.
	Stamp int64 `protobuf:"varint,2,opt,name=stamp,proto3" json:"stamp,omitempty"`
	// contains filtered or unexported fields
}

type Handler struct {
	UnimplementedBarAPIServer
	UnimplementedFooAPIServer
	Name string
}

type HealthResponse struct {

	// Generic availability check, set to 'false' in case of errors.
	Alive bool `protobuf:"varint,1,opt,name=alive,proto3" json:"alive,omitempty"`
	// contains filtered or unexported fields
}

type OpenClientStreamRequest struct {

	// Identifier for the endpoint generating the stream message.
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// Message generation UNIX timestamp.
	Stamp int64 `protobuf:"varint,2,opt,name=stamp,proto3" json:"stamp,omitempty"`
	// contains filtered or unexported fields
}

type Pong struct {

	// Whether the service is 'ready-for-use'
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

type Response struct {

	// A key on the entity
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type StreamResult struct {

	// Set to the total number of messages received during the request.
	Received int64 `protobuf:"varint,1,opt,name=received,proto3" json:"received,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedBarAPIServer struct {
}

type UnimplementedEchoAPIServer struct {
}

type UnimplementedFooAPIServer struct {
}

type UnsafeBarAPIServer interface {
	// contains filtered or unexported methods
}

type UnsafeEchoAPIServer interface {
	// contains filtered or unexported methods
}

type UnsafeFooAPIServer interface {
	// contains filtered or unexported methods
}