proto

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: Jul 22, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Stargate_Connector_FullMethodName = "/cloudproud.lunodb.v1.Stargate/Connector"
)

Variables

View Source
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) Descriptor() ([]byte, []int)

func (*Column) GetName

func (m *Column) GetName() string

func (*Column) GetType

func (m *Column) GetType() *types.Type

func (*Column) ProtoMessage

func (*Column) ProtoMessage()

func (*Column) Reset

func (m *Column) Reset()

func (*Column) String

func (m *Column) String() string

func (*Column) XXX_DiscardUnknown

func (m *Column) XXX_DiscardUnknown()

func (*Column) XXX_Marshal

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

func (*Column) XXX_Merge

func (m *Column) XXX_Merge(src proto.Message)

func (*Column) XXX_Size

func (m *Column) XXX_Size() int

func (*Column) XXX_Unmarshal

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

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) Descriptor() ([]byte, []int)

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) Reset

func (m *Empty) Reset()

func (*Empty) String

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal

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

func (*Empty) XXX_Merge

func (m *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal

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

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) Descriptor() ([]byte, []int)

func (*Error) GetMessage

func (m *Error) GetMessage() string

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) Reset

func (m *Error) Reset()

func (*Error) String

func (m *Error) String() string

func (*Error) XXX_DiscardUnknown

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal

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

func (*Error) XXX_Merge

func (m *Error) XXX_Merge(src proto.Message)

func (*Error) XXX_Size

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal

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

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 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) Descriptor() ([]byte, []int)

func (*Header) GetColumns

func (m *Header) GetColumns() []*Column

func (*Header) ProtoMessage

func (*Header) ProtoMessage()

func (*Header) Reset

func (m *Header) Reset()

func (*Header) String

func (m *Header) String() string

func (*Header) XXX_DiscardUnknown

func (m *Header) XXX_DiscardUnknown()

func (*Header) XXX_Marshal

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

func (*Header) XXX_Merge

func (m *Header) XXX_Merge(src proto.Message)

func (*Header) XXX_Size

func (m *Header) XXX_Size() int

func (*Header) XXX_Unmarshal

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

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) Descriptor() ([]byte, []int)

func (*Row) GetValues

func (m *Row) GetValues() [][]byte

func (*Row) ProtoMessage

func (*Row) ProtoMessage()

func (*Row) Reset

func (m *Row) Reset()

func (*Row) String

func (m *Row) String() string

func (*Row) XXX_DiscardUnknown

func (m *Row) XXX_DiscardUnknown()

func (*Row) XXX_Marshal

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

func (*Row) XXX_Merge

func (m *Row) XXX_Merge(src proto.Message)

func (*Row) XXX_Size

func (m *Row) XXX_Size() int

func (*Row) XXX_Unmarshal

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

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.

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.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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