AnyToDbGate

Documentation

Index

• Variables
• func RegisterAnyToDbGateServer(s grpc.ServiceRegistrar, srv AnyToDbGateServer)
• type AnyToDbGateClient
  • func NewAnyToDbGateClient(cc grpc.ClientConnInterface) AnyToDbGateClient
• type AnyToDbGateServer
• type AnyToDbGate_ExecuteQueryClient
• type AnyToDbGate_ExecuteQueryServer
• type ExecuteQueryRequest
  • func (*ExecuteQueryRequest) Descriptor() ([]byte, []int)
  • func (x *ExecuteQueryRequest) GetHost() string
  • func (x *ExecuteQueryRequest) GetQuery() string
  • func (*ExecuteQueryRequest) ProtoMessage()
  • func (x *ExecuteQueryRequest) ProtoReflect() protoreflect.Message
  • func (x *ExecuteQueryRequest) Reset()
  • func (x *ExecuteQueryRequest) String() string
• type ExecuteQueryResponse
  • func (*ExecuteQueryResponse) Descriptor() ([]byte, []int)
  • func (x *ExecuteQueryResponse) GetPieceId() int32
  • func (x *ExecuteQueryResponse) GetResult() string
  • func (*ExecuteQueryResponse) ProtoMessage()
  • func (x *ExecuteQueryResponse) ProtoReflect() protoreflect.Message
  • func (x *ExecuteQueryResponse) Reset()
  • func (x *ExecuteQueryResponse) String() string
• type UnimplementedAnyToDbGateServer
  • func (UnimplementedAnyToDbGateServer) ExecuteQuery(*ExecuteQueryRequest, AnyToDbGate_ExecuteQueryServer) error
• type UnsafeAnyToDbGateServer

Variables

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)

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.

func NewAnyToDbGateClient

func NewAnyToDbGateClient(cc grpc.ClientConnInterface) AnyToDbGateClient

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

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

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

func (UnimplementedAnyToDbGateServer) ExecuteQuery(*ExecuteQueryRequest, AnyToDbGate_ExecuteQueryServer) error

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.