AnyToDbGate

package module
v0.0.0-...-763d59e Latest Latest
Warning

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

Go to latest
Published: Sep 20, 2022 License: Apache-2.0 Imports: 8 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
var AnyToDbGate_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "anytodbgate.AnyToDbGate",
	HandlerType: (*AnyToDbGateServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ExecuteQuery",
			Handler:       _AnyToDbGate_ExecuteQuery_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "any_to_db_gate.proto",
}

AnyToDbGate_ServiceDesc is the grpc.ServiceDesc for AnyToDbGate service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_any_to_db_gate_proto protoreflect.FileDescriptor

Functions

func RegisterAnyToDbGateServer

func RegisterAnyToDbGateServer(s grpc.ServiceRegistrar, srv AnyToDbGateServer)

Types

type AnyToDbGateClient

type AnyToDbGateClient interface {
	// execute query to DbGate container
	ExecuteQuery(ctx context.Context, in *ExecuteQueryRequest, opts ...grpc.CallOption) (AnyToDbGate_ExecuteQueryClient, error)
}

AnyToDbGateClient is the client API for AnyToDbGate service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type AnyToDbGateServer

type AnyToDbGateServer interface {
	// execute query to DbGate container
	ExecuteQuery(*ExecuteQueryRequest, AnyToDbGate_ExecuteQueryServer) error
	// contains filtered or unexported methods
}

AnyToDbGateServer is the server API for AnyToDbGate service. All implementations must embed UnimplementedAnyToDbGateServer for forward compatibility

type AnyToDbGate_ExecuteQueryClient

type AnyToDbGate_ExecuteQueryClient interface {
	Recv() (*ExecuteQueryResponse, error)
	grpc.ClientStream
}

type AnyToDbGate_ExecuteQueryServer

type AnyToDbGate_ExecuteQueryServer interface {
	Send(*ExecuteQueryResponse) error
	grpc.ServerStream
}

type ExecuteQueryRequest

type ExecuteQueryRequest struct {
	Host  string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

* the message of executeQueryRequest

func (*ExecuteQueryRequest) Descriptor deprecated

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

Deprecated: Use ExecuteQueryRequest.ProtoReflect.Descriptor instead.

func (*ExecuteQueryRequest) GetHost

func (x *ExecuteQueryRequest) GetHost() string

func (*ExecuteQueryRequest) GetQuery

func (x *ExecuteQueryRequest) GetQuery() string

func (*ExecuteQueryRequest) ProtoMessage

func (*ExecuteQueryRequest) ProtoMessage()

func (*ExecuteQueryRequest) ProtoReflect

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

func (*ExecuteQueryRequest) Reset

func (x *ExecuteQueryRequest) Reset()

func (*ExecuteQueryRequest) String

func (x *ExecuteQueryRequest) String() string

type ExecuteQueryResponse

type ExecuteQueryResponse struct {
	Result  string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	PieceId int32  `protobuf:"varint,2,opt,name=piece_id,json=pieceId,proto3" json:"piece_id,omitempty"`
	// contains filtered or unexported fields
}

* the message of executeQueryResponse

func (*ExecuteQueryResponse) Descriptor deprecated

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

Deprecated: Use ExecuteQueryResponse.ProtoReflect.Descriptor instead.

func (*ExecuteQueryResponse) GetPieceId

func (x *ExecuteQueryResponse) GetPieceId() int32

func (*ExecuteQueryResponse) GetResult

func (x *ExecuteQueryResponse) GetResult() string

func (*ExecuteQueryResponse) ProtoMessage

func (*ExecuteQueryResponse) ProtoMessage()

func (*ExecuteQueryResponse) ProtoReflect

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

func (*ExecuteQueryResponse) Reset

func (x *ExecuteQueryResponse) Reset()

func (*ExecuteQueryResponse) String

func (x *ExecuteQueryResponse) String() string

type UnimplementedAnyToDbGateServer

type UnimplementedAnyToDbGateServer struct {
}

UnimplementedAnyToDbGateServer must be embedded to have forward compatible implementations.

func (UnimplementedAnyToDbGateServer) ExecuteQuery

type UnsafeAnyToDbGateServer

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

UnsafeAnyToDbGateServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AnyToDbGateServer will result in compilation errors.

Jump to

Keyboard shortcuts

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