pb

package
v0.13.5 Latest Latest
Warning

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

 Go to latest Published: Jan 20, 2025 License: Apache-2.0 Imports: 15 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	Frames_Read_FullMethodName    = "/pb.Frames/Read"
	Frames_Write_FullMethodName   = "/pb.Frames/Write"
	Frames_Create_FullMethodName  = "/pb.Frames/Create"
	Frames_Delete_FullMethodName  = "/pb.Frames/Delete"
	Frames_Exec_FullMethodName    = "/pb.Frames/Exec"
	Frames_History_FullMethodName = "/pb.Frames/History"
	Frames_Version_FullMethodName = "/pb.Frames/Version"
)

Variables

View Source 
var (
	DType_name = map[int32]string{
		0: "NONE",
		1: "INTEGER",
		2: "FLOAT",
		3: "STRING",
		4: "TIME",
		5: "BOOLEAN",
		6: "NULL",
	}
	DType_value = map[string]int32{
		"NONE":    0,
		"INTEGER": 1,
		"FLOAT":   2,
		"STRING":  3,
		"TIME":    4,
		"BOOLEAN": 5,
		"NULL":    6,
	}
)

Enum value maps for DType.

View Source 
var (
	ErrorOptions_name = map[int32]string{
		0: "FAIL",
		1: "IGNORE",
	}
	ErrorOptions_value = map[string]int32{
		"FAIL":   0,
		"IGNORE": 1,
	}
)

Enum value maps for ErrorOptions.

View Source 
var (
	Column_Kind_name = map[int32]string{
		0: "SLICE",
		1: "LABEL",
	}
	Column_Kind_value = map[string]int32{
		"SLICE": 0,
		"LABEL": 1,
	}
)

Enum value maps for Column_Kind.

View Source 
var File_frames_proto protoreflect.FileDescriptor
View Source 
var Frames_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.Frames",
	HandlerType: (*FramesServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _Frames_Create_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Frames_Delete_Handler,
		},
		{
			MethodName: "Exec",
			Handler:    _Frames_Exec_Handler,
		},
		{
			MethodName: "Version",
			Handler:    _Frames_Version_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Read",
			Handler:       _Frames_Read_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Write",
			Handler:       _Frames_Write_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "History",
			Handler:       _Frames_History_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "frames.proto",
}

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

Functions

func AsGoMap 

func AsGoMap(mv map[string]*Value) map[string]interface{}

AsGoMap returns map with interface{} values

func AsInt64 

func AsInt64(val interface{}) (int64, bool)

AsInt64 convert val to int64, it'll return 0, false on failure

func FromGoMap 

func FromGoMap(m map[string]interface{}) (map[string]*Value, error)

FromGoMap return map[string]*Value

func NSToTime 

func NSToTime(ns int64) time.Time

NSToTime returns time from epoch nanoseconds

func RegisterFramesServer 

func RegisterFramesServer(s grpc.ServiceRegistrar, srv FramesServer)

Types

type Column 

type Column struct {
	Kind  Column_Kind `protobuf:"varint,1,opt,name=kind,proto3,enum=pb.Column_Kind" json:"kind,omitempty"`
	Name  string      `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Dtype DType       `protobuf:"varint,3,opt,name=dtype,proto3,enum=pb.DType" json:"dtype,omitempty"`
	Size  int64       `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"` // used only in LABEL
	// In slice columns these arrays will be of length 1
	Ints    []int64   `protobuf:"varint,5,rep,packed,name=ints,proto3" json:"ints,omitempty"`
	Floats  []float64 `protobuf:"fixed64,6,rep,packed,name=floats,proto3" json:"floats,omitempty"`
	Strings []string  `protobuf:"bytes,7,rep,name=strings,proto3" json:"strings,omitempty"`
	Times   []int64   `protobuf:"varint,8,rep,packed,name=times,proto3" json:"times,omitempty"` // epoch nano
	Bools   []bool    `protobuf:"varint,9,rep,packed,name=bools,proto3" json:"bools,omitempty"`
	// contains filtered or unexported fields
}

func (*Column) Descriptor deprecated 

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

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetBools 

func (x *Column) GetBools() []bool

func (*Column) GetDtype 

func (x *Column) GetDtype() DType

func (*Column) GetFloats 

func (x *Column) GetFloats() []float64

func (*Column) GetInts 

func (x *Column) GetInts() []int64

func (*Column) GetKind 

func (x *Column) GetKind() Column_Kind

func (*Column) GetName 

func (x *Column) GetName() string

func (*Column) GetSize 

func (x *Column) GetSize() int64

func (*Column) GetStrings 

func (x *Column) GetStrings() []string

func (*Column) GetTimes 

func (x *Column) GetTimes() []int64

func (*Column) ProtoMessage 

func (*Column) ProtoMessage()

func (*Column) ProtoReflect added in v0.12.0 

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

func (*Column) Reset 

func (x *Column) Reset()

func (*Column) String 

func (x *Column) String() string

type Column_Kind 

type Column_Kind int32
const (
	Column_SLICE Column_Kind = 0
	Column_LABEL Column_Kind = 1
)

func (Column_Kind) Descriptor added in v0.12.0 

func (Column_Kind) Descriptor() protoreflect.EnumDescriptor

func (Column_Kind) Enum added in v0.12.0 

func (x Column_Kind) Enum() *Column_Kind

func (Column_Kind) EnumDescriptor deprecated 

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

Deprecated: Use Column_Kind.Descriptor instead.

func (Column_Kind) Number added in v0.12.0 

func (x Column_Kind) Number() protoreflect.EnumNumber

func (Column_Kind) String 

func (x Column_Kind) String() string

func (Column_Kind) Type added in v0.12.0 

func (Column_Kind) Type() protoreflect.EnumType

type CreateRequest 

type CreateRequest struct {
	Session  *Session     `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Backend  string       `protobuf:"bytes,2,opt,name=backend,proto3" json:"backend,omitempty"` // name of the backend
	Table    string       `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`     // Table name (path)
	Schema   *TableSchema `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"`   // Schema (for describing unstructured/schemaless data)
	IfExists ErrorOptions `protobuf:"varint,5,opt,name=if_exists,json=ifExists,proto3,enum=pb.ErrorOptions" json:"if_exists,omitempty"`
	// TSDB
	Rate                   string `protobuf:"bytes,6,opt,name=rate,proto3" json:"rate,omitempty"` //Sample rate
	Aggregates             string `protobuf:"bytes,7,opt,name=aggregates,proto3" json:"aggregates,omitempty"`
	AggregationGranularity string `` /* 127-byte string literal not displayed */
	// Stream
	Shards         int64 `protobuf:"varint,9,opt,name=shards,proto3" json:"shards,omitempty"`
	RetentionHours int64 `protobuf:"varint,10,opt,name=retention_hours,json=retentionHours,proto3" json:"retention_hours,omitempty"`
	// contains filtered or unexported fields
}

CreateRequest is a table creation request

func (*CreateRequest) Descriptor deprecated 

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

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) GetAggregates 

func (x *CreateRequest) GetAggregates() string

func (*CreateRequest) GetAggregationGranularity 

func (x *CreateRequest) GetAggregationGranularity() string

func (*CreateRequest) GetBackend 

func (x *CreateRequest) GetBackend() string

func (*CreateRequest) GetIfExists 

func (x *CreateRequest) GetIfExists() ErrorOptions

func (*CreateRequest) GetRate 

func (x *CreateRequest) GetRate() string

func (*CreateRequest) GetRetentionHours 

func (x *CreateRequest) GetRetentionHours() int64

func (*CreateRequest) GetSchema 

func (x *CreateRequest) GetSchema() *TableSchema

func (*CreateRequest) GetSession 

func (x *CreateRequest) GetSession() *Session

func (*CreateRequest) GetShards 

func (x *CreateRequest) GetShards() int64

func (*CreateRequest) GetTable 

func (x *CreateRequest) GetTable() string

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect added in v0.12.0 

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

func (*CreateRequest) Reset 

func (x *CreateRequest) Reset()

func (*CreateRequest) String 

func (x *CreateRequest) String() string

type CreateResponse 

type CreateResponse struct {
	// contains filtered or unexported fields
}

func (*CreateResponse) Descriptor deprecated 

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

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect added in v0.12.0 

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

func (*CreateResponse) Reset 

func (x *CreateResponse) Reset()

func (*CreateResponse) String 

func (x *CreateResponse) String() string

type DType 

type DType int32
const (
	DType_NONE    DType = 0
	DType_INTEGER DType = 1
	DType_FLOAT   DType = 2
	DType_STRING  DType = 3
	DType_TIME    DType = 4
	DType_BOOLEAN DType = 5
	DType_NULL    DType = 6
)

func (DType) Descriptor added in v0.12.0 

func (DType) Descriptor() protoreflect.EnumDescriptor

func (DType) Enum added in v0.12.0 

func (x DType) Enum() *DType

func (DType) EnumDescriptor deprecated 

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

Deprecated: Use DType.Descriptor instead.

func (DType) Number added in v0.12.0 

func (x DType) Number() protoreflect.EnumNumber

func (DType) String 

func (x DType) String() string

func (DType) Type added in v0.12.0 

func (DType) Type() protoreflect.EnumType

type DeleteRequest 

type DeleteRequest struct {
	Session   *Session     `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Backend   string       `protobuf:"bytes,2,opt,name=backend,proto3" json:"backend,omitempty"`                                            // Name of the backend
	Table     string       `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`                                                // Table name (path)
	Filter    string       `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`                                              // Filter string for selective delete
	IfMissing ErrorOptions `protobuf:"varint,5,opt,name=if_missing,json=ifMissing,proto3,enum=pb.ErrorOptions" json:"if_missing,omitempty"` // Ignore error on missing table
	// TSDB and Stream specific fields
	Start   string   `protobuf:"bytes,6,opt,name=start,proto3" json:"start,omitempty"`
	End     string   `protobuf:"bytes,7,opt,name=end,proto3" json:"end,omitempty"`
	Metrics []string `protobuf:"bytes,8,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

DeleteRequest is a deletion request

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetBackend 

func (x *DeleteRequest) GetBackend() string

func (*DeleteRequest) GetEnd 

func (x *DeleteRequest) GetEnd() string

func (*DeleteRequest) GetFilter 

func (x *DeleteRequest) GetFilter() string

func (*DeleteRequest) GetIfMissing 

func (x *DeleteRequest) GetIfMissing() ErrorOptions

func (*DeleteRequest) GetMetrics 

func (x *DeleteRequest) GetMetrics() []string

func (*DeleteRequest) GetSession 

func (x *DeleteRequest) GetSession() *Session

func (*DeleteRequest) GetStart 

func (x *DeleteRequest) GetStart() string

func (*DeleteRequest) GetTable 

func (x *DeleteRequest) GetTable() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect added in v0.12.0 

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

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DeleteResponse 

type DeleteResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteResponse) Descriptor deprecated 

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect added in v0.12.0 

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

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

type ErrorOptions 

type ErrorOptions int32
const (
	ErrorOptions_FAIL   ErrorOptions = 0 // Default to fail on error
	ErrorOptions_IGNORE ErrorOptions = 1
)

func (ErrorOptions) Descriptor added in v0.12.0 

func (ErrorOptions) Descriptor() protoreflect.EnumDescriptor

func (ErrorOptions) Enum added in v0.12.0 

func (x ErrorOptions) Enum() *ErrorOptions

func (ErrorOptions) EnumDescriptor deprecated 

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

Deprecated: Use ErrorOptions.Descriptor instead.

func (ErrorOptions) Number added in v0.12.0 

func (x ErrorOptions) Number() protoreflect.EnumNumber

func (ErrorOptions) String 

func (x ErrorOptions) String() string

func (ErrorOptions) Type added in v0.12.0 

func (ErrorOptions) Type() protoreflect.EnumType

type ExecRequest 

type ExecRequest struct {
	Session *Session          `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Backend string            `protobuf:"bytes,2,opt,name=backend,proto3" json:"backend,omitempty"` // Name of the backend
	Table   string            `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`     // Table name (path)
	Command string            `protobuf:"bytes,4,opt,name=command,proto3" json:"command,omitempty"` // Command to execute
	Args    map[string]*Value ``                                                                    // Command arguments
	/* 149-byte string literal not displayed */
	Expression string `protobuf:"bytes,6,opt,name=expression,proto3" json:"expression,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecRequest) Arg 

func (r *ExecRequest) Arg(name string) (interface{}, error)

Arg returns the value of argument

func (*ExecRequest) Descriptor deprecated 

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

Deprecated: Use ExecRequest.ProtoReflect.Descriptor instead.

func (*ExecRequest) GetArgs 

func (x *ExecRequest) GetArgs() map[string]*Value

func (*ExecRequest) GetBackend 

func (x *ExecRequest) GetBackend() string

func (*ExecRequest) GetCommand 

func (x *ExecRequest) GetCommand() string

func (*ExecRequest) GetExpression 

func (x *ExecRequest) GetExpression() string

func (*ExecRequest) GetSession 

func (x *ExecRequest) GetSession() *Session

func (*ExecRequest) GetTable 

func (x *ExecRequest) GetTable() string

func (*ExecRequest) ProtoMessage 

func (*ExecRequest) ProtoMessage()

func (*ExecRequest) ProtoReflect added in v0.12.0 

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

func (*ExecRequest) Reset 

func (x *ExecRequest) Reset()

func (*ExecRequest) String 

func (x *ExecRequest) String() string

type ExecResponse 

type ExecResponse struct {
	Frame *Frame `protobuf:"bytes,1,opt,name=frame,proto3" json:"frame,omitempty"`
	Rows  int64  `protobuf:"varint,2,opt,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecResponse) Descriptor deprecated 

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

Deprecated: Use ExecResponse.ProtoReflect.Descriptor instead.

func (*ExecResponse) GetFrame 

func (x *ExecResponse) GetFrame() *Frame

func (*ExecResponse) GetRows added in v0.8.6 

func (x *ExecResponse) GetRows() int64

func (*ExecResponse) ProtoMessage 

func (*ExecResponse) ProtoMessage()

func (*ExecResponse) ProtoReflect added in v0.12.0 

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

func (*ExecResponse) Reset 

func (x *ExecResponse) Reset()

func (*ExecResponse) String 

func (x *ExecResponse) String() string

type Frame 

type Frame struct {
	Columns    []*Column         `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	Indices    []*Column         `protobuf:"bytes,2,rep,name=indices,proto3" json:"indices,omitempty"`
	Labels     map[string]*Value ``                                                                /* 153-byte string literal not displayed */
	Error      string            `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"` // Used in errors when reading over HTTP
	NullValues []*NullValuesMap  `protobuf:"bytes,5,rep,name=null_values,json=nullValues,proto3" json:"null_values,omitempty"`
	// contains filtered or unexported fields
}

func (*Frame) Descriptor deprecated 

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

Deprecated: Use Frame.ProtoReflect.Descriptor instead.

func (*Frame) GetColumns 

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

func (*Frame) GetError 

func (x *Frame) GetError() string

func (*Frame) GetIndices 

func (x *Frame) GetIndices() []*Column

func (*Frame) GetLabels 

func (x *Frame) GetLabels() map[string]*Value

func (*Frame) GetNullValues 

func (x *Frame) GetNullValues() []*NullValuesMap

func (*Frame) ProtoMessage 

func (*Frame) ProtoMessage()

func (*Frame) ProtoReflect added in v0.12.0 

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

func (*Frame) Reset 

func (x *Frame) Reset()

func (*Frame) String 

func (x *Frame) String() string

type Framed 

type Framed interface {
	Proto() *Frame
}

Framed is a frame based on protobuf

type FramesClient 

type FramesClient interface {
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Frame], error)
	Write(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[WriteRequest, WriteRespose], error)
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Exec(ctx context.Context, in *ExecRequest, opts ...grpc.CallOption) (*ExecResponse, error)
	History(ctx context.Context, in *HistoryRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Frame], error)
	Version(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error)
}

FramesClient is the client API for Frames 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 NewFramesClient 

func NewFramesClient(cc grpc.ClientConnInterface) FramesClient

type FramesServer 

type FramesServer interface {
	Read(*ReadRequest, grpc.ServerStreamingServer[Frame]) error
	Write(grpc.ClientStreamingServer[WriteRequest, WriteRespose]) error
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Exec(context.Context, *ExecRequest) (*ExecResponse, error)
	History(*HistoryRequest, grpc.ServerStreamingServer[Frame]) error
	Version(context.Context, *VersionRequest) (*VersionResponse, error)
}

FramesServer is the server API for Frames service. All implementations should embed UnimplementedFramesServer for forward compatibility.

type Frames_HistoryClient added in v0.7.6 

type Frames_HistoryClient = grpc.ServerStreamingClient[Frame]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Frames_HistoryServer added in v0.7.6 

type Frames_HistoryServer = grpc.ServerStreamingServer[Frame]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Frames_ReadClient 

type Frames_ReadClient = grpc.ServerStreamingClient[Frame]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Frames_ReadServer 

type Frames_ReadServer = grpc.ServerStreamingServer[Frame]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Frames_WriteClient 

type Frames_WriteClient = grpc.ClientStreamingClient[WriteRequest, WriteRespose]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Frames_WriteServer 

type Frames_WriteServer = grpc.ClientStreamingServer[WriteRequest, WriteRespose]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type HistoryRequest added in v0.7.6 

type HistoryRequest struct {
	Session      *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Backend      string   `protobuf:"bytes,2,opt,name=backend,proto3" json:"backend,omitempty"`                                 // Filter by backend type
	Table        string   `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`                                     // Filter by Table name
	User         string   `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`                                       // Filter by the user executed the command
	Action       string   `protobuf:"bytes,5,opt,name=action,proto3" json:"action,omitempty"`                                   // Filter by Action type
	MinStartTime string   `protobuf:"bytes,6,opt,name=min_start_time,json=minStartTime,proto3" json:"min_start_time,omitempty"` // Filter time range
	MaxStartTime string   `protobuf:"bytes,7,opt,name=max_start_time,json=maxStartTime,proto3" json:"max_start_time,omitempty"` // Filter time range
	Container    string   `protobuf:"bytes,8,opt,name=container,proto3" json:"container,omitempty"`                             // Filter time range
	MinDuration  int64    `protobuf:"varint,9,opt,name=min_duration,json=minDuration,proto3" json:"min_duration,omitempty"`     // Filter time range
	MaxDuration  int64    `protobuf:"varint,10,opt,name=max_duration,json=maxDuration,proto3" json:"max_duration,omitempty"`    // Filter time range
	// contains filtered or unexported fields
}

func (*HistoryRequest) Descriptor deprecated added in v0.7.6 

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

Deprecated: Use HistoryRequest.ProtoReflect.Descriptor instead.

func (*HistoryRequest) GetAction added in v0.7.6 

func (x *HistoryRequest) GetAction() string

func (*HistoryRequest) GetBackend added in v0.7.6 

func (x *HistoryRequest) GetBackend() string

func (*HistoryRequest) GetContainer added in v0.7.6 

func (x *HistoryRequest) GetContainer() string

func (*HistoryRequest) GetMaxDuration added in v0.7.6 

func (x *HistoryRequest) GetMaxDuration() int64

func (*HistoryRequest) GetMaxStartTime added in v0.7.6 

func (x *HistoryRequest) GetMaxStartTime() string

func (*HistoryRequest) GetMinDuration added in v0.7.6 

func (x *HistoryRequest) GetMinDuration() int64

func (*HistoryRequest) GetMinStartTime added in v0.7.6 

func (x *HistoryRequest) GetMinStartTime() string

func (*HistoryRequest) GetSession added in v0.7.6 

func (x *HistoryRequest) GetSession() *Session

func (*HistoryRequest) GetTable added in v0.7.6 

func (x *HistoryRequest) GetTable() string

func (*HistoryRequest) GetUser added in v0.7.6 

func (x *HistoryRequest) GetUser() string

func (*HistoryRequest) ProtoMessage added in v0.7.6 

func (*HistoryRequest) ProtoMessage()

func (*HistoryRequest) ProtoReflect added in v0.12.0 

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

func (*HistoryRequest) Reset added in v0.7.6 

func (x *HistoryRequest) Reset()

func (*HistoryRequest) String added in v0.7.6 

func (x *HistoryRequest) String() string

type InitialWriteRequest 

type InitialWriteRequest struct {
	Session       *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Backend       string   `protobuf:"bytes,2,opt,name=backend,proto3" json:"backend,omitempty"`
	Table         string   `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	InitialData   *Frame   `protobuf:"bytes,4,opt,name=initial_data,json=initialData,proto3" json:"initial_data,omitempty"`
	Expression    string   `protobuf:"bytes,5,opt,name=expression,proto3" json:"expression,omitempty"`                            // NoSQL
	More          bool     `protobuf:"varint,6,opt,name=more,proto3" json:"more,omitempty"`                                       // Stream
	PartitionKeys []string `protobuf:"bytes,7,rep,name=partition_keys,json=partitionKeys,proto3" json:"partition_keys,omitempty"` // NoSQL
	Condition     string   `protobuf:"bytes,8,opt,name=condition,proto3" json:"condition,omitempty"`                              // NoSQL
	SaveMode      string   `protobuf:"bytes,9,opt,name=save_mode,json=saveMode,proto3" json:"save_mode,omitempty"`                // NoSQL
	// contains filtered or unexported fields
}

func (*InitialWriteRequest) Descriptor deprecated 

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

Deprecated: Use InitialWriteRequest.ProtoReflect.Descriptor instead.

func (*InitialWriteRequest) GetBackend 

func (x *InitialWriteRequest) GetBackend() string

func (*InitialWriteRequest) GetCondition 

func (x *InitialWriteRequest) GetCondition() string

func (*InitialWriteRequest) GetExpression 

func (x *InitialWriteRequest) GetExpression() string

func (*InitialWriteRequest) GetInitialData 

func (x *InitialWriteRequest) GetInitialData() *Frame

func (*InitialWriteRequest) GetMore 

func (x *InitialWriteRequest) GetMore() bool

func (*InitialWriteRequest) GetPartitionKeys 

func (x *InitialWriteRequest) GetPartitionKeys() []string

func (*InitialWriteRequest) GetSaveMode 

func (x *InitialWriteRequest) GetSaveMode() string

func (*InitialWriteRequest) GetSession 

func (x *InitialWriteRequest) GetSession() *Session

func (*InitialWriteRequest) GetTable 

func (x *InitialWriteRequest) GetTable() string

func (*InitialWriteRequest) ProtoMessage 

func (*InitialWriteRequest) ProtoMessage()

func (*InitialWriteRequest) ProtoReflect added in v0.12.0 

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

func (*InitialWriteRequest) Reset 

func (x *InitialWriteRequest) Reset()

func (*InitialWriteRequest) String 

func (x *InitialWriteRequest) String() string

type JoinStruct 

type JoinStruct struct {
	// contains filtered or unexported fields
}

func (*JoinStruct) Descriptor deprecated 

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

Deprecated: Use JoinStruct.ProtoReflect.Descriptor instead.

func (*JoinStruct) ProtoMessage 

func (*JoinStruct) ProtoMessage()

func (*JoinStruct) ProtoReflect added in v0.12.0 

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

func (*JoinStruct) Reset 

func (x *JoinStruct) Reset()

func (*JoinStruct) String 

func (x *JoinStruct) String() string

type NullValuesMap 

type NullValuesMap struct {
	NullColumns map[string]bool `` /* 164-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NullValuesMap) Descriptor deprecated 

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

Deprecated: Use NullValuesMap.ProtoReflect.Descriptor instead.

func (*NullValuesMap) GetNullColumns 

func (x *NullValuesMap) GetNullColumns() map[string]bool

func (*NullValuesMap) ProtoMessage 

func (*NullValuesMap) ProtoMessage()

func (*NullValuesMap) ProtoReflect added in v0.12.0 

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

func (*NullValuesMap) Reset 

func (x *NullValuesMap) Reset()

func (*NullValuesMap) String 

func (x *NullValuesMap) String() string

type ReadRequest 

type ReadRequest struct {
	Session      *Session      `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Backend      string        `protobuf:"bytes,2,opt,name=backend,proto3" json:"backend,omitempty"`
	Schema       *TableSchema  `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	DataFormat   string        `protobuf:"bytes,4,opt,name=data_format,json=dataFormat,proto3" json:"data_format,omitempty"`
	RowLayout    bool          `protobuf:"varint,5,opt,name=row_layout,json=rowLayout,proto3" json:"row_layout,omitempty"`
	MultiIndex   bool          `protobuf:"varint,6,opt,name=multi_index,json=multiIndex,proto3" json:"multi_index,omitempty"` // TSDB
	Query        string        `protobuf:"bytes,7,opt,name=query,proto3" json:"query,omitempty"`                              // TSDB - SQL Query
	Table        string        `protobuf:"bytes,8,opt,name=table,proto3" json:"table,omitempty"`                              // Table name
	Columns      []string      `protobuf:"bytes,9,rep,name=columns,proto3" json:"columns,omitempty"`
	Filter       string        `protobuf:"bytes,10,opt,name=filter,proto3" json:"filter,omitempty"`
	GroupBy      string        `protobuf:"bytes,11,opt,name=group_by,json=groupBy,proto3" json:"group_by,omitempty"` // TSDB
	Join         []*JoinStruct `protobuf:"bytes,12,rep,name=join,proto3" json:"join,omitempty"`
	Limit        int64         `protobuf:"varint,13,opt,name=limit,proto3" json:"limit,omitempty"`
	MessageLimit int64         `protobuf:"varint,14,opt,name=message_limit,json=messageLimit,proto3" json:"message_limit,omitempty"`
	Marker       string        `protobuf:"bytes,15,opt,name=marker,proto3" json:"marker,omitempty"`
	ResetIndex   bool          `protobuf:"varint,29,opt,name=reset_index,json=resetIndex,proto3" json:"reset_index,omitempty"`
	// NoSQL
	Segments          []int64  `protobuf:"varint,16,rep,packed,name=segments,proto3" json:"segments,omitempty"`
	TotalSegments     int64    `protobuf:"varint,17,opt,name=total_segments,json=totalSegments,proto3" json:"total_segments,omitempty"`
	ShardingKeys      []string `protobuf:"bytes,18,rep,name=sharding_keys,json=shardingKeys,proto3" json:"sharding_keys,omitempty"`
	SortKeyRangeStart string   `protobuf:"bytes,19,opt,name=sort_key_range_start,json=sortKeyRangeStart,proto3" json:"sort_key_range_start,omitempty"`
	SortKeyRangeEnd   string   `protobuf:"bytes,20,opt,name=sort_key_range_end,json=sortKeyRangeEnd,proto3" json:"sort_key_range_end,omitempty"`
	// TSDB
	Start             string `protobuf:"bytes,21,opt,name=start,proto3" json:"start,omitempty"`
	End               string `protobuf:"bytes,22,opt,name=end,proto3" json:"end,omitempty"`
	Step              string `protobuf:"bytes,23,opt,name=step,proto3" json:"step,omitempty"`
	Aggregators       string `protobuf:"bytes,24,opt,name=aggregators,proto3" json:"aggregators,omitempty"`
	AggregationWindow string `protobuf:"bytes,28,opt,name=aggregation_window,json=aggregationWindow,proto3" json:"aggregation_window,omitempty"`
	// Stream
	Seek     string `protobuf:"bytes,25,opt,name=seek,proto3" json:"seek,omitempty"`
	ShardId  string `protobuf:"bytes,26,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Sequence int64  `protobuf:"varint,27,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadRequest) Descriptor deprecated 

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

Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.

func (*ReadRequest) GetAggregationWindow 

func (x *ReadRequest) GetAggregationWindow() string

func (*ReadRequest) GetAggregators 

func (x *ReadRequest) GetAggregators() string

func (*ReadRequest) GetBackend 

func (x *ReadRequest) GetBackend() string

func (*ReadRequest) GetColumns 

func (x *ReadRequest) GetColumns() []string

func (*ReadRequest) GetDataFormat 

func (x *ReadRequest) GetDataFormat() string

func (*ReadRequest) GetEnd 

func (x *ReadRequest) GetEnd() string

func (*ReadRequest) GetFilter 

func (x *ReadRequest) GetFilter() string

func (*ReadRequest) GetGroupBy 

func (x *ReadRequest) GetGroupBy() string

func (*ReadRequest) GetJoin 

func (x *ReadRequest) GetJoin() []*JoinStruct

func (*ReadRequest) GetLimit 

func (x *ReadRequest) GetLimit() int64

func (*ReadRequest) GetMarker 

func (x *ReadRequest) GetMarker() string

func (*ReadRequest) GetMessageLimit 

func (x *ReadRequest) GetMessageLimit() int64

func (*ReadRequest) GetMultiIndex 

func (x *ReadRequest) GetMultiIndex() bool

func (*ReadRequest) GetQuery 

func (x *ReadRequest) GetQuery() string

func (*ReadRequest) GetResetIndex 

func (x *ReadRequest) GetResetIndex() bool

func (*ReadRequest) GetRowLayout 

func (x *ReadRequest) GetRowLayout() bool

func (*ReadRequest) GetSchema 

func (x *ReadRequest) GetSchema() *TableSchema

func (*ReadRequest) GetSeek 

func (x *ReadRequest) GetSeek() string

func (*ReadRequest) GetSegments 

func (x *ReadRequest) GetSegments() []int64

func (*ReadRequest) GetSequence 

func (x *ReadRequest) GetSequence() int64

func (*ReadRequest) GetSession 

func (x *ReadRequest) GetSession() *Session

func (*ReadRequest) GetShardId 

func (x *ReadRequest) GetShardId() string

func (*ReadRequest) GetShardingKeys 

func (x *ReadRequest) GetShardingKeys() []string

func (*ReadRequest) GetSortKeyRangeEnd 

func (x *ReadRequest) GetSortKeyRangeEnd() string

func (*ReadRequest) GetSortKeyRangeStart 

func (x *ReadRequest) GetSortKeyRangeStart() string

func (*ReadRequest) GetStart 

func (x *ReadRequest) GetStart() string

func (*ReadRequest) GetStep 

func (x *ReadRequest) GetStep() string

func (*ReadRequest) GetTable 

func (x *ReadRequest) GetTable() string

func (*ReadRequest) GetTotalSegments 

func (x *ReadRequest) GetTotalSegments() int64

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) ProtoReflect added in v0.12.0 

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

func (*ReadRequest) Reset 

func (x *ReadRequest) Reset()

func (*ReadRequest) String 

func (x *ReadRequest) String() string

type SchemaField 

type SchemaField struct {
	Name       string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Doc        string            `protobuf:"bytes,2,opt,name=doc,proto3" json:"doc,omitempty"`
	Default    *Value            `protobuf:"bytes,3,opt,name=default,proto3" json:"default,omitempty"`
	Type       string            `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Properties map[string]*Value `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

TODO: Place these under TableSchema

func (*SchemaField) Descriptor deprecated 

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

Deprecated: Use SchemaField.ProtoReflect.Descriptor instead.

func (*SchemaField) GetDefault 

func (x *SchemaField) GetDefault() *Value

func (*SchemaField) GetDoc 

func (x *SchemaField) GetDoc() string

func (*SchemaField) GetName 

func (x *SchemaField) GetName() string

func (*SchemaField) GetProperties 

func (x *SchemaField) GetProperties() map[string]*Value

func (*SchemaField) GetType 

func (x *SchemaField) GetType() string

func (*SchemaField) Property 

func (s *SchemaField) Property(key string) (interface{}, bool)

Property return a schema property

func (*SchemaField) ProtoMessage 

func (*SchemaField) ProtoMessage()

func (*SchemaField) ProtoReflect added in v0.12.0 

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

func (*SchemaField) Reset 

func (x *SchemaField) Reset()

func (*SchemaField) String 

func (x *SchemaField) String() string

type SchemaKey 

type SchemaKey struct {
	ShardingKey []string `protobuf:"bytes,1,rep,name=sharding_key,json=shardingKey,proto3" json:"sharding_key,omitempty"`
	SortingKey  []string `protobuf:"bytes,2,rep,name=sorting_key,json=sortingKey,proto3" json:"sorting_key,omitempty"`
	// contains filtered or unexported fields
}

func (*SchemaKey) Descriptor deprecated 

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

Deprecated: Use SchemaKey.ProtoReflect.Descriptor instead.

func (*SchemaKey) GetShardingKey 

func (x *SchemaKey) GetShardingKey() []string

func (*SchemaKey) GetSortingKey 

func (x *SchemaKey) GetSortingKey() []string

func (*SchemaKey) ProtoMessage 

func (*SchemaKey) ProtoMessage()

func (*SchemaKey) ProtoReflect added in v0.12.0 

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

func (*SchemaKey) Reset 

func (x *SchemaKey) Reset()

func (*SchemaKey) String 

func (x *SchemaKey) String() string

type Session 

type Session struct {
	Url       string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Container string `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"`
	Path      string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	User      string `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
	Password  string `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"`
	Token     string `protobuf:"bytes,6,opt,name=token,proto3" json:"token,omitempty"`
	Id        string `protobuf:"bytes,7,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*Session) Descriptor deprecated 

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

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) Format 

func (s *Session) Format(state fmt.State, verb rune)

Format implements fmt.Formatter We're doing this to hide passwords from prints

func (*Session) GetContainer 

func (x *Session) GetContainer() string

func (*Session) GetId 

func (x *Session) GetId() string

func (*Session) GetPassword 

func (x *Session) GetPassword() string

func (*Session) GetPath 

func (x *Session) GetPath() string

func (*Session) GetToken 

func (x *Session) GetToken() string

func (*Session) GetUrl 

func (x *Session) GetUrl() string

func (*Session) GetUser 

func (x *Session) GetUser() string

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) ProtoReflect added in v0.12.0 

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

func (*Session) Reset 

func (x *Session) Reset()

func (*Session) String 

func (x *Session) String() string

type TableSchema 

type TableSchema struct {
	Type      string         `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Namespace string         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name      string         `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Doc       string         `protobuf:"bytes,4,opt,name=doc,proto3" json:"doc,omitempty"`
	Aliases   []string       `protobuf:"bytes,5,rep,name=aliases,proto3" json:"aliases,omitempty"`
	Fields    []*SchemaField `protobuf:"bytes,6,rep,name=fields,proto3" json:"fields,omitempty"`
	Key       *SchemaKey     `protobuf:"bytes,7,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

TODO: Rename to Schema?

func (*TableSchema) Descriptor deprecated 

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

Deprecated: Use TableSchema.ProtoReflect.Descriptor instead.

func (*TableSchema) GetAliases 

func (x *TableSchema) GetAliases() []string

func (*TableSchema) GetDoc 

func (x *TableSchema) GetDoc() string

func (*TableSchema) GetFields 

func (x *TableSchema) GetFields() []*SchemaField

func (*TableSchema) GetKey 

func (x *TableSchema) GetKey() *SchemaKey

func (*TableSchema) GetName 

func (x *TableSchema) GetName() string

func (*TableSchema) GetNamespace 

func (x *TableSchema) GetNamespace() string

func (*TableSchema) GetType 

func (x *TableSchema) GetType() string

func (*TableSchema) ProtoMessage 

func (*TableSchema) ProtoMessage()

func (*TableSchema) ProtoReflect added in v0.12.0 

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

func (*TableSchema) Reset 

func (x *TableSchema) Reset()

func (*TableSchema) String 

func (x *TableSchema) String() string

type UnimplementedFramesServer added in v0.12.0 

type UnimplementedFramesServer struct{}

UnimplementedFramesServer should 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 (UnimplementedFramesServer) Create added in v0.12.0 

func (UnimplementedFramesServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)

func (UnimplementedFramesServer) Delete added in v0.12.0 

func (UnimplementedFramesServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

func (UnimplementedFramesServer) Exec added in v0.12.0 

func (UnimplementedFramesServer) Exec(context.Context, *ExecRequest) (*ExecResponse, error)

func (UnimplementedFramesServer) History added in v0.12.0 

func (UnimplementedFramesServer) History(*HistoryRequest, grpc.ServerStreamingServer[Frame]) error

func (UnimplementedFramesServer) Read added in v0.12.0 

func (UnimplementedFramesServer) Read(*ReadRequest, grpc.ServerStreamingServer[Frame]) error

func (UnimplementedFramesServer) Version added in v0.12.0 

func (UnimplementedFramesServer) Version(context.Context, *VersionRequest) (*VersionResponse, error)

func (UnimplementedFramesServer) Write added in v0.12.0 

func (UnimplementedFramesServer) Write(grpc.ClientStreamingServer[WriteRequest, WriteRespose]) error

type UnsafeFramesServer added in v0.12.0 

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

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

type Value 

type Value struct {

	// Types that are assignable to Value:
	//
	//	*Value_Ival
	//	*Value_Fval
	//	*Value_Sval
	//	*Value_Tval
	//	*Value_Bval
	Value isValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

Union of values

func (*Value) Descriptor deprecated 

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetBval 

func (x *Value) GetBval() bool

func (*Value) GetFval 

func (x *Value) GetFval() float64

func (*Value) GetIval 

func (x *Value) GetIval() int64

func (*Value) GetSval 

func (x *Value) GetSval() string

func (*Value) GetTval 

func (x *Value) GetTval() int64

func (*Value) GetValue 

func (m *Value) GetValue() isValue_Value

func (*Value) GoValue 

func (v *Value) GoValue() (interface{}, error)

GoValue return value as interface{}

func (*Value) MarshalJSON 

func (v *Value) MarshalJSON() ([]byte, error)

MarshalJSON marshal Value as JSON object

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect added in v0.12.0 

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

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) SetValue 

func (v *Value) SetValue(i interface{}) error

SetValue sets the value from Go type

func (*Value) String 

func (x *Value) String() string

func (*Value) UnmarshalJSON 

func (v *Value) UnmarshalJSON(data []byte) error

UnmarshalJSON will unmarshal encoded native Go type to value (Implement json.Unmarshaler interface)

type Value_Bval 

type Value_Bval struct {
	Bval bool `protobuf:"varint,5,opt,name=bval,proto3,oneof"`
}

type Value_Fval 

type Value_Fval struct {
	Fval float64 `protobuf:"fixed64,2,opt,name=fval,proto3,oneof"`
}

type Value_Ival 

type Value_Ival struct {
	Ival int64 `protobuf:"varint,1,opt,name=ival,proto3,oneof"`
}

type Value_Sval 

type Value_Sval struct {
	Sval string `protobuf:"bytes,3,opt,name=sval,proto3,oneof"`
}

type Value_Tval 

type Value_Tval struct {
	Tval int64 `protobuf:"varint,4,opt,name=tval,proto3,oneof"` // epoch nano
}

type VersionRequest added in v0.8.6 

type VersionRequest struct {
	// contains filtered or unexported fields
}

func (*VersionRequest) Descriptor deprecated added in v0.8.6 

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

Deprecated: Use VersionRequest.ProtoReflect.Descriptor instead.

func (*VersionRequest) ProtoMessage added in v0.8.6 

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) ProtoReflect added in v0.12.0 

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

func (*VersionRequest) Reset added in v0.8.6 

func (x *VersionRequest) Reset()

func (*VersionRequest) String added in v0.8.6 

func (x *VersionRequest) String() string

type VersionResponse added in v0.8.6 

type VersionResponse struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionResponse) Descriptor deprecated added in v0.8.6 

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

Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.

func (*VersionResponse) GetVersion added in v0.8.6 

func (x *VersionResponse) GetVersion() string

func (*VersionResponse) ProtoMessage added in v0.8.6 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) ProtoReflect added in v0.12.0 

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

func (*VersionResponse) Reset added in v0.8.6 

func (x *VersionResponse) Reset()

func (*VersionResponse) String added in v0.8.6 

func (x *VersionResponse) String() string

type WriteRequest 

type WriteRequest struct {

	// Types that are assignable to Type:
	//
	//	*WriteRequest_Request
	//	*WriteRequest_Frame
	Type isWriteRequest_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*WriteRequest) Descriptor deprecated 

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

Deprecated: Use WriteRequest.ProtoReflect.Descriptor instead.

func (*WriteRequest) GetFrame 

func (x *WriteRequest) GetFrame() *Frame

func (*WriteRequest) GetRequest 

func (x *WriteRequest) GetRequest() *InitialWriteRequest

func (*WriteRequest) GetType 

func (m *WriteRequest) GetType() isWriteRequest_Type

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) ProtoReflect added in v0.12.0 

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

func (*WriteRequest) Reset 

func (x *WriteRequest) Reset()

func (*WriteRequest) String 

func (x *WriteRequest) String() string

type WriteRequest_Frame 

type WriteRequest_Frame struct {
	Frame *Frame `protobuf:"bytes,2,opt,name=frame,proto3,oneof"`
}

type WriteRequest_Request 

type WriteRequest_Request struct {
	Request *InitialWriteRequest `protobuf:"bytes,1,opt,name=request,proto3,oneof"`
}

type WriteRespose 

type WriteRespose struct {
	Frames int64 `protobuf:"varint,1,opt,name=frames,proto3" json:"frames,omitempty"`
	Rows   int64 `protobuf:"varint,2,opt,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteRespose) Descriptor deprecated 

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

Deprecated: Use WriteRespose.ProtoReflect.Descriptor instead.

func (*WriteRespose) GetFrames 

func (x *WriteRespose) GetFrames() int64

func (*WriteRespose) GetRows 

func (x *WriteRespose) GetRows() int64

func (*WriteRespose) ProtoMessage 

func (*WriteRespose) ProtoMessage()

func (*WriteRespose) ProtoReflect added in v0.12.0 

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

func (*WriteRespose) Reset 

func (x *WriteRespose) Reset()

func (*WriteRespose) String 

func (x *WriteRespose) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.