service

package
v0.1.6 Latest Latest
Warning

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

Go to latest
Published: Aug 16, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ColumnType_name = map[int32]string{
		0: "COLUMN_TYPE_UNSPECIFIED",
		1: "COLUMN_TYPE_TINY_INT",
		2: "COLUMN_TYPE_INT",
		3: "COLUMN_TYPE_BIG_INT",
		4: "COLUMN_TYPE_DOUBLE",
		5: "COLUMN_TYPE_DECIMAL",
		6: "COLUMN_TYPE_VARCHAR",
		7: "COLUMN_TYPE_TIMESTAMP",
	}
	ColumnType_value = map[string]int32{
		"COLUMN_TYPE_UNSPECIFIED": 0,
		"COLUMN_TYPE_TINY_INT":    1,
		"COLUMN_TYPE_INT":         2,
		"COLUMN_TYPE_BIG_INT":     3,
		"COLUMN_TYPE_DOUBLE":      4,
		"COLUMN_TYPE_DECIMAL":     5,
		"COLUMN_TYPE_VARCHAR":     6,
		"COLUMN_TYPE_TIMESTAMP":   7,
	}
)

Enum value maps for ColumnType.

View Source
var File_squareup_cash_pranadb_service_v1_service_proto protoreflect.FileDescriptor

Functions

func RegisterPranaDBServiceServer

func RegisterPranaDBServiceServer(s *grpc.Server, srv PranaDBServiceServer)

Types

type Arg added in v0.1.1

type Arg struct {
	Type            ColumnType       `protobuf:"varint,1,opt,name=type,proto3,enum=squareup.cash.pranadb.service.v1.ColumnType" json:"type,omitempty"`
	Value           *ArgValue        `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	DecimalParams   *DecimalParams   `protobuf:"bytes,3,opt,name=decimal_params,json=decimalParams,proto3,oneof" json:"decimal_params,omitempty"`
	TimestampParams *TimestampParams `protobuf:"bytes,4,opt,name=timestamp_params,json=timestampParams,proto3,oneof" json:"timestamp_params,omitempty"`
	// contains filtered or unexported fields
}

func (*Arg) Descriptor deprecated added in v0.1.1

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

Deprecated: Use Arg.ProtoReflect.Descriptor instead.

func (*Arg) GetDecimalParams added in v0.1.1

func (x *Arg) GetDecimalParams() *DecimalParams

func (*Arg) GetTimestampParams added in v0.1.1

func (x *Arg) GetTimestampParams() *TimestampParams

func (*Arg) GetType added in v0.1.1

func (x *Arg) GetType() ColumnType

func (*Arg) GetValue added in v0.1.1

func (x *Arg) GetValue() *ArgValue

func (*Arg) ProtoMessage added in v0.1.1

func (*Arg) ProtoMessage()

func (*Arg) ProtoReflect added in v0.1.1

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

func (*Arg) Reset added in v0.1.1

func (x *Arg) Reset()

func (*Arg) String added in v0.1.1

func (x *Arg) String() string

type ArgValue added in v0.1.1

type ArgValue struct {

	// Types that are assignable to Value:
	//	*ArgValue_IntValue
	//	*ArgValue_FloatValue
	//	*ArgValue_StringValue
	//	*ArgValue_DecimalValue
	//	*ArgValue_TimestampValue
	Value isArgValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*ArgValue) Descriptor deprecated added in v0.1.1

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

Deprecated: Use ArgValue.ProtoReflect.Descriptor instead.

func (*ArgValue) GetDecimalValue added in v0.1.1

func (x *ArgValue) GetDecimalValue() string

func (*ArgValue) GetFloatValue added in v0.1.1

func (x *ArgValue) GetFloatValue() float64

func (*ArgValue) GetIntValue added in v0.1.1

func (x *ArgValue) GetIntValue() int64

func (*ArgValue) GetStringValue added in v0.1.1

func (x *ArgValue) GetStringValue() string

func (*ArgValue) GetTimestampValue added in v0.1.1

func (x *ArgValue) GetTimestampValue() string

func (*ArgValue) GetValue added in v0.1.1

func (m *ArgValue) GetValue() isArgValue_Value

func (*ArgValue) ProtoMessage added in v0.1.1

func (*ArgValue) ProtoMessage()

func (*ArgValue) ProtoReflect added in v0.1.1

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

func (*ArgValue) Reset added in v0.1.1

func (x *ArgValue) Reset()

func (*ArgValue) String added in v0.1.1

func (x *ArgValue) String() string

type ArgValue_DecimalValue added in v0.1.1

type ArgValue_DecimalValue struct {
	DecimalValue string `protobuf:"bytes,4,opt,name=decimal_value,json=decimalValue,proto3,oneof"`
}

type ArgValue_FloatValue added in v0.1.1

type ArgValue_FloatValue struct {
	FloatValue float64 `protobuf:"fixed64,2,opt,name=float_value,json=floatValue,proto3,oneof"`
}

type ArgValue_IntValue added in v0.1.1

type ArgValue_IntValue struct {
	IntValue int64 `protobuf:"varint,1,opt,name=int_value,json=intValue,proto3,oneof"`
}

type ArgValue_StringValue added in v0.1.1

type ArgValue_StringValue struct {
	StringValue string `protobuf:"bytes,3,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type ArgValue_TimestampValue added in v0.1.1

type ArgValue_TimestampValue struct {
	TimestampValue string `protobuf:"bytes,5,opt,name=timestamp_value,json=timestampValue,proto3,oneof"`
}

type ColValue

type ColValue struct {

	// Types that are assignable to Value:
	//	*ColValue_IsNull
	//	*ColValue_IntValue
	//	*ColValue_FloatValue
	//	*ColValue_StringValue
	Value isColValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*ColValue) Descriptor deprecated

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

Deprecated: Use ColValue.ProtoReflect.Descriptor instead.

func (*ColValue) GetFloatValue

func (x *ColValue) GetFloatValue() float64

func (*ColValue) GetIntValue

func (x *ColValue) GetIntValue() int64

func (*ColValue) GetIsNull

func (x *ColValue) GetIsNull() bool

func (*ColValue) GetStringValue

func (x *ColValue) GetStringValue() string

func (*ColValue) GetValue

func (m *ColValue) GetValue() isColValue_Value

func (*ColValue) ProtoMessage

func (*ColValue) ProtoMessage()

func (*ColValue) ProtoReflect

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

func (*ColValue) Reset

func (x *ColValue) Reset()

func (*ColValue) String

func (x *ColValue) String() string

type ColValue_FloatValue

type ColValue_FloatValue struct {
	FloatValue float64 `protobuf:"fixed64,3,opt,name=float_value,json=floatValue,proto3,oneof"`
}

type ColValue_IntValue

type ColValue_IntValue struct {
	IntValue int64 `protobuf:"varint,2,opt,name=int_value,json=intValue,proto3,oneof"`
}

type ColValue_IsNull

type ColValue_IsNull struct {
	IsNull bool `protobuf:"varint,1,opt,name=is_null,json=isNull,proto3,oneof"`
}

type ColValue_StringValue

type ColValue_StringValue struct {
	StringValue string `protobuf:"bytes,4,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type Column

type Column struct {
	Name          string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type          ColumnType     `protobuf:"varint,2,opt,name=type,proto3,enum=squareup.cash.pranadb.service.v1.ColumnType" json:"type,omitempty"`
	DecimalParams *DecimalParams `protobuf:"bytes,3,opt,name=decimal_params,json=decimalParams,proto3,oneof" json:"decimal_params,omitempty"`
	// contains filtered or unexported fields
}

func (*Column) Descriptor deprecated

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

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetDecimalParams

func (x *Column) GetDecimalParams() *DecimalParams

func (*Column) GetName

func (x *Column) GetName() string

func (*Column) GetType

func (x *Column) GetType() ColumnType

func (*Column) ProtoMessage

func (*Column) ProtoMessage()

func (*Column) ProtoReflect

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

func (*Column) Reset

func (x *Column) Reset()

func (*Column) String

func (x *Column) String() string

type ColumnType

type ColumnType int32
const (
	ColumnType_COLUMN_TYPE_UNSPECIFIED ColumnType = 0
	ColumnType_COLUMN_TYPE_TINY_INT    ColumnType = 1
	ColumnType_COLUMN_TYPE_INT         ColumnType = 2
	ColumnType_COLUMN_TYPE_BIG_INT     ColumnType = 3
	ColumnType_COLUMN_TYPE_DOUBLE      ColumnType = 4
	ColumnType_COLUMN_TYPE_DECIMAL     ColumnType = 5
	ColumnType_COLUMN_TYPE_VARCHAR     ColumnType = 6
	ColumnType_COLUMN_TYPE_TIMESTAMP   ColumnType = 7
)

func (ColumnType) Descriptor

func (ColumnType) Descriptor() protoreflect.EnumDescriptor

func (ColumnType) Enum

func (x ColumnType) Enum() *ColumnType

func (ColumnType) EnumDescriptor deprecated

func (ColumnType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ColumnType.Descriptor instead.

func (ColumnType) Number

func (x ColumnType) Number() protoreflect.EnumNumber

func (ColumnType) String

func (x ColumnType) String() string

func (ColumnType) Type

type Columns

type Columns struct {
	Columns []*Column `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

Column definitions sent prior to a set of Pages.

func (*Columns) Descriptor deprecated

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

Deprecated: Use Columns.ProtoReflect.Descriptor instead.

func (*Columns) GetColumns

func (x *Columns) GetColumns() []*Column

func (*Columns) ProtoMessage

func (*Columns) ProtoMessage()

func (*Columns) ProtoReflect

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

func (*Columns) Reset

func (x *Columns) Reset()

func (*Columns) String

func (x *Columns) String() string

type DecimalParams

type DecimalParams struct {
	DecimalPrecision uint32 `protobuf:"varint,1,opt,name=decimal_precision,json=decimalPrecision,proto3" json:"decimal_precision,omitempty"`
	DecimalScale     uint32 `protobuf:"varint,2,opt,name=decimal_scale,json=decimalScale,proto3" json:"decimal_scale,omitempty"`
	// contains filtered or unexported fields
}

func (*DecimalParams) Descriptor deprecated

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

Deprecated: Use DecimalParams.ProtoReflect.Descriptor instead.

func (*DecimalParams) GetDecimalPrecision

func (x *DecimalParams) GetDecimalPrecision() uint32

func (*DecimalParams) GetDecimalScale

func (x *DecimalParams) GetDecimalScale() uint32

func (*DecimalParams) ProtoMessage

func (*DecimalParams) ProtoMessage()

func (*DecimalParams) ProtoReflect

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

func (*DecimalParams) Reset

func (x *DecimalParams) Reset()

func (*DecimalParams) String

func (x *DecimalParams) String() string

type ExecuteStatementRequest added in v0.1.1

type ExecuteStatementRequest struct {
	Schema string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// Types that are assignable to Statement:
	//	*ExecuteStatementRequest_Name
	//	*ExecuteStatementRequest_Sql
	Statement isExecuteStatementRequest_Statement `protobuf_oneof:"statement"`
	BatchSize int32                               `protobuf:"varint,4,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	Args      []*Arg                              `protobuf:"bytes,5,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteStatementRequest) Descriptor deprecated added in v0.1.1

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

Deprecated: Use ExecuteStatementRequest.ProtoReflect.Descriptor instead.

func (*ExecuteStatementRequest) GetArgs added in v0.1.1

func (x *ExecuteStatementRequest) GetArgs() []*Arg

func (*ExecuteStatementRequest) GetBatchSize added in v0.1.1

func (x *ExecuteStatementRequest) GetBatchSize() int32

func (*ExecuteStatementRequest) GetName added in v0.1.1

func (x *ExecuteStatementRequest) GetName() string

func (*ExecuteStatementRequest) GetSchema added in v0.1.1

func (x *ExecuteStatementRequest) GetSchema() string

func (*ExecuteStatementRequest) GetSql added in v0.1.1

func (x *ExecuteStatementRequest) GetSql() string

func (*ExecuteStatementRequest) GetStatement added in v0.1.1

func (m *ExecuteStatementRequest) GetStatement() isExecuteStatementRequest_Statement

func (*ExecuteStatementRequest) ProtoMessage added in v0.1.1

func (*ExecuteStatementRequest) ProtoMessage()

func (*ExecuteStatementRequest) ProtoReflect added in v0.1.1

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

func (*ExecuteStatementRequest) Reset added in v0.1.1

func (x *ExecuteStatementRequest) Reset()

func (*ExecuteStatementRequest) String added in v0.1.1

func (x *ExecuteStatementRequest) String() string

type ExecuteStatementRequest_Name added in v0.1.1

type ExecuteStatementRequest_Name struct {
	Name string `protobuf:"bytes,2,opt,name=name,proto3,oneof"`
}

type ExecuteStatementRequest_Sql added in v0.1.1

type ExecuteStatementRequest_Sql struct {
	Sql string `protobuf:"bytes,3,opt,name=sql,proto3,oneof"`
}

type ExecuteStatementResponse added in v0.1.1

type ExecuteStatementResponse struct {

	// Types that are assignable to Result:
	//	*ExecuteStatementResponse_Columns
	//	*ExecuteStatementResponse_Page
	Result isExecuteStatementResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*ExecuteStatementResponse) Descriptor deprecated added in v0.1.1

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

Deprecated: Use ExecuteStatementResponse.ProtoReflect.Descriptor instead.

func (*ExecuteStatementResponse) GetColumns added in v0.1.1

func (x *ExecuteStatementResponse) GetColumns() *Columns

func (*ExecuteStatementResponse) GetPage added in v0.1.1

func (x *ExecuteStatementResponse) GetPage() *Page

func (*ExecuteStatementResponse) GetResult added in v0.1.1

func (m *ExecuteStatementResponse) GetResult() isExecuteStatementResponse_Result

func (*ExecuteStatementResponse) ProtoMessage added in v0.1.1

func (*ExecuteStatementResponse) ProtoMessage()

func (*ExecuteStatementResponse) ProtoReflect added in v0.1.1

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

func (*ExecuteStatementResponse) Reset added in v0.1.1

func (x *ExecuteStatementResponse) Reset()

func (*ExecuteStatementResponse) String added in v0.1.1

func (x *ExecuteStatementResponse) String() string

type ExecuteStatementResponse_Columns added in v0.1.1

type ExecuteStatementResponse_Columns struct {
	Columns *Columns `protobuf:"bytes,1,opt,name=columns,proto3,oneof"` // Present in first response.
}

type ExecuteStatementResponse_Page added in v0.1.1

type ExecuteStatementResponse_Page struct {
	Page *Page `protobuf:"bytes,2,opt,name=page,proto3,oneof"`
}

type Page

type Page struct {
	Count uint64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Rows  []*Row `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

Each query may return an arbitrary number of pages.

func (*Page) Descriptor deprecated

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

Deprecated: Use Page.ProtoReflect.Descriptor instead.

func (*Page) GetCount

func (x *Page) GetCount() uint64

func (*Page) GetRows

func (x *Page) GetRows() []*Row

func (*Page) ProtoMessage

func (*Page) ProtoMessage()

func (*Page) ProtoReflect

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

func (*Page) Reset

func (x *Page) Reset()

func (*Page) String

func (x *Page) String() string

type PranaDBServiceClient

type PranaDBServiceClient interface {
	ExecuteStatement(ctx context.Context, in *ExecuteStatementRequest, opts ...grpc.CallOption) (PranaDBService_ExecuteStatementClient, error)
	RegisterProtobufs(ctx context.Context, in *RegisterProtobufsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

PranaDBServiceClient is the client API for PranaDBService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type PranaDBServiceServer

type PranaDBServiceServer interface {
	ExecuteStatement(*ExecuteStatementRequest, PranaDBService_ExecuteStatementServer) error
	RegisterProtobufs(context.Context, *RegisterProtobufsRequest) (*emptypb.Empty, error)
}

PranaDBServiceServer is the server API for PranaDBService service.

type PranaDBService_ExecuteStatementClient added in v0.1.1

type PranaDBService_ExecuteStatementClient interface {
	Recv() (*ExecuteStatementResponse, error)
	grpc.ClientStream
}

type PranaDBService_ExecuteStatementServer added in v0.1.1

type PranaDBService_ExecuteStatementServer interface {
	Send(*ExecuteStatementResponse) error
	grpc.ServerStream
}

type RegisterProtobufsRequest

type RegisterProtobufsRequest struct {
	Descriptors *descriptorpb.FileDescriptorSet `protobuf:"bytes,1,opt,name=descriptors,proto3" json:"descriptors,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterProtobufsRequest) Descriptor deprecated

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

Deprecated: Use RegisterProtobufsRequest.ProtoReflect.Descriptor instead.

func (*RegisterProtobufsRequest) GetDescriptors

func (*RegisterProtobufsRequest) ProtoMessage

func (*RegisterProtobufsRequest) ProtoMessage()

func (*RegisterProtobufsRequest) ProtoReflect

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

func (*RegisterProtobufsRequest) Reset

func (x *RegisterProtobufsRequest) Reset()

func (*RegisterProtobufsRequest) String

func (x *RegisterProtobufsRequest) String() string

type Row

type Row struct {
	Values []*ColValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*Row) Descriptor deprecated

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

Deprecated: Use Row.ProtoReflect.Descriptor instead.

func (*Row) GetValues

func (x *Row) GetValues() []*ColValue

func (*Row) ProtoMessage

func (*Row) ProtoMessage()

func (*Row) ProtoReflect

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

func (*Row) Reset

func (x *Row) Reset()

func (*Row) String

func (x *Row) String() string

type TimestampParams added in v0.1.1

type TimestampParams struct {

	// 0 (default) = whole seconds. 6 = microseconds.
	FractionalSecondsPrecision uint32 `` /* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TimestampParams) Descriptor deprecated added in v0.1.1

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

Deprecated: Use TimestampParams.ProtoReflect.Descriptor instead.

func (*TimestampParams) GetFractionalSecondsPrecision added in v0.1.1

func (x *TimestampParams) GetFractionalSecondsPrecision() uint32

func (*TimestampParams) ProtoMessage added in v0.1.1

func (*TimestampParams) ProtoMessage()

func (*TimestampParams) ProtoReflect added in v0.1.1

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

func (*TimestampParams) Reset added in v0.1.1

func (x *TimestampParams) Reset()

func (*TimestampParams) String added in v0.1.1

func (x *TimestampParams) String() string

type UnimplementedPranaDBServiceServer

type UnimplementedPranaDBServiceServer struct {
}

UnimplementedPranaDBServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPranaDBServiceServer) ExecuteStatement added in v0.1.1

func (*UnimplementedPranaDBServiceServer) RegisterProtobufs

Jump to

Keyboard shortcuts

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