internal

package
v1.0.3 Latest Latest
Warning

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

 Go to latest Published: Jun 17, 2022 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateIteratorRequest 

type CreateIteratorRequest struct {
	ShardIDs             []uint64 `protobuf:"varint,1,rep,name=ShardIDs" json:"ShardIDs,omitempty"`
	Opt                  []byte   `protobuf:"bytes,2,req,name=Opt" json:"Opt,omitempty"`
	Database             []byte   `protobuf:"bytes,3,req,name=Database" json:"Database,omitempty"`
	RetentionPolicy      []byte   `protobuf:"bytes,4,req,name=RetentionPolicy" json:"RetentionPolicy,omitempty"`
	MeasurementName      []byte   `protobuf:"bytes,5,req,name=MeasurementName" json:"MeasurementName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateIteratorRequest) Descriptor 

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

func (*CreateIteratorRequest) GetDatabase 

func (m *CreateIteratorRequest) GetDatabase() []byte

func (*CreateIteratorRequest) GetMeasurementName 

func (m *CreateIteratorRequest) GetMeasurementName() []byte

func (*CreateIteratorRequest) GetOpt 

func (m *CreateIteratorRequest) GetOpt() []byte

func (*CreateIteratorRequest) GetRetentionPolicy 

func (m *CreateIteratorRequest) GetRetentionPolicy() []byte

func (*CreateIteratorRequest) GetShardIDs 

func (m *CreateIteratorRequest) GetShardIDs() []uint64

func (*CreateIteratorRequest) ProtoMessage 

func (*CreateIteratorRequest) ProtoMessage()

func (*CreateIteratorRequest) Reset 

func (m *CreateIteratorRequest) Reset()

func (*CreateIteratorRequest) String 

func (m *CreateIteratorRequest) String() string

func (*CreateIteratorRequest) XXX_DiscardUnknown 

func (m *CreateIteratorRequest) XXX_DiscardUnknown()

func (*CreateIteratorRequest) XXX_Marshal 

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

func (*CreateIteratorRequest) XXX_Merge 

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

func (*CreateIteratorRequest) XXX_Size 

func (m *CreateIteratorRequest) XXX_Size() int

func (*CreateIteratorRequest) XXX_Unmarshal 

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

type CreateIteratorResponse 

type CreateIteratorResponse struct {
	Err                  *string  `protobuf:"bytes,1,opt,name=Err" json:"Err,omitempty"`
	DataType             *int32   `protobuf:"varint,2,opt,name=DataType" json:"DataType,omitempty"`
	SeriesN              *int32   `protobuf:"varint,3,opt,name=SeriesN" json:"SeriesN,omitempty"`
	PointN               *int32   `protobuf:"varint,4,opt,name=PointN" json:"PointN,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateIteratorResponse) Descriptor 

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

func (*CreateIteratorResponse) GetDataType 

func (m *CreateIteratorResponse) GetDataType() int32

func (*CreateIteratorResponse) GetErr 

func (m *CreateIteratorResponse) GetErr() string

func (*CreateIteratorResponse) GetPointN 

func (m *CreateIteratorResponse) GetPointN() int32

func (*CreateIteratorResponse) GetSeriesN 

func (m *CreateIteratorResponse) GetSeriesN() int32

func (*CreateIteratorResponse) ProtoMessage 

func (*CreateIteratorResponse) ProtoMessage()

func (*CreateIteratorResponse) Reset 

func (m *CreateIteratorResponse) Reset()

func (*CreateIteratorResponse) String 

func (m *CreateIteratorResponse) String() string

func (*CreateIteratorResponse) XXX_DiscardUnknown 

func (m *CreateIteratorResponse) XXX_DiscardUnknown()

func (*CreateIteratorResponse) XXX_Marshal 

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

func (*CreateIteratorResponse) XXX_Merge 

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

func (*CreateIteratorResponse) XXX_Size 

func (m *CreateIteratorResponse) XXX_Size() int

func (*CreateIteratorResponse) XXX_Unmarshal 

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

type ExecuteStatementRequest 

type ExecuteStatementRequest struct {
	Statement            *string  `protobuf:"bytes,1,req,name=Statement" json:"Statement,omitempty"`
	Database             *string  `protobuf:"bytes,2,req,name=Database" json:"Database,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecuteStatementRequest) Descriptor 

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

func (*ExecuteStatementRequest) GetDatabase 

func (m *ExecuteStatementRequest) GetDatabase() string

func (*ExecuteStatementRequest) GetStatement 

func (m *ExecuteStatementRequest) GetStatement() string

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 {
	Code                 *int32   `protobuf:"varint,1,req,name=Code" json:"Code,omitempty"`
	Message              *string  `protobuf:"bytes,2,opt,name=Message" json:"Message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecuteStatementResponse) Descriptor 

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

func (*ExecuteStatementResponse) GetCode 

func (m *ExecuteStatementResponse) GetCode() int32

func (*ExecuteStatementResponse) GetMessage 

func (m *ExecuteStatementResponse) GetMessage() string

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_Size 

func (m *ExecuteStatementResponse) XXX_Size() int

func (*ExecuteStatementResponse) XXX_Unmarshal 

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

type FieldDimensionsRequest 

type FieldDimensionsRequest struct {
	ShardIDs             []uint64 `protobuf:"varint,1,rep,name=ShardIDs" json:"ShardIDs,omitempty"`
	Measurement          []byte   `protobuf:"bytes,2,req,name=Measurement" json:"Measurement,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FieldDimensionsRequest) Descriptor 

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

func (*FieldDimensionsRequest) GetMeasurement 

func (m *FieldDimensionsRequest) GetMeasurement() []byte

func (*FieldDimensionsRequest) GetShardIDs 

func (m *FieldDimensionsRequest) GetShardIDs() []uint64

func (*FieldDimensionsRequest) ProtoMessage 

func (*FieldDimensionsRequest) ProtoMessage()

func (*FieldDimensionsRequest) Reset 

func (m *FieldDimensionsRequest) Reset()

func (*FieldDimensionsRequest) String 

func (m *FieldDimensionsRequest) String() string

func (*FieldDimensionsRequest) XXX_DiscardUnknown 

func (m *FieldDimensionsRequest) XXX_DiscardUnknown()

func (*FieldDimensionsRequest) XXX_Marshal 

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

func (*FieldDimensionsRequest) XXX_Merge 

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

func (*FieldDimensionsRequest) XXX_Size 

func (m *FieldDimensionsRequest) XXX_Size() int

func (*FieldDimensionsRequest) XXX_Unmarshal 

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

type FieldDimensionsResponse 

type FieldDimensionsResponse struct {
	Fields               []byte   `protobuf:"bytes,1,req,name=Fields" json:"Fields,omitempty"`
	Dimensions           []string `protobuf:"bytes,2,rep,name=Dimensions" json:"Dimensions,omitempty"`
	Err                  *string  `protobuf:"bytes,3,opt,name=Err" json:"Err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FieldDimensionsResponse) Descriptor 

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

func (*FieldDimensionsResponse) GetDimensions 

func (m *FieldDimensionsResponse) GetDimensions() []string

func (*FieldDimensionsResponse) GetErr 

func (m *FieldDimensionsResponse) GetErr() string

func (*FieldDimensionsResponse) GetFields 

func (m *FieldDimensionsResponse) GetFields() []byte

func (*FieldDimensionsResponse) ProtoMessage 

func (*FieldDimensionsResponse) ProtoMessage()

func (*FieldDimensionsResponse) Reset 

func (m *FieldDimensionsResponse) Reset()

func (*FieldDimensionsResponse) String 

func (m *FieldDimensionsResponse) String() string

func (*FieldDimensionsResponse) XXX_DiscardUnknown 

func (m *FieldDimensionsResponse) XXX_DiscardUnknown()

func (*FieldDimensionsResponse) XXX_Marshal 

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

func (*FieldDimensionsResponse) XXX_Merge 

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

func (*FieldDimensionsResponse) XXX_Size 

func (m *FieldDimensionsResponse) XXX_Size() int

func (*FieldDimensionsResponse) XXX_Unmarshal 

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

type WriteShardRequest 

type WriteShardRequest struct {
	ShardID              *uint64  `protobuf:"varint,1,req,name=ShardID" json:"ShardID,omitempty"`
	Points               [][]byte `protobuf:"bytes,2,rep,name=Points" json:"Points,omitempty"`
	Database             *string  `protobuf:"bytes,3,opt,name=Database" json:"Database,omitempty"`
	RetentionPolicy      *string  `protobuf:"bytes,4,opt,name=RetentionPolicy" json:"RetentionPolicy,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WriteShardRequest) Descriptor 

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

func (*WriteShardRequest) GetDatabase 

func (m *WriteShardRequest) GetDatabase() string

func (*WriteShardRequest) GetPoints 

func (m *WriteShardRequest) GetPoints() [][]byte

func (*WriteShardRequest) GetRetentionPolicy 

func (m *WriteShardRequest) GetRetentionPolicy() string

func (*WriteShardRequest) GetShardID 

func (m *WriteShardRequest) GetShardID() uint64

func (*WriteShardRequest) ProtoMessage 

func (*WriteShardRequest) ProtoMessage()

func (*WriteShardRequest) Reset 

func (m *WriteShardRequest) Reset()

func (*WriteShardRequest) String 

func (m *WriteShardRequest) String() string

func (*WriteShardRequest) XXX_DiscardUnknown 

func (m *WriteShardRequest) XXX_DiscardUnknown()

func (*WriteShardRequest) XXX_Marshal 

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

func (*WriteShardRequest) XXX_Merge 

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

func (*WriteShardRequest) XXX_Size 

func (m *WriteShardRequest) XXX_Size() int

func (*WriteShardRequest) XXX_Unmarshal 

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

type WriteShardResponse 

type WriteShardResponse struct {
	Code                 *int32   `protobuf:"varint,1,req,name=Code" json:"Code,omitempty"`
	Message              *string  `protobuf:"bytes,2,opt,name=Message" json:"Message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WriteShardResponse) Descriptor 

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

func (*WriteShardResponse) GetCode 

func (m *WriteShardResponse) GetCode() int32

func (*WriteShardResponse) GetMessage 

func (m *WriteShardResponse) GetMessage() string

func (*WriteShardResponse) ProtoMessage 

func (*WriteShardResponse) ProtoMessage()

func (*WriteShardResponse) Reset 

func (m *WriteShardResponse) Reset()

func (*WriteShardResponse) String 

func (m *WriteShardResponse) String() string

func (*WriteShardResponse) XXX_DiscardUnknown 

func (m *WriteShardResponse) XXX_DiscardUnknown()

func (*WriteShardResponse) XXX_Marshal 

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

func (*WriteShardResponse) XXX_Merge 

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

func (*WriteShardResponse) XXX_Size 

func (m *WriteShardResponse) XXX_Size() int

func (*WriteShardResponse) XXX_Unmarshal 

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

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.