Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterStargateServer(s grpc.ServiceRegistrar, srv StargateServer)
- type Column
- func (*Column) Descriptor() ([]byte, []int)
- func (m *Column) GetName() string
- func (m *Column) GetType() *types.Type
- func (*Column) ProtoMessage()
- func (m *Column) Reset()
- func (m *Column) String() string
- func (m *Column) XXX_DiscardUnknown()
- func (m *Column) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Column) XXX_Merge(src proto.Message)
- func (m *Column) XXX_Size() int
- func (m *Column) XXX_Unmarshal(b []byte) error
- type ConnectorRequest
- func (*ConnectorRequest) Descriptor() ([]byte, []int)
- func (m *ConnectorRequest) GetExecuteStatement() *ExecuteStatementRequest
- func (m *ConnectorRequest) GetFetch() *FetchRequest
- func (m *ConnectorRequest) GetId() uint32
- func (m *ConnectorRequest) GetPing() *PingRequest
- func (m *ConnectorRequest) GetState() isConnectorRequest_State
- func (*ConnectorRequest) ProtoMessage()
- func (m *ConnectorRequest) Reset()
- func (m *ConnectorRequest) String() string
- func (m *ConnectorRequest) XXX_DiscardUnknown()
- func (m *ConnectorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConnectorRequest) XXX_Merge(src proto.Message)
- func (*ConnectorRequest) XXX_OneofWrappers() []interface{}
- func (m *ConnectorRequest) XXX_Size() int
- func (m *ConnectorRequest) XXX_Unmarshal(b []byte) error
- type ConnectorRequest_ExecuteStatement
- type ConnectorRequest_Fetch
- type ConnectorRequest_Ping
- type ConnectorResponse
- func (*ConnectorResponse) Descriptor() ([]byte, []int)
- func (m *ConnectorResponse) GetExecuteStatement() *ExecuteStatementResponse
- func (m *ConnectorResponse) GetFetch() *FetchResponse
- func (m *ConnectorResponse) GetId() uint32
- func (m *ConnectorResponse) GetPing() *PingResponse
- func (m *ConnectorResponse) GetState() isConnectorResponse_State
- func (*ConnectorResponse) ProtoMessage()
- func (m *ConnectorResponse) Reset()
- func (m *ConnectorResponse) String() string
- func (m *ConnectorResponse) XXX_DiscardUnknown()
- func (m *ConnectorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConnectorResponse) XXX_Merge(src proto.Message)
- func (*ConnectorResponse) XXX_OneofWrappers() []interface{}
- func (m *ConnectorResponse) XXX_Size() int
- func (m *ConnectorResponse) XXX_Unmarshal(b []byte) error
- type ConnectorResponse_ExecuteStatement
- type ConnectorResponse_Fetch
- type ConnectorResponse_Ping
- type Empty
- func (*Empty) Descriptor() ([]byte, []int)
- func (*Empty) ProtoMessage()
- func (m *Empty) Reset()
- func (m *Empty) String() string
- func (m *Empty) XXX_DiscardUnknown()
- func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Empty) XXX_Merge(src proto.Message)
- func (m *Empty) XXX_Size() int
- func (m *Empty) XXX_Unmarshal(b []byte) error
- type Error
- func (*Error) Descriptor() ([]byte, []int)
- func (m *Error) GetMessage() string
- func (*Error) ProtoMessage()
- func (m *Error) Reset()
- func (m *Error) String() string
- func (m *Error) XXX_DiscardUnknown()
- func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Error) XXX_Merge(src proto.Message)
- func (m *Error) XXX_Size() int
- func (m *Error) XXX_Unmarshal(b []byte) error
- type ExecuteStatementRequest
- func (*ExecuteStatementRequest) Descriptor() ([]byte, []int)
- func (m *ExecuteStatementRequest) GetPlan() *plan.Literal
- func (*ExecuteStatementRequest) ProtoMessage()
- func (m *ExecuteStatementRequest) Reset()
- func (m *ExecuteStatementRequest) String() string
- func (m *ExecuteStatementRequest) XXX_DiscardUnknown()
- func (m *ExecuteStatementRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecuteStatementRequest) XXX_Merge(src proto.Message)
- func (m *ExecuteStatementRequest) XXX_Size() int
- func (m *ExecuteStatementRequest) XXX_Unmarshal(b []byte) error
- type ExecuteStatementResponse
- func (*ExecuteStatementResponse) Descriptor() ([]byte, []int)
- func (m *ExecuteStatementResponse) GetData() *Row
- func (m *ExecuteStatementResponse) GetEOE() *Empty
- func (m *ExecuteStatementResponse) GetError() *Error
- func (m *ExecuteStatementResponse) GetResult() isExecuteStatementResponse_Result
- func (*ExecuteStatementResponse) ProtoMessage()
- func (m *ExecuteStatementResponse) Reset()
- func (m *ExecuteStatementResponse) String() string
- func (m *ExecuteStatementResponse) XXX_DiscardUnknown()
- func (m *ExecuteStatementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecuteStatementResponse) XXX_Merge(src proto.Message)
- func (*ExecuteStatementResponse) XXX_OneofWrappers() []interface{}
- func (m *ExecuteStatementResponse) XXX_Size() int
- func (m *ExecuteStatementResponse) XXX_Unmarshal(b []byte) error
- type ExecuteStatementResponse_Data
- type ExecuteStatementResponse_EOE
- type ExecuteStatementResponse_Error
- type FetchRequest
- func (*FetchRequest) Descriptor() ([]byte, []int)
- func (*FetchRequest) ProtoMessage()
- func (m *FetchRequest) Reset()
- func (m *FetchRequest) String() string
- func (m *FetchRequest) XXX_DiscardUnknown()
- func (m *FetchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FetchRequest) XXX_Merge(src proto.Message)
- func (m *FetchRequest) XXX_Size() int
- func (m *FetchRequest) XXX_Unmarshal(b []byte) error
- type FetchResponse
- func (*FetchResponse) Descriptor() ([]byte, []int)
- func (m *FetchResponse) GetError() *Error
- func (m *FetchResponse) GetTables() []*node.Table
- func (*FetchResponse) ProtoMessage()
- func (m *FetchResponse) Reset()
- func (m *FetchResponse) String() string
- func (m *FetchResponse) XXX_DiscardUnknown()
- func (m *FetchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FetchResponse) XXX_Merge(src proto.Message)
- func (m *FetchResponse) XXX_Size() int
- func (m *FetchResponse) XXX_Unmarshal(b []byte) error
- type Header
- func (*Header) Descriptor() ([]byte, []int)
- func (m *Header) GetColumns() []*Column
- func (*Header) ProtoMessage()
- func (m *Header) Reset()
- func (m *Header) String() string
- func (m *Header) XXX_DiscardUnknown()
- func (m *Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Header) XXX_Merge(src proto.Message)
- func (m *Header) XXX_Size() int
- func (m *Header) XXX_Unmarshal(b []byte) error
- type PingRequest
- func (*PingRequest) Descriptor() ([]byte, []int)
- func (*PingRequest) ProtoMessage()
- func (m *PingRequest) Reset()
- func (m *PingRequest) String() string
- func (m *PingRequest) XXX_DiscardUnknown()
- func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PingRequest) XXX_Merge(src proto.Message)
- func (m *PingRequest) XXX_Size() int
- func (m *PingRequest) XXX_Unmarshal(b []byte) error
- type PingResponse
- func (*PingResponse) Descriptor() ([]byte, []int)
- func (m *PingResponse) GetError() *Error
- func (*PingResponse) ProtoMessage()
- func (m *PingResponse) Reset()
- func (m *PingResponse) String() string
- func (m *PingResponse) XXX_DiscardUnknown()
- func (m *PingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PingResponse) XXX_Merge(src proto.Message)
- func (m *PingResponse) XXX_Size() int
- func (m *PingResponse) XXX_Unmarshal(b []byte) error
- type Row
- func (*Row) Descriptor() ([]byte, []int)
- func (m *Row) GetValues() [][]byte
- func (*Row) ProtoMessage()
- func (m *Row) Reset()
- func (m *Row) String() string
- func (m *Row) XXX_DiscardUnknown()
- func (m *Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Row) XXX_Merge(src proto.Message)
- func (m *Row) XXX_Size() int
- func (m *Row) XXX_Unmarshal(b []byte) error
- type StargateClient
- type StargateServer
- type Stargate_ConnectorClient
- type Stargate_ConnectorServer
- type UnimplementedStargateServer
- type UnsafeStargateServer
Constants ¶
const (
Stargate_Connector_FullMethodName = "/cloudproud.lunodb.v1.Stargate/Connector"
)
Variables ¶
var Stargate_ServiceDesc = grpc.ServiceDesc{ ServiceName: "cloudproud.lunodb.v1.Stargate", HandlerType: (*StargateServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Connector", Handler: _Stargate_Connector_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "proto/lunodb.proto", }
Stargate_ServiceDesc is the grpc.ServiceDesc for Stargate service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterStargateServer ¶
func RegisterStargateServer(s grpc.ServiceRegistrar, srv StargateServer)
Types ¶
type Column ¶
type Column struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Type *types.Type `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Column) Descriptor ¶
func (*Column) ProtoMessage ¶
func (*Column) ProtoMessage()
func (*Column) XXX_DiscardUnknown ¶
func (m *Column) XXX_DiscardUnknown()
func (*Column) XXX_Marshal ¶
func (*Column) XXX_Unmarshal ¶
type ConnectorRequest ¶
type ConnectorRequest struct {
Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
// Types that are valid to be assigned to State:
//
// *ConnectorRequest_Ping
// *ConnectorRequest_Fetch
// *ConnectorRequest_ExecuteStatement
State isConnectorRequest_State `protobuf_oneof:"state"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ConnectorRequest) Descriptor ¶
func (*ConnectorRequest) Descriptor() ([]byte, []int)
func (*ConnectorRequest) GetExecuteStatement ¶
func (m *ConnectorRequest) GetExecuteStatement() *ExecuteStatementRequest
func (*ConnectorRequest) GetFetch ¶
func (m *ConnectorRequest) GetFetch() *FetchRequest
func (*ConnectorRequest) GetId ¶
func (m *ConnectorRequest) GetId() uint32
func (*ConnectorRequest) GetPing ¶
func (m *ConnectorRequest) GetPing() *PingRequest
func (*ConnectorRequest) GetState ¶
func (m *ConnectorRequest) GetState() isConnectorRequest_State
func (*ConnectorRequest) ProtoMessage ¶
func (*ConnectorRequest) ProtoMessage()
func (*ConnectorRequest) Reset ¶
func (m *ConnectorRequest) Reset()
func (*ConnectorRequest) String ¶
func (m *ConnectorRequest) String() string
func (*ConnectorRequest) XXX_DiscardUnknown ¶
func (m *ConnectorRequest) XXX_DiscardUnknown()
func (*ConnectorRequest) XXX_Marshal ¶
func (m *ConnectorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnectorRequest) XXX_Merge ¶
func (m *ConnectorRequest) XXX_Merge(src proto.Message)
func (*ConnectorRequest) XXX_OneofWrappers ¶
func (*ConnectorRequest) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ConnectorRequest) XXX_Size ¶
func (m *ConnectorRequest) XXX_Size() int
func (*ConnectorRequest) XXX_Unmarshal ¶
func (m *ConnectorRequest) XXX_Unmarshal(b []byte) error
type ConnectorRequest_ExecuteStatement ¶
type ConnectorRequest_ExecuteStatement struct {
ExecuteStatement *ExecuteStatementRequest `protobuf:"bytes,4,opt,name=execute_statement,json=executeStatement,proto3,oneof" json:"execute_statement,omitempty"`
}
type ConnectorRequest_Fetch ¶
type ConnectorRequest_Fetch struct {
Fetch *FetchRequest `protobuf:"bytes,3,opt,name=fetch,proto3,oneof" json:"fetch,omitempty"`
}
type ConnectorRequest_Ping ¶
type ConnectorRequest_Ping struct {
Ping *PingRequest `protobuf:"bytes,2,opt,name=ping,proto3,oneof" json:"ping,omitempty"`
}
type ConnectorResponse ¶
type ConnectorResponse struct {
Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
// Types that are valid to be assigned to State:
//
// *ConnectorResponse_Ping
// *ConnectorResponse_Fetch
// *ConnectorResponse_ExecuteStatement
State isConnectorResponse_State `protobuf_oneof:"state"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ConnectorResponse) Descriptor ¶
func (*ConnectorResponse) Descriptor() ([]byte, []int)
func (*ConnectorResponse) GetExecuteStatement ¶
func (m *ConnectorResponse) GetExecuteStatement() *ExecuteStatementResponse
func (*ConnectorResponse) GetFetch ¶
func (m *ConnectorResponse) GetFetch() *FetchResponse
func (*ConnectorResponse) GetId ¶
func (m *ConnectorResponse) GetId() uint32
func (*ConnectorResponse) GetPing ¶
func (m *ConnectorResponse) GetPing() *PingResponse
func (*ConnectorResponse) GetState ¶
func (m *ConnectorResponse) GetState() isConnectorResponse_State
func (*ConnectorResponse) ProtoMessage ¶
func (*ConnectorResponse) ProtoMessage()
func (*ConnectorResponse) Reset ¶
func (m *ConnectorResponse) Reset()
func (*ConnectorResponse) String ¶
func (m *ConnectorResponse) String() string
func (*ConnectorResponse) XXX_DiscardUnknown ¶
func (m *ConnectorResponse) XXX_DiscardUnknown()
func (*ConnectorResponse) XXX_Marshal ¶
func (m *ConnectorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnectorResponse) XXX_Merge ¶
func (m *ConnectorResponse) XXX_Merge(src proto.Message)
func (*ConnectorResponse) XXX_OneofWrappers ¶
func (*ConnectorResponse) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ConnectorResponse) XXX_Size ¶
func (m *ConnectorResponse) XXX_Size() int
func (*ConnectorResponse) XXX_Unmarshal ¶
func (m *ConnectorResponse) XXX_Unmarshal(b []byte) error
type ConnectorResponse_ExecuteStatement ¶
type ConnectorResponse_ExecuteStatement struct {
ExecuteStatement *ExecuteStatementResponse `protobuf:"bytes,4,opt,name=execute_statement,json=executeStatement,proto3,oneof" json:"execute_statement,omitempty"`
}
type ConnectorResponse_Fetch ¶
type ConnectorResponse_Fetch struct {
Fetch *FetchResponse `protobuf:"bytes,3,opt,name=fetch,proto3,oneof" json:"fetch,omitempty"`
}
type ConnectorResponse_Ping ¶
type ConnectorResponse_Ping struct {
Ping *PingResponse `protobuf:"bytes,2,opt,name=ping,proto3,oneof" json:"ping,omitempty"`
}
type Empty ¶
type Empty struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) XXX_DiscardUnknown ¶
func (m *Empty) XXX_DiscardUnknown()
func (*Empty) XXX_Marshal ¶
func (*Empty) XXX_Unmarshal ¶
type Error ¶
type Error 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 (*Error) Descriptor ¶
func (*Error) GetMessage ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) XXX_DiscardUnknown ¶
func (m *Error) XXX_DiscardUnknown()
func (*Error) XXX_Marshal ¶
func (*Error) XXX_Unmarshal ¶
type ExecuteStatementRequest ¶
type ExecuteStatementRequest struct {
Plan *plan.Literal `protobuf:"bytes,1,opt,name=plan,proto3" json:"plan,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ExecuteStatementRequest) Descriptor ¶
func (*ExecuteStatementRequest) Descriptor() ([]byte, []int)
func (*ExecuteStatementRequest) GetPlan ¶
func (m *ExecuteStatementRequest) GetPlan() *plan.Literal
func (*ExecuteStatementRequest) ProtoMessage ¶
func (*ExecuteStatementRequest) ProtoMessage()
func (*ExecuteStatementRequest) Reset ¶
func (m *ExecuteStatementRequest) Reset()
func (*ExecuteStatementRequest) String ¶
func (m *ExecuteStatementRequest) String() string
func (*ExecuteStatementRequest) XXX_DiscardUnknown ¶
func (m *ExecuteStatementRequest) XXX_DiscardUnknown()
func (*ExecuteStatementRequest) XXX_Marshal ¶
func (m *ExecuteStatementRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecuteStatementRequest) XXX_Merge ¶
func (m *ExecuteStatementRequest) XXX_Merge(src proto.Message)
func (*ExecuteStatementRequest) XXX_Size ¶
func (m *ExecuteStatementRequest) XXX_Size() int
func (*ExecuteStatementRequest) XXX_Unmarshal ¶
func (m *ExecuteStatementRequest) XXX_Unmarshal(b []byte) error
type ExecuteStatementResponse ¶
type ExecuteStatementResponse struct {
// Types that are valid to be assigned to Result:
//
// *ExecuteStatementResponse_Data
// *ExecuteStatementResponse_Error
// *ExecuteStatementResponse_EOE
Result isExecuteStatementResponse_Result `protobuf_oneof:"result"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ExecuteStatementResponse) Descriptor ¶
func (*ExecuteStatementResponse) Descriptor() ([]byte, []int)
func (*ExecuteStatementResponse) GetData ¶
func (m *ExecuteStatementResponse) GetData() *Row
func (*ExecuteStatementResponse) GetEOE ¶
func (m *ExecuteStatementResponse) GetEOE() *Empty
func (*ExecuteStatementResponse) GetError ¶
func (m *ExecuteStatementResponse) GetError() *Error
func (*ExecuteStatementResponse) GetResult ¶
func (m *ExecuteStatementResponse) GetResult() isExecuteStatementResponse_Result
func (*ExecuteStatementResponse) ProtoMessage ¶
func (*ExecuteStatementResponse) ProtoMessage()
func (*ExecuteStatementResponse) Reset ¶
func (m *ExecuteStatementResponse) Reset()
func (*ExecuteStatementResponse) String ¶
func (m *ExecuteStatementResponse) String() string
func (*ExecuteStatementResponse) XXX_DiscardUnknown ¶
func (m *ExecuteStatementResponse) XXX_DiscardUnknown()
func (*ExecuteStatementResponse) XXX_Marshal ¶
func (m *ExecuteStatementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecuteStatementResponse) XXX_Merge ¶
func (m *ExecuteStatementResponse) XXX_Merge(src proto.Message)
func (*ExecuteStatementResponse) XXX_OneofWrappers ¶
func (*ExecuteStatementResponse) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ExecuteStatementResponse) XXX_Size ¶
func (m *ExecuteStatementResponse) XXX_Size() int
func (*ExecuteStatementResponse) XXX_Unmarshal ¶
func (m *ExecuteStatementResponse) XXX_Unmarshal(b []byte) error
type ExecuteStatementResponse_Data ¶
type ExecuteStatementResponse_Data struct {
Data *Row `protobuf:"bytes,1,opt,name=data,proto3,oneof" json:"data,omitempty"`
}
type ExecuteStatementResponse_EOE ¶
type ExecuteStatementResponse_EOE struct {
EOE *Empty `protobuf:"bytes,3,opt,name=EOE,proto3,oneof" json:"EOE,omitempty"`
}
type ExecuteStatementResponse_Error ¶
type ExecuteStatementResponse_Error struct {
Error *Error `protobuf:"bytes,2,opt,name=error,proto3,oneof" json:"error,omitempty"`
}
type FetchRequest ¶
type FetchRequest struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*FetchRequest) Descriptor ¶
func (*FetchRequest) Descriptor() ([]byte, []int)
func (*FetchRequest) ProtoMessage ¶
func (*FetchRequest) ProtoMessage()
func (*FetchRequest) Reset ¶
func (m *FetchRequest) Reset()
func (*FetchRequest) String ¶
func (m *FetchRequest) String() string
func (*FetchRequest) XXX_DiscardUnknown ¶
func (m *FetchRequest) XXX_DiscardUnknown()
func (*FetchRequest) XXX_Marshal ¶
func (m *FetchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FetchRequest) XXX_Merge ¶
func (m *FetchRequest) XXX_Merge(src proto.Message)
func (*FetchRequest) XXX_Size ¶
func (m *FetchRequest) XXX_Size() int
func (*FetchRequest) XXX_Unmarshal ¶
func (m *FetchRequest) XXX_Unmarshal(b []byte) error
type FetchResponse ¶
type FetchResponse struct {
Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
Tables []*node.Table `protobuf:"bytes,2,rep,name=tables,proto3" json:"tables,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*FetchResponse) Descriptor ¶
func (*FetchResponse) Descriptor() ([]byte, []int)
func (*FetchResponse) GetError ¶
func (m *FetchResponse) GetError() *Error
func (*FetchResponse) GetTables ¶
func (m *FetchResponse) GetTables() []*node.Table
func (*FetchResponse) ProtoMessage ¶
func (*FetchResponse) ProtoMessage()
func (*FetchResponse) Reset ¶
func (m *FetchResponse) Reset()
func (*FetchResponse) String ¶
func (m *FetchResponse) String() string
func (*FetchResponse) XXX_DiscardUnknown ¶
func (m *FetchResponse) XXX_DiscardUnknown()
func (*FetchResponse) XXX_Marshal ¶
func (m *FetchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FetchResponse) XXX_Merge ¶
func (m *FetchResponse) XXX_Merge(src proto.Message)
func (*FetchResponse) XXX_Size ¶
func (m *FetchResponse) XXX_Size() int
func (*FetchResponse) XXX_Unmarshal ¶
func (m *FetchResponse) XXX_Unmarshal(b []byte) error
type Header ¶
type Header struct {
Columns []*Column `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Header) Descriptor ¶
func (*Header) GetColumns ¶
func (*Header) ProtoMessage ¶
func (*Header) ProtoMessage()
func (*Header) XXX_DiscardUnknown ¶
func (m *Header) XXX_DiscardUnknown()
func (*Header) XXX_Marshal ¶
func (*Header) XXX_Unmarshal ¶
type PingRequest ¶
type PingRequest struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*PingRequest) Descriptor ¶
func (*PingRequest) Descriptor() ([]byte, []int)
func (*PingRequest) ProtoMessage ¶
func (*PingRequest) ProtoMessage()
func (*PingRequest) Reset ¶
func (m *PingRequest) Reset()
func (*PingRequest) String ¶
func (m *PingRequest) String() string
func (*PingRequest) XXX_DiscardUnknown ¶
func (m *PingRequest) XXX_DiscardUnknown()
func (*PingRequest) XXX_Marshal ¶
func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PingRequest) XXX_Merge ¶
func (m *PingRequest) XXX_Merge(src proto.Message)
func (*PingRequest) XXX_Size ¶
func (m *PingRequest) XXX_Size() int
func (*PingRequest) XXX_Unmarshal ¶
func (m *PingRequest) XXX_Unmarshal(b []byte) error
type PingResponse ¶
type PingResponse struct {
Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*PingResponse) Descriptor ¶
func (*PingResponse) Descriptor() ([]byte, []int)
func (*PingResponse) GetError ¶
func (m *PingResponse) GetError() *Error
func (*PingResponse) ProtoMessage ¶
func (*PingResponse) ProtoMessage()
func (*PingResponse) Reset ¶
func (m *PingResponse) Reset()
func (*PingResponse) String ¶
func (m *PingResponse) String() string
func (*PingResponse) XXX_DiscardUnknown ¶
func (m *PingResponse) XXX_DiscardUnknown()
func (*PingResponse) XXX_Marshal ¶
func (m *PingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PingResponse) XXX_Merge ¶
func (m *PingResponse) XXX_Merge(src proto.Message)
func (*PingResponse) XXX_Size ¶
func (m *PingResponse) XXX_Size() int
func (*PingResponse) XXX_Unmarshal ¶
func (m *PingResponse) XXX_Unmarshal(b []byte) error
type Row ¶
type Row struct {
Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Row) Descriptor ¶
func (*Row) ProtoMessage ¶
func (*Row) ProtoMessage()
func (*Row) XXX_DiscardUnknown ¶
func (m *Row) XXX_DiscardUnknown()
func (*Row) XXX_Unmarshal ¶
type StargateClient ¶
type StargateClient interface {
Connector(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ConnectorResponse, ConnectorRequest], error)
}
StargateClient is the client API for Stargate 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 NewStargateClient ¶
func NewStargateClient(cc grpc.ClientConnInterface) StargateClient
type StargateServer ¶
type StargateServer interface {
Connector(grpc.BidiStreamingServer[ConnectorResponse, ConnectorRequest]) error
// contains filtered or unexported methods
}
StargateServer is the server API for Stargate service. All implementations must embed UnimplementedStargateServer for forward compatibility.
type Stargate_ConnectorClient ¶
type Stargate_ConnectorClient = grpc.BidiStreamingClient[ConnectorResponse, ConnectorRequest]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Stargate_ConnectorServer ¶
type Stargate_ConnectorServer = grpc.BidiStreamingServer[ConnectorResponse, ConnectorRequest]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type UnimplementedStargateServer ¶
type UnimplementedStargateServer struct{}
UnimplementedStargateServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedStargateServer) Connector ¶
func (UnimplementedStargateServer) Connector(grpc.BidiStreamingServer[ConnectorResponse, ConnectorRequest]) error
type UnsafeStargateServer ¶
type UnsafeStargateServer interface {
// contains filtered or unexported methods
}
UnsafeStargateServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StargateServer will result in compilation errors.