rpc

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Nov 12, 2020 License: Apache-2.0 Imports: 8 Imported by: 20

Documentation

Overview

Package rpc is a generated GoMock package.

Package rpc is generated code used to make or handle TChannel calls using Thrift.

Index

Constants

This section is empty.

Variables

View Source
var AggregateQueryRawRequest_Limit_DEFAULT int64
View Source
var AggregateQueryRawRequest_TagNameFilter_DEFAULT [][]byte
View Source
var AggregateQueryRawResultTagNameElement_TagValues_DEFAULT []*AggregateQueryRawResultTagValueElement
View Source
var AggregateQueryRequest_Limit_DEFAULT int64
View Source
var AggregateQueryRequest_TagNameFilter_DEFAULT []string
View Source
var AggregateQueryResultTagNameElement_TagValues_DEFAULT []*AggregateQueryResultTagValueElement
View Source
var BlockMetadataV2_Checksum_DEFAULT int64
View Source
var BlockMetadataV2_EncodedTags_DEFAULT []byte
View Source
var BlockMetadataV2_LastRead_DEFAULT int64
View Source
var BlockMetadataV2_Size_DEFAULT int64
View Source
var Block_Checksum_DEFAULT int64
View Source
var Datapoint_Annotation_DEFAULT []byte
View Source
var DebugProfileStartRequest_ConditionalIsOverloaded_DEFAULT bool
View Source
var DebugProfileStartRequest_ConditionalNumGoroutinesGreaterThan_DEFAULT int64
View Source
var DebugProfileStartRequest_ConditionalNumGoroutinesLessThan_DEFAULT int64
View Source
var DebugProfileStartRequest_Debug_DEFAULT int64
View Source
var DebugProfileStartRequest_Duration_DEFAULT string
View Source
var DebugProfileStartRequest_Interval_DEFAULT string
View Source
var FetchBlocksMetadataRawV2Request_IncludeChecksums_DEFAULT bool
View Source
var FetchBlocksMetadataRawV2Request_IncludeLastRead_DEFAULT bool
View Source
var FetchBlocksMetadataRawV2Request_IncludeSizes_DEFAULT bool
View Source
var FetchBlocksMetadataRawV2Request_PageToken_DEFAULT []byte
View Source
var FetchBlocksMetadataRawV2Result__NextPageToken_DEFAULT []byte
View Source
var FetchTaggedIDResult__Segments_DEFAULT []*Segments
View Source
var FetchTaggedRequest_DocsLimit_DEFAULT int64
View Source
var FetchTaggedRequest_Limit_DEFAULT int64
View Source
var FetchTaggedRequest_RequireExhaustive_DEFAULT bool = true
View Source
var GoUnusedProtection__ int
View Source
var NodeHealthResult__Metadata_DEFAULT map[string]string
View Source
var NodeSetPersistRateLimitRequest_LimitCheckEvery_DEFAULT int64
View Source
var NodeSetPersistRateLimitRequest_LimitEnabled_DEFAULT bool
View Source
var NodeSetPersistRateLimitRequest_LimitMbps_DEFAULT float64
View Source
var QueryRequest_Limit_DEFAULT int64
View Source
var QueryRequest_NoData_DEFAULT bool
View Source
var Segment_BlockSize_DEFAULT int64
View Source
var Segment_Checksum_DEFAULT int64
View Source
var Segment_StartTime_DEFAULT int64
View Source
var Segments_Unmerged_DEFAULT []*Segment

Functions

func NewTChanClusterInheritedClient

func NewTChanClusterInheritedClient(thriftService string, client thrift.TChanClient) *tchanClusterClient

func NewTChanClusterServer

func NewTChanClusterServer(handler TChanCluster) thrift.TChanServer

NewTChanClusterServer wraps a handler for TChanCluster so it can be registered with a thrift.Server.

func NewTChanNodeInheritedClient

func NewTChanNodeInheritedClient(thriftService string, client thrift.TChanClient) *tchanNodeClient

func NewTChanNodeServer

func NewTChanNodeServer(handler TChanNode) thrift.TChanServer

NewTChanNodeServer wraps a handler for TChanNode so it can be registered with a thrift.Server.

Types

type AggregateQueryRawRequest added in v0.7.3

type AggregateQueryRawRequest struct {
	Query              []byte             `thrift:"query,1,required" db:"query" json:"query"`
	RangeStart         int64              `thrift:"rangeStart,2,required" db:"rangeStart" json:"rangeStart"`
	RangeEnd           int64              `thrift:"rangeEnd,3,required" db:"rangeEnd" json:"rangeEnd"`
	NameSpace          []byte             `thrift:"nameSpace,4,required" db:"nameSpace" json:"nameSpace"`
	Limit              *int64             `thrift:"limit,5" db:"limit" json:"limit,omitempty"`
	TagNameFilter      [][]byte           `thrift:"tagNameFilter,6" db:"tagNameFilter" json:"tagNameFilter,omitempty"`
	AggregateQueryType AggregateQueryType `thrift:"aggregateQueryType,7" db:"aggregateQueryType" json:"aggregateQueryType,omitempty"`
	RangeType          TimeType           `thrift:"rangeType,8" db:"rangeType" json:"rangeType,omitempty"`
}

Attributes:

  • Query
  • RangeStart
  • RangeEnd
  • NameSpace
  • Limit
  • TagNameFilter
  • AggregateQueryType
  • RangeType
var NodeAggregateRawArgs_Req_DEFAULT *AggregateQueryRawRequest

func NewAggregateQueryRawRequest added in v0.7.3

func NewAggregateQueryRawRequest() *AggregateQueryRawRequest

func (*AggregateQueryRawRequest) GetAggregateQueryType added in v0.7.3

func (p *AggregateQueryRawRequest) GetAggregateQueryType() AggregateQueryType

func (*AggregateQueryRawRequest) GetLimit added in v0.7.3

func (p *AggregateQueryRawRequest) GetLimit() int64

func (*AggregateQueryRawRequest) GetNameSpace added in v0.7.3

func (p *AggregateQueryRawRequest) GetNameSpace() []byte

func (*AggregateQueryRawRequest) GetQuery added in v0.7.3

func (p *AggregateQueryRawRequest) GetQuery() []byte

func (*AggregateQueryRawRequest) GetRangeEnd added in v0.7.3

func (p *AggregateQueryRawRequest) GetRangeEnd() int64

func (*AggregateQueryRawRequest) GetRangeStart added in v0.7.3

func (p *AggregateQueryRawRequest) GetRangeStart() int64

func (*AggregateQueryRawRequest) GetRangeType added in v0.7.3

func (p *AggregateQueryRawRequest) GetRangeType() TimeType

func (*AggregateQueryRawRequest) GetTagNameFilter added in v0.7.3

func (p *AggregateQueryRawRequest) GetTagNameFilter() [][]byte

func (*AggregateQueryRawRequest) IsSetAggregateQueryType added in v0.7.3

func (p *AggregateQueryRawRequest) IsSetAggregateQueryType() bool

func (*AggregateQueryRawRequest) IsSetLimit added in v0.7.3

func (p *AggregateQueryRawRequest) IsSetLimit() bool

func (*AggregateQueryRawRequest) IsSetRangeType added in v0.7.3

func (p *AggregateQueryRawRequest) IsSetRangeType() bool

func (*AggregateQueryRawRequest) IsSetTagNameFilter added in v0.7.3

func (p *AggregateQueryRawRequest) IsSetTagNameFilter() bool

func (*AggregateQueryRawRequest) Read added in v0.7.3

func (*AggregateQueryRawRequest) ReadField1 added in v0.7.3

func (p *AggregateQueryRawRequest) ReadField1(iprot thrift.TProtocol) error

func (*AggregateQueryRawRequest) ReadField2 added in v0.7.3

func (p *AggregateQueryRawRequest) ReadField2(iprot thrift.TProtocol) error

func (*AggregateQueryRawRequest) ReadField3 added in v0.7.3

func (p *AggregateQueryRawRequest) ReadField3(iprot thrift.TProtocol) error

func (*AggregateQueryRawRequest) ReadField4 added in v0.7.3

func (p *AggregateQueryRawRequest) ReadField4(iprot thrift.TProtocol) error

func (*AggregateQueryRawRequest) ReadField5 added in v0.7.3

func (p *AggregateQueryRawRequest) ReadField5(iprot thrift.TProtocol) error

func (*AggregateQueryRawRequest) ReadField6 added in v0.7.3

func (p *AggregateQueryRawRequest) ReadField6(iprot thrift.TProtocol) error

func (*AggregateQueryRawRequest) ReadField7 added in v0.7.3

func (p *AggregateQueryRawRequest) ReadField7(iprot thrift.TProtocol) error

func (*AggregateQueryRawRequest) ReadField8 added in v0.7.3

func (p *AggregateQueryRawRequest) ReadField8(iprot thrift.TProtocol) error

func (*AggregateQueryRawRequest) String added in v0.7.3

func (p *AggregateQueryRawRequest) String() string

func (*AggregateQueryRawRequest) Write added in v0.7.3

type AggregateQueryRawResultTagNameElement added in v0.7.3

type AggregateQueryRawResultTagNameElement struct {
	TagName   []byte                                    `thrift:"tagName,1,required" db:"tagName" json:"tagName"`
	TagValues []*AggregateQueryRawResultTagValueElement `thrift:"tagValues,2" db:"tagValues" json:"tagValues,omitempty"`
}

Attributes:

  • TagName
  • TagValues

func NewAggregateQueryRawResultTagNameElement added in v0.7.3

func NewAggregateQueryRawResultTagNameElement() *AggregateQueryRawResultTagNameElement

func (*AggregateQueryRawResultTagNameElement) GetTagName added in v0.7.3

func (p *AggregateQueryRawResultTagNameElement) GetTagName() []byte

func (*AggregateQueryRawResultTagNameElement) GetTagValues added in v0.7.3

func (*AggregateQueryRawResultTagNameElement) IsSetTagValues added in v0.7.3

func (p *AggregateQueryRawResultTagNameElement) IsSetTagValues() bool

func (*AggregateQueryRawResultTagNameElement) Read added in v0.7.3

func (*AggregateQueryRawResultTagNameElement) ReadField1 added in v0.7.3

func (*AggregateQueryRawResultTagNameElement) ReadField2 added in v0.7.3

func (*AggregateQueryRawResultTagNameElement) String added in v0.7.3

func (*AggregateQueryRawResultTagNameElement) Write added in v0.7.3

type AggregateQueryRawResultTagValueElement added in v0.7.3

type AggregateQueryRawResultTagValueElement struct {
	TagValue []byte `thrift:"tagValue,1,required" db:"tagValue" json:"tagValue"`
}

Attributes:

  • TagValue

func NewAggregateQueryRawResultTagValueElement added in v0.7.3

func NewAggregateQueryRawResultTagValueElement() *AggregateQueryRawResultTagValueElement

func (*AggregateQueryRawResultTagValueElement) GetTagValue added in v0.7.3

func (p *AggregateQueryRawResultTagValueElement) GetTagValue() []byte

func (*AggregateQueryRawResultTagValueElement) Read added in v0.7.3

func (*AggregateQueryRawResultTagValueElement) ReadField1 added in v0.7.3

func (*AggregateQueryRawResultTagValueElement) String added in v0.7.3

func (*AggregateQueryRawResultTagValueElement) Write added in v0.7.3

type AggregateQueryRawResult_ added in v0.7.3

type AggregateQueryRawResult_ struct {
	Results    []*AggregateQueryRawResultTagNameElement `thrift:"results,1,required" db:"results" json:"results"`
	Exhaustive bool                                     `thrift:"exhaustive,2,required" db:"exhaustive" json:"exhaustive"`
}

Attributes:

  • Results
  • Exhaustive
var NodeAggregateRawResult_Success_DEFAULT *AggregateQueryRawResult_

func NewAggregateQueryRawResult_ added in v0.7.3

func NewAggregateQueryRawResult_() *AggregateQueryRawResult_

func (*AggregateQueryRawResult_) GetExhaustive added in v0.7.3

func (p *AggregateQueryRawResult_) GetExhaustive() bool

func (*AggregateQueryRawResult_) GetResults added in v0.7.3

func (*AggregateQueryRawResult_) Read added in v0.7.3

func (*AggregateQueryRawResult_) ReadField1 added in v0.7.3

func (p *AggregateQueryRawResult_) ReadField1(iprot thrift.TProtocol) error

func (*AggregateQueryRawResult_) ReadField2 added in v0.7.3

func (p *AggregateQueryRawResult_) ReadField2(iprot thrift.TProtocol) error

func (*AggregateQueryRawResult_) String added in v0.7.3

func (p *AggregateQueryRawResult_) String() string

func (*AggregateQueryRawResult_) Write added in v0.7.3

type AggregateQueryRequest added in v0.7.3

type AggregateQueryRequest struct {
	Query              *Query             `thrift:"query,1" db:"query" json:"query,omitempty"`
	RangeStart         int64              `thrift:"rangeStart,2,required" db:"rangeStart" json:"rangeStart"`
	RangeEnd           int64              `thrift:"rangeEnd,3,required" db:"rangeEnd" json:"rangeEnd"`
	NameSpace          string             `thrift:"nameSpace,4,required" db:"nameSpace" json:"nameSpace"`
	Limit              *int64             `thrift:"limit,5" db:"limit" json:"limit,omitempty"`
	TagNameFilter      []string           `thrift:"tagNameFilter,6" db:"tagNameFilter" json:"tagNameFilter,omitempty"`
	AggregateQueryType AggregateQueryType `thrift:"aggregateQueryType,7" db:"aggregateQueryType" json:"aggregateQueryType,omitempty"`
	RangeType          TimeType           `thrift:"rangeType,8" db:"rangeType" json:"rangeType,omitempty"`
}

Attributes:

  • Query
  • RangeStart
  • RangeEnd
  • NameSpace
  • Limit
  • TagNameFilter
  • AggregateQueryType
  • RangeType
var ClusterAggregateArgs_Req_DEFAULT *AggregateQueryRequest
var NodeAggregateArgs_Req_DEFAULT *AggregateQueryRequest

func NewAggregateQueryRequest added in v0.7.3

func NewAggregateQueryRequest() *AggregateQueryRequest

func (*AggregateQueryRequest) GetAggregateQueryType added in v0.7.3

func (p *AggregateQueryRequest) GetAggregateQueryType() AggregateQueryType

func (*AggregateQueryRequest) GetLimit added in v0.7.3

func (p *AggregateQueryRequest) GetLimit() int64

func (*AggregateQueryRequest) GetNameSpace added in v0.7.3

func (p *AggregateQueryRequest) GetNameSpace() string

func (*AggregateQueryRequest) GetQuery added in v0.7.3

func (p *AggregateQueryRequest) GetQuery() *Query

func (*AggregateQueryRequest) GetRangeEnd added in v0.7.3

func (p *AggregateQueryRequest) GetRangeEnd() int64

func (*AggregateQueryRequest) GetRangeStart added in v0.7.3

func (p *AggregateQueryRequest) GetRangeStart() int64

func (*AggregateQueryRequest) GetRangeType added in v0.7.3

func (p *AggregateQueryRequest) GetRangeType() TimeType

func (*AggregateQueryRequest) GetTagNameFilter added in v0.7.3

func (p *AggregateQueryRequest) GetTagNameFilter() []string

func (*AggregateQueryRequest) IsSetAggregateQueryType added in v0.7.3

func (p *AggregateQueryRequest) IsSetAggregateQueryType() bool

func (*AggregateQueryRequest) IsSetLimit added in v0.7.3

func (p *AggregateQueryRequest) IsSetLimit() bool

func (*AggregateQueryRequest) IsSetQuery added in v0.7.3

func (p *AggregateQueryRequest) IsSetQuery() bool

func (*AggregateQueryRequest) IsSetRangeType added in v0.7.3

func (p *AggregateQueryRequest) IsSetRangeType() bool

func (*AggregateQueryRequest) IsSetTagNameFilter added in v0.7.3

func (p *AggregateQueryRequest) IsSetTagNameFilter() bool

func (*AggregateQueryRequest) Read added in v0.7.3

func (*AggregateQueryRequest) ReadField1 added in v0.7.3

func (p *AggregateQueryRequest) ReadField1(iprot thrift.TProtocol) error

func (*AggregateQueryRequest) ReadField2 added in v0.7.3

func (p *AggregateQueryRequest) ReadField2(iprot thrift.TProtocol) error

func (*AggregateQueryRequest) ReadField3 added in v0.7.3

func (p *AggregateQueryRequest) ReadField3(iprot thrift.TProtocol) error

func (*AggregateQueryRequest) ReadField4 added in v0.7.3

func (p *AggregateQueryRequest) ReadField4(iprot thrift.TProtocol) error

func (*AggregateQueryRequest) ReadField5 added in v0.7.3

func (p *AggregateQueryRequest) ReadField5(iprot thrift.TProtocol) error

func (*AggregateQueryRequest) ReadField6 added in v0.7.3

func (p *AggregateQueryRequest) ReadField6(iprot thrift.TProtocol) error

func (*AggregateQueryRequest) ReadField7 added in v0.7.3

func (p *AggregateQueryRequest) ReadField7(iprot thrift.TProtocol) error

func (*AggregateQueryRequest) ReadField8 added in v0.7.3

func (p *AggregateQueryRequest) ReadField8(iprot thrift.TProtocol) error

func (*AggregateQueryRequest) String added in v0.7.3

func (p *AggregateQueryRequest) String() string

func (*AggregateQueryRequest) Write added in v0.7.3

func (p *AggregateQueryRequest) Write(oprot thrift.TProtocol) error

type AggregateQueryResultTagNameElement added in v0.7.3

type AggregateQueryResultTagNameElement struct {
	TagName   string                                 `thrift:"tagName,1,required" db:"tagName" json:"tagName"`
	TagValues []*AggregateQueryResultTagValueElement `thrift:"tagValues,2" db:"tagValues" json:"tagValues,omitempty"`
}

Attributes:

  • TagName
  • TagValues

func NewAggregateQueryResultTagNameElement added in v0.7.3

func NewAggregateQueryResultTagNameElement() *AggregateQueryResultTagNameElement

func (*AggregateQueryResultTagNameElement) GetTagName added in v0.7.3

func (*AggregateQueryResultTagNameElement) GetTagValues added in v0.7.3

func (*AggregateQueryResultTagNameElement) IsSetTagValues added in v0.7.3

func (p *AggregateQueryResultTagNameElement) IsSetTagValues() bool

func (*AggregateQueryResultTagNameElement) Read added in v0.7.3

func (*AggregateQueryResultTagNameElement) ReadField1 added in v0.7.3

func (*AggregateQueryResultTagNameElement) ReadField2 added in v0.7.3

func (*AggregateQueryResultTagNameElement) String added in v0.7.3

func (*AggregateQueryResultTagNameElement) Write added in v0.7.3

type AggregateQueryResultTagValueElement added in v0.7.3

type AggregateQueryResultTagValueElement struct {
	TagValue string `thrift:"tagValue,1,required" db:"tagValue" json:"tagValue"`
}

Attributes:

  • TagValue

func NewAggregateQueryResultTagValueElement added in v0.7.3

func NewAggregateQueryResultTagValueElement() *AggregateQueryResultTagValueElement

func (*AggregateQueryResultTagValueElement) GetTagValue added in v0.7.3

func (*AggregateQueryResultTagValueElement) Read added in v0.7.3

func (*AggregateQueryResultTagValueElement) ReadField1 added in v0.7.3

func (*AggregateQueryResultTagValueElement) String added in v0.7.3

func (*AggregateQueryResultTagValueElement) Write added in v0.7.3

type AggregateQueryResult_ added in v0.7.3

type AggregateQueryResult_ struct {
	Results    []*AggregateQueryResultTagNameElement `thrift:"results,1,required" db:"results" json:"results"`
	Exhaustive bool                                  `thrift:"exhaustive,2,required" db:"exhaustive" json:"exhaustive"`
}

Attributes:

  • Results
  • Exhaustive
var ClusterAggregateResult_Success_DEFAULT *AggregateQueryResult_
var NodeAggregateResult_Success_DEFAULT *AggregateQueryResult_

func NewAggregateQueryResult_ added in v0.7.3

func NewAggregateQueryResult_() *AggregateQueryResult_

func (*AggregateQueryResult_) GetExhaustive added in v0.7.3

func (p *AggregateQueryResult_) GetExhaustive() bool

func (*AggregateQueryResult_) GetResults added in v0.7.3

func (*AggregateQueryResult_) Read added in v0.7.3

func (*AggregateQueryResult_) ReadField1 added in v0.7.3

func (p *AggregateQueryResult_) ReadField1(iprot thrift.TProtocol) error

func (*AggregateQueryResult_) ReadField2 added in v0.7.3

func (p *AggregateQueryResult_) ReadField2(iprot thrift.TProtocol) error

func (*AggregateQueryResult_) String added in v0.7.3

func (p *AggregateQueryResult_) String() string

func (*AggregateQueryResult_) Write added in v0.7.3

func (p *AggregateQueryResult_) Write(oprot thrift.TProtocol) error

type AggregateQueryType added in v0.7.3

type AggregateQueryType int64
const (
	AggregateQueryType_AGGREGATE_BY_TAG_NAME       AggregateQueryType = 0
	AggregateQueryType_AGGREGATE_BY_TAG_NAME_VALUE AggregateQueryType = 1
)
var AggregateQueryRawRequest_AggregateQueryType_DEFAULT AggregateQueryType = 1
var AggregateQueryRequest_AggregateQueryType_DEFAULT AggregateQueryType = 1

func AggregateQueryTypeFromString added in v0.7.3

func AggregateQueryTypeFromString(s string) (AggregateQueryType, error)

func AggregateQueryTypePtr added in v0.7.3

func AggregateQueryTypePtr(v AggregateQueryType) *AggregateQueryType

func (AggregateQueryType) MarshalText added in v0.7.3

func (p AggregateQueryType) MarshalText() ([]byte, error)

func (*AggregateQueryType) Scan added in v0.7.3

func (p *AggregateQueryType) Scan(value interface{}) error

func (AggregateQueryType) String added in v0.7.3

func (p AggregateQueryType) String() string

func (*AggregateQueryType) UnmarshalText added in v0.7.3

func (p *AggregateQueryType) UnmarshalText(text []byte) error

func (*AggregateQueryType) Value added in v0.7.3

func (p *AggregateQueryType) Value() (driver.Value, error)

type AggregateTilesRequest added in v0.15.14

type AggregateTilesRequest struct {
	SourceNamespace string   `thrift:"sourceNamespace,1,required" db:"sourceNamespace" json:"sourceNamespace"`
	TargetNamespace string   `thrift:"targetNamespace,2,required" db:"targetNamespace" json:"targetNamespace"`
	RangeStart      int64    `thrift:"rangeStart,3,required" db:"rangeStart" json:"rangeStart"`
	RangeEnd        int64    `thrift:"rangeEnd,4,required" db:"rangeEnd" json:"rangeEnd"`
	Step            string   `thrift:"step,5,required" db:"step" json:"step"`
	RangeType       TimeType `thrift:"rangeType,6" db:"rangeType" json:"rangeType,omitempty"`
}

Attributes:

  • SourceNamespace
  • TargetNamespace
  • RangeStart
  • RangeEnd
  • Step
  • RangeType
var NodeAggregateTilesArgs_Req_DEFAULT *AggregateTilesRequest

func NewAggregateTilesRequest added in v0.15.14

func NewAggregateTilesRequest() *AggregateTilesRequest

func (*AggregateTilesRequest) GetRangeEnd added in v0.15.14

func (p *AggregateTilesRequest) GetRangeEnd() int64

func (*AggregateTilesRequest) GetRangeStart added in v0.15.14

func (p *AggregateTilesRequest) GetRangeStart() int64

func (*AggregateTilesRequest) GetRangeType added in v0.15.14

func (p *AggregateTilesRequest) GetRangeType() TimeType

func (*AggregateTilesRequest) GetSourceNamespace added in v0.15.14

func (p *AggregateTilesRequest) GetSourceNamespace() string

func (*AggregateTilesRequest) GetStep added in v0.15.14

func (p *AggregateTilesRequest) GetStep() string

func (*AggregateTilesRequest) GetTargetNamespace added in v0.15.14

func (p *AggregateTilesRequest) GetTargetNamespace() string

func (*AggregateTilesRequest) IsSetRangeType added in v0.15.14

func (p *AggregateTilesRequest) IsSetRangeType() bool

func (*AggregateTilesRequest) Read added in v0.15.14

func (*AggregateTilesRequest) ReadField1 added in v0.15.14

func (p *AggregateTilesRequest) ReadField1(iprot thrift.TProtocol) error

func (*AggregateTilesRequest) ReadField2 added in v0.15.14

func (p *AggregateTilesRequest) ReadField2(iprot thrift.TProtocol) error

func (*AggregateTilesRequest) ReadField3 added in v0.15.14

func (p *AggregateTilesRequest) ReadField3(iprot thrift.TProtocol) error

func (*AggregateTilesRequest) ReadField4 added in v0.15.14

func (p *AggregateTilesRequest) ReadField4(iprot thrift.TProtocol) error

func (*AggregateTilesRequest) ReadField5 added in v0.15.14

func (p *AggregateTilesRequest) ReadField5(iprot thrift.TProtocol) error

func (*AggregateTilesRequest) ReadField6 added in v0.15.14

func (p *AggregateTilesRequest) ReadField6(iprot thrift.TProtocol) error

func (*AggregateTilesRequest) String added in v0.15.14

func (p *AggregateTilesRequest) String() string

func (*AggregateTilesRequest) Write added in v0.15.14

func (p *AggregateTilesRequest) Write(oprot thrift.TProtocol) error

type AggregateTilesResult_ added in v0.15.14

type AggregateTilesResult_ struct {
	ProcessedTileCount int64 `thrift:"processedTileCount,1,required" db:"processedTileCount" json:"processedTileCount"`
}

Attributes:

  • ProcessedTileCount
var NodeAggregateTilesResult_Success_DEFAULT *AggregateTilesResult_

func NewAggregateTilesResult_ added in v0.15.14

func NewAggregateTilesResult_() *AggregateTilesResult_

func (*AggregateTilesResult_) GetProcessedTileCount added in v0.15.16

func (p *AggregateTilesResult_) GetProcessedTileCount() int64

func (*AggregateTilesResult_) Read added in v0.15.14

func (*AggregateTilesResult_) ReadField1 added in v0.15.14

func (p *AggregateTilesResult_) ReadField1(iprot thrift.TProtocol) error

func (*AggregateTilesResult_) String added in v0.15.14

func (p *AggregateTilesResult_) String() string

func (*AggregateTilesResult_) Write added in v0.15.14

func (p *AggregateTilesResult_) Write(oprot thrift.TProtocol) error

type AllQuery added in v0.8.0

type AllQuery struct {
}
var Query_All_DEFAULT *AllQuery

func NewAllQuery added in v0.8.0

func NewAllQuery() *AllQuery

func (*AllQuery) Read added in v0.8.0

func (p *AllQuery) Read(iprot thrift.TProtocol) error

func (*AllQuery) String added in v0.8.0

func (p *AllQuery) String() string

func (*AllQuery) Write added in v0.8.0

func (p *AllQuery) Write(oprot thrift.TProtocol) error

type Block

type Block struct {
	Start    int64     `thrift:"start,1,required" db:"start" json:"start"`
	Segments *Segments `thrift:"segments,2" db:"segments" json:"segments,omitempty"`
	Err      *Error    `thrift:"err,3" db:"err" json:"err,omitempty"`
	Checksum *int64    `thrift:"checksum,4" db:"checksum" json:"checksum,omitempty"`
}

Attributes:

  • Start
  • Segments
  • Err
  • Checksum

func NewBlock

func NewBlock() *Block

func (*Block) GetChecksum

func (p *Block) GetChecksum() int64

func (*Block) GetErr

func (p *Block) GetErr() *Error

func (*Block) GetSegments

func (p *Block) GetSegments() *Segments

func (*Block) GetStart

func (p *Block) GetStart() int64

func (*Block) IsSetChecksum

func (p *Block) IsSetChecksum() bool

func (*Block) IsSetErr

func (p *Block) IsSetErr() bool

func (*Block) IsSetSegments

func (p *Block) IsSetSegments() bool

func (*Block) Read

func (p *Block) Read(iprot thrift.TProtocol) error

func (*Block) ReadField1

func (p *Block) ReadField1(iprot thrift.TProtocol) error

func (*Block) ReadField2

func (p *Block) ReadField2(iprot thrift.TProtocol) error

func (*Block) ReadField3

func (p *Block) ReadField3(iprot thrift.TProtocol) error

func (*Block) ReadField4

func (p *Block) ReadField4(iprot thrift.TProtocol) error

func (*Block) String

func (p *Block) String() string

func (*Block) Write

func (p *Block) Write(oprot thrift.TProtocol) error

type BlockMetadataV2

type BlockMetadataV2 struct {
	ID               []byte   `thrift:"id,1,required" db:"id" json:"id"`
	Start            int64    `thrift:"start,2,required" db:"start" json:"start"`
	Err              *Error   `thrift:"err,3" db:"err" json:"err,omitempty"`
	Size             *int64   `thrift:"size,4" db:"size" json:"size,omitempty"`
	Checksum         *int64   `thrift:"checksum,5" db:"checksum" json:"checksum,omitempty"`
	LastRead         *int64   `thrift:"lastRead,6" db:"lastRead" json:"lastRead,omitempty"`
	LastReadTimeType TimeType `thrift:"lastReadTimeType,7" db:"lastReadTimeType" json:"lastReadTimeType,omitempty"`
	EncodedTags      []byte   `thrift:"encodedTags,8" db:"encodedTags" json:"encodedTags,omitempty"`
}

Attributes:

  • ID
  • Start
  • Err
  • Size
  • Checksum
  • LastRead
  • LastReadTimeType
  • EncodedTags

func NewBlockMetadataV2

func NewBlockMetadataV2() *BlockMetadataV2

func (*BlockMetadataV2) GetChecksum

func (p *BlockMetadataV2) GetChecksum() int64

func (*BlockMetadataV2) GetEncodedTags

func (p *BlockMetadataV2) GetEncodedTags() []byte

func (*BlockMetadataV2) GetErr

func (p *BlockMetadataV2) GetErr() *Error

func (*BlockMetadataV2) GetID

func (p *BlockMetadataV2) GetID() []byte

func (*BlockMetadataV2) GetLastRead

func (p *BlockMetadataV2) GetLastRead() int64

func (*BlockMetadataV2) GetLastReadTimeType

func (p *BlockMetadataV2) GetLastReadTimeType() TimeType

func (*BlockMetadataV2) GetSize

func (p *BlockMetadataV2) GetSize() int64

func (*BlockMetadataV2) GetStart

func (p *BlockMetadataV2) GetStart() int64

func (*BlockMetadataV2) IsSetChecksum

func (p *BlockMetadataV2) IsSetChecksum() bool

func (*BlockMetadataV2) IsSetEncodedTags

func (p *BlockMetadataV2) IsSetEncodedTags() bool

func (*BlockMetadataV2) IsSetErr

func (p *BlockMetadataV2) IsSetErr() bool

func (*BlockMetadataV2) IsSetLastRead

func (p *BlockMetadataV2) IsSetLastRead() bool

func (*BlockMetadataV2) IsSetLastReadTimeType

func (p *BlockMetadataV2) IsSetLastReadTimeType() bool

func (*BlockMetadataV2) IsSetSize

func (p *BlockMetadataV2) IsSetSize() bool

func (*BlockMetadataV2) Read

func (p *BlockMetadataV2) Read(iprot thrift.TProtocol) error

func (*BlockMetadataV2) ReadField1

func (p *BlockMetadataV2) ReadField1(iprot thrift.TProtocol) error

func (*BlockMetadataV2) ReadField2

func (p *BlockMetadataV2) ReadField2(iprot thrift.TProtocol) error

func (*BlockMetadataV2) ReadField3

func (p *BlockMetadataV2) ReadField3(iprot thrift.TProtocol) error

func (*BlockMetadataV2) ReadField4

func (p *BlockMetadataV2) ReadField4(iprot thrift.TProtocol) error

func (*BlockMetadataV2) ReadField5

func (p *BlockMetadataV2) ReadField5(iprot thrift.TProtocol) error

func (*BlockMetadataV2) ReadField6

func (p *BlockMetadataV2) ReadField6(iprot thrift.TProtocol) error

func (*BlockMetadataV2) ReadField7

func (p *BlockMetadataV2) ReadField7(iprot thrift.TProtocol) error

func (*BlockMetadataV2) ReadField8

func (p *BlockMetadataV2) ReadField8(iprot thrift.TProtocol) error

func (*BlockMetadataV2) String

func (p *BlockMetadataV2) String() string

func (*BlockMetadataV2) Write

func (p *BlockMetadataV2) Write(oprot thrift.TProtocol) error

type Blocks

type Blocks struct {
	ID     []byte   `thrift:"id,1,required" db:"id" json:"id"`
	Blocks []*Block `thrift:"blocks,2,required" db:"blocks" json:"blocks"`
}

Attributes:

  • ID
  • Blocks

func NewBlocks

func NewBlocks() *Blocks

func (*Blocks) GetBlocks

func (p *Blocks) GetBlocks() []*Block

func (*Blocks) GetID

func (p *Blocks) GetID() []byte

func (*Blocks) Read

func (p *Blocks) Read(iprot thrift.TProtocol) error

func (*Blocks) ReadField1

func (p *Blocks) ReadField1(iprot thrift.TProtocol) error

func (*Blocks) ReadField2

func (p *Blocks) ReadField2(iprot thrift.TProtocol) error

func (*Blocks) String

func (p *Blocks) String() string

func (*Blocks) Write

func (p *Blocks) Write(oprot thrift.TProtocol) error

type Cluster

type Cluster interface {
	Health() (r *HealthResult_, err error)
	// Parameters:
	//  - Req
	Write(req *WriteRequest) (err error)
	// Parameters:
	//  - Req
	WriteTagged(req *WriteTaggedRequest) (err error)
	// Parameters:
	//  - Req
	Query(req *QueryRequest) (r *QueryResult_, err error)
	// Parameters:
	//  - Req
	Aggregate(req *AggregateQueryRequest) (r *AggregateQueryResult_, err error)
	// Parameters:
	//  - Req
	Fetch(req *FetchRequest) (r *FetchResult_, err error)
	// Parameters:
	//  - Req
	Truncate(req *TruncateRequest) (r *TruncateResult_, err error)
}

type ClusterAggregateArgs added in v0.7.3

type ClusterAggregateArgs struct {
	Req *AggregateQueryRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewClusterAggregateArgs added in v0.7.3

func NewClusterAggregateArgs() *ClusterAggregateArgs

func (*ClusterAggregateArgs) GetReq added in v0.7.3

func (*ClusterAggregateArgs) IsSetReq added in v0.7.3

func (p *ClusterAggregateArgs) IsSetReq() bool

func (*ClusterAggregateArgs) Read added in v0.7.3

func (p *ClusterAggregateArgs) Read(iprot thrift.TProtocol) error

func (*ClusterAggregateArgs) ReadField1 added in v0.7.3

func (p *ClusterAggregateArgs) ReadField1(iprot thrift.TProtocol) error

func (*ClusterAggregateArgs) String added in v0.7.3

func (p *ClusterAggregateArgs) String() string

func (*ClusterAggregateArgs) Write added in v0.7.3

func (p *ClusterAggregateArgs) Write(oprot thrift.TProtocol) error

type ClusterAggregateResult added in v0.7.3

type ClusterAggregateResult struct {
	Success *AggregateQueryResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                 `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewClusterAggregateResult added in v0.7.3

func NewClusterAggregateResult() *ClusterAggregateResult

func (*ClusterAggregateResult) GetErr added in v0.7.3

func (p *ClusterAggregateResult) GetErr() *Error

func (*ClusterAggregateResult) GetSuccess added in v0.7.3

func (*ClusterAggregateResult) IsSetErr added in v0.7.3

func (p *ClusterAggregateResult) IsSetErr() bool

func (*ClusterAggregateResult) IsSetSuccess added in v0.7.3

func (p *ClusterAggregateResult) IsSetSuccess() bool

func (*ClusterAggregateResult) Read added in v0.7.3

func (*ClusterAggregateResult) ReadField0 added in v0.7.3

func (p *ClusterAggregateResult) ReadField0(iprot thrift.TProtocol) error

func (*ClusterAggregateResult) ReadField1 added in v0.7.3

func (p *ClusterAggregateResult) ReadField1(iprot thrift.TProtocol) error

func (*ClusterAggregateResult) String added in v0.7.3

func (p *ClusterAggregateResult) String() string

func (*ClusterAggregateResult) Write added in v0.7.3

func (p *ClusterAggregateResult) Write(oprot thrift.TProtocol) error

type ClusterClient

type ClusterClient struct {
	Transport       thrift.TTransport
	ProtocolFactory thrift.TProtocolFactory
	InputProtocol   thrift.TProtocol
	OutputProtocol  thrift.TProtocol
	SeqId           int32
}

func NewClusterClientProtocol

func NewClusterClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *ClusterClient

func (*ClusterClient) Aggregate added in v0.7.3

func (p *ClusterClient) Aggregate(req *AggregateQueryRequest) (r *AggregateQueryResult_, err error)

Parameters:

  • Req

func (*ClusterClient) Fetch

func (p *ClusterClient) Fetch(req *FetchRequest) (r *FetchResult_, err error)

Parameters:

  • Req

func (*ClusterClient) Health

func (p *ClusterClient) Health() (r *HealthResult_, err error)

func (*ClusterClient) Query

func (p *ClusterClient) Query(req *QueryRequest) (r *QueryResult_, err error)

Parameters:

  • Req

func (*ClusterClient) Truncate

func (p *ClusterClient) Truncate(req *TruncateRequest) (r *TruncateResult_, err error)

Parameters:

  • Req

func (*ClusterClient) Write

func (p *ClusterClient) Write(req *WriteRequest) (err error)

Parameters:

  • Req

func (*ClusterClient) WriteTagged

func (p *ClusterClient) WriteTagged(req *WriteTaggedRequest) (err error)

Parameters:

  • Req

type ClusterFetchArgs

type ClusterFetchArgs struct {
	Req *FetchRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewClusterFetchArgs

func NewClusterFetchArgs() *ClusterFetchArgs

func (*ClusterFetchArgs) GetReq

func (p *ClusterFetchArgs) GetReq() *FetchRequest

func (*ClusterFetchArgs) IsSetReq

func (p *ClusterFetchArgs) IsSetReq() bool

func (*ClusterFetchArgs) Read

func (p *ClusterFetchArgs) Read(iprot thrift.TProtocol) error

func (*ClusterFetchArgs) ReadField1

func (p *ClusterFetchArgs) ReadField1(iprot thrift.TProtocol) error

func (*ClusterFetchArgs) String

func (p *ClusterFetchArgs) String() string

func (*ClusterFetchArgs) Write

func (p *ClusterFetchArgs) Write(oprot thrift.TProtocol) error

type ClusterFetchResult

type ClusterFetchResult struct {
	Success *FetchResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error        `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewClusterFetchResult

func NewClusterFetchResult() *ClusterFetchResult

func (*ClusterFetchResult) GetErr

func (p *ClusterFetchResult) GetErr() *Error

func (*ClusterFetchResult) GetSuccess

func (p *ClusterFetchResult) GetSuccess() *FetchResult_

func (*ClusterFetchResult) IsSetErr

func (p *ClusterFetchResult) IsSetErr() bool

func (*ClusterFetchResult) IsSetSuccess

func (p *ClusterFetchResult) IsSetSuccess() bool

func (*ClusterFetchResult) Read

func (p *ClusterFetchResult) Read(iprot thrift.TProtocol) error

func (*ClusterFetchResult) ReadField0

func (p *ClusterFetchResult) ReadField0(iprot thrift.TProtocol) error

func (*ClusterFetchResult) ReadField1

func (p *ClusterFetchResult) ReadField1(iprot thrift.TProtocol) error

func (*ClusterFetchResult) String

func (p *ClusterFetchResult) String() string

func (*ClusterFetchResult) Write

func (p *ClusterFetchResult) Write(oprot thrift.TProtocol) error

type ClusterHealthArgs

type ClusterHealthArgs struct {
}

func NewClusterHealthArgs

func NewClusterHealthArgs() *ClusterHealthArgs

func (*ClusterHealthArgs) Read

func (p *ClusterHealthArgs) Read(iprot thrift.TProtocol) error

func (*ClusterHealthArgs) String

func (p *ClusterHealthArgs) String() string

func (*ClusterHealthArgs) Write

func (p *ClusterHealthArgs) Write(oprot thrift.TProtocol) error

type ClusterHealthResult

type ClusterHealthResult struct {
	Success *HealthResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error         `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewClusterHealthResult

func NewClusterHealthResult() *ClusterHealthResult

func (*ClusterHealthResult) GetErr

func (p *ClusterHealthResult) GetErr() *Error

func (*ClusterHealthResult) GetSuccess

func (p *ClusterHealthResult) GetSuccess() *HealthResult_

func (*ClusterHealthResult) IsSetErr

func (p *ClusterHealthResult) IsSetErr() bool

func (*ClusterHealthResult) IsSetSuccess

func (p *ClusterHealthResult) IsSetSuccess() bool

func (*ClusterHealthResult) Read

func (p *ClusterHealthResult) Read(iprot thrift.TProtocol) error

func (*ClusterHealthResult) ReadField0

func (p *ClusterHealthResult) ReadField0(iprot thrift.TProtocol) error

func (*ClusterHealthResult) ReadField1

func (p *ClusterHealthResult) ReadField1(iprot thrift.TProtocol) error

func (*ClusterHealthResult) String

func (p *ClusterHealthResult) String() string

func (*ClusterHealthResult) Write

func (p *ClusterHealthResult) Write(oprot thrift.TProtocol) error

type ClusterProcessor

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

func NewClusterProcessor

func NewClusterProcessor(handler Cluster) *ClusterProcessor

func (*ClusterProcessor) AddToProcessorMap

func (p *ClusterProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*ClusterProcessor) GetProcessorFunction

func (p *ClusterProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*ClusterProcessor) Process

func (p *ClusterProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*ClusterProcessor) ProcessorMap

func (p *ClusterProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type ClusterQueryArgs

type ClusterQueryArgs struct {
	Req *QueryRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewClusterQueryArgs

func NewClusterQueryArgs() *ClusterQueryArgs

func (*ClusterQueryArgs) GetReq

func (p *ClusterQueryArgs) GetReq() *QueryRequest

func (*ClusterQueryArgs) IsSetReq

func (p *ClusterQueryArgs) IsSetReq() bool

func (*ClusterQueryArgs) Read

func (p *ClusterQueryArgs) Read(iprot thrift.TProtocol) error

func (*ClusterQueryArgs) ReadField1

func (p *ClusterQueryArgs) ReadField1(iprot thrift.TProtocol) error

func (*ClusterQueryArgs) String

func (p *ClusterQueryArgs) String() string

func (*ClusterQueryArgs) Write

func (p *ClusterQueryArgs) Write(oprot thrift.TProtocol) error

type ClusterQueryResult

type ClusterQueryResult struct {
	Success *QueryResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error        `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewClusterQueryResult

func NewClusterQueryResult() *ClusterQueryResult

func (*ClusterQueryResult) GetErr

func (p *ClusterQueryResult) GetErr() *Error

func (*ClusterQueryResult) GetSuccess

func (p *ClusterQueryResult) GetSuccess() *QueryResult_

func (*ClusterQueryResult) IsSetErr

func (p *ClusterQueryResult) IsSetErr() bool

func (*ClusterQueryResult) IsSetSuccess

func (p *ClusterQueryResult) IsSetSuccess() bool

func (*ClusterQueryResult) Read

func (p *ClusterQueryResult) Read(iprot thrift.TProtocol) error

func (*ClusterQueryResult) ReadField0

func (p *ClusterQueryResult) ReadField0(iprot thrift.TProtocol) error

func (*ClusterQueryResult) ReadField1

func (p *ClusterQueryResult) ReadField1(iprot thrift.TProtocol) error

func (*ClusterQueryResult) String

func (p *ClusterQueryResult) String() string

func (*ClusterQueryResult) Write

func (p *ClusterQueryResult) Write(oprot thrift.TProtocol) error

type ClusterTruncateArgs

type ClusterTruncateArgs struct {
	Req *TruncateRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewClusterTruncateArgs

func NewClusterTruncateArgs() *ClusterTruncateArgs

func (*ClusterTruncateArgs) GetReq

func (p *ClusterTruncateArgs) GetReq() *TruncateRequest

func (*ClusterTruncateArgs) IsSetReq

func (p *ClusterTruncateArgs) IsSetReq() bool

func (*ClusterTruncateArgs) Read

func (p *ClusterTruncateArgs) Read(iprot thrift.TProtocol) error

func (*ClusterTruncateArgs) ReadField1

func (p *ClusterTruncateArgs) ReadField1(iprot thrift.TProtocol) error

func (*ClusterTruncateArgs) String

func (p *ClusterTruncateArgs) String() string

func (*ClusterTruncateArgs) Write

func (p *ClusterTruncateArgs) Write(oprot thrift.TProtocol) error

type ClusterTruncateResult

type ClusterTruncateResult struct {
	Success *TruncateResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error           `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewClusterTruncateResult

func NewClusterTruncateResult() *ClusterTruncateResult

func (*ClusterTruncateResult) GetErr

func (p *ClusterTruncateResult) GetErr() *Error

func (*ClusterTruncateResult) GetSuccess

func (p *ClusterTruncateResult) GetSuccess() *TruncateResult_

func (*ClusterTruncateResult) IsSetErr

func (p *ClusterTruncateResult) IsSetErr() bool

func (*ClusterTruncateResult) IsSetSuccess

func (p *ClusterTruncateResult) IsSetSuccess() bool

func (*ClusterTruncateResult) Read

func (*ClusterTruncateResult) ReadField0

func (p *ClusterTruncateResult) ReadField0(iprot thrift.TProtocol) error

func (*ClusterTruncateResult) ReadField1

func (p *ClusterTruncateResult) ReadField1(iprot thrift.TProtocol) error

func (*ClusterTruncateResult) String

func (p *ClusterTruncateResult) String() string

func (*ClusterTruncateResult) Write

func (p *ClusterTruncateResult) Write(oprot thrift.TProtocol) error

type ClusterWriteArgs

type ClusterWriteArgs struct {
	Req *WriteRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewClusterWriteArgs

func NewClusterWriteArgs() *ClusterWriteArgs

func (*ClusterWriteArgs) GetReq

func (p *ClusterWriteArgs) GetReq() *WriteRequest

func (*ClusterWriteArgs) IsSetReq

func (p *ClusterWriteArgs) IsSetReq() bool

func (*ClusterWriteArgs) Read

func (p *ClusterWriteArgs) Read(iprot thrift.TProtocol) error

func (*ClusterWriteArgs) ReadField1

func (p *ClusterWriteArgs) ReadField1(iprot thrift.TProtocol) error

func (*ClusterWriteArgs) String

func (p *ClusterWriteArgs) String() string

func (*ClusterWriteArgs) Write

func (p *ClusterWriteArgs) Write(oprot thrift.TProtocol) error

type ClusterWriteResult

type ClusterWriteResult struct {
	Err *Error `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Err

func NewClusterWriteResult

func NewClusterWriteResult() *ClusterWriteResult

func (*ClusterWriteResult) GetErr

func (p *ClusterWriteResult) GetErr() *Error

func (*ClusterWriteResult) IsSetErr

func (p *ClusterWriteResult) IsSetErr() bool

func (*ClusterWriteResult) Read

func (p *ClusterWriteResult) Read(iprot thrift.TProtocol) error

func (*ClusterWriteResult) ReadField1

func (p *ClusterWriteResult) ReadField1(iprot thrift.TProtocol) error

func (*ClusterWriteResult) String

func (p *ClusterWriteResult) String() string

func (*ClusterWriteResult) Write

func (p *ClusterWriteResult) Write(oprot thrift.TProtocol) error

type ClusterWriteTaggedArgs

type ClusterWriteTaggedArgs struct {
	Req *WriteTaggedRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewClusterWriteTaggedArgs

func NewClusterWriteTaggedArgs() *ClusterWriteTaggedArgs

func (*ClusterWriteTaggedArgs) GetReq

func (*ClusterWriteTaggedArgs) IsSetReq

func (p *ClusterWriteTaggedArgs) IsSetReq() bool

func (*ClusterWriteTaggedArgs) Read

func (*ClusterWriteTaggedArgs) ReadField1

func (p *ClusterWriteTaggedArgs) ReadField1(iprot thrift.TProtocol) error

func (*ClusterWriteTaggedArgs) String

func (p *ClusterWriteTaggedArgs) String() string

func (*ClusterWriteTaggedArgs) Write

func (p *ClusterWriteTaggedArgs) Write(oprot thrift.TProtocol) error

type ClusterWriteTaggedResult

type ClusterWriteTaggedResult struct {
	Err *Error `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Err

func NewClusterWriteTaggedResult

func NewClusterWriteTaggedResult() *ClusterWriteTaggedResult

func (*ClusterWriteTaggedResult) GetErr

func (p *ClusterWriteTaggedResult) GetErr() *Error

func (*ClusterWriteTaggedResult) IsSetErr

func (p *ClusterWriteTaggedResult) IsSetErr() bool

func (*ClusterWriteTaggedResult) Read

func (*ClusterWriteTaggedResult) ReadField1

func (p *ClusterWriteTaggedResult) ReadField1(iprot thrift.TProtocol) error

func (*ClusterWriteTaggedResult) String

func (p *ClusterWriteTaggedResult) String() string

func (*ClusterWriteTaggedResult) Write

type ConjunctionQuery

type ConjunctionQuery struct {
	Queries []*Query `thrift:"queries,1,required" db:"queries" json:"queries"`
}

Attributes:

  • Queries
var Query_Conjunction_DEFAULT *ConjunctionQuery

func NewConjunctionQuery

func NewConjunctionQuery() *ConjunctionQuery

func (*ConjunctionQuery) GetQueries

func (p *ConjunctionQuery) GetQueries() []*Query

func (*ConjunctionQuery) Read

func (p *ConjunctionQuery) Read(iprot thrift.TProtocol) error

func (*ConjunctionQuery) ReadField1

func (p *ConjunctionQuery) ReadField1(iprot thrift.TProtocol) error

func (*ConjunctionQuery) String

func (p *ConjunctionQuery) String() string

func (*ConjunctionQuery) Write

func (p *ConjunctionQuery) Write(oprot thrift.TProtocol) error

type Datapoint

type Datapoint struct {
	Timestamp         int64    `thrift:"timestamp,1,required" db:"timestamp" json:"timestamp"`
	Value             float64  `thrift:"value,2,required" db:"value" json:"value"`
	Annotation        []byte   `thrift:"annotation,3" db:"annotation" json:"annotation,omitempty"`
	TimestampTimeType TimeType `thrift:"timestampTimeType,4" db:"timestampTimeType" json:"timestampTimeType,omitempty"`
}

Attributes:

  • Timestamp
  • Value
  • Annotation
  • TimestampTimeType
var WriteBatchRawRequestElement_Datapoint_DEFAULT *Datapoint
var WriteBatchRawV2RequestElement_Datapoint_DEFAULT *Datapoint
var WriteRequest_Datapoint_DEFAULT *Datapoint
var WriteTaggedBatchRawRequestElement_Datapoint_DEFAULT *Datapoint
var WriteTaggedBatchRawV2RequestElement_Datapoint_DEFAULT *Datapoint
var WriteTaggedRequest_Datapoint_DEFAULT *Datapoint

func NewDatapoint

func NewDatapoint() *Datapoint

func (*Datapoint) GetAnnotation

func (p *Datapoint) GetAnnotation() []byte

func (*Datapoint) GetTimestamp

func (p *Datapoint) GetTimestamp() int64

func (*Datapoint) GetTimestampTimeType

func (p *Datapoint) GetTimestampTimeType() TimeType

func (*Datapoint) GetValue

func (p *Datapoint) GetValue() float64

func (*Datapoint) IsSetAnnotation

func (p *Datapoint) IsSetAnnotation() bool

func (*Datapoint) IsSetTimestampTimeType

func (p *Datapoint) IsSetTimestampTimeType() bool

func (*Datapoint) Read

func (p *Datapoint) Read(iprot thrift.TProtocol) error

func (*Datapoint) ReadField1

func (p *Datapoint) ReadField1(iprot thrift.TProtocol) error

func (*Datapoint) ReadField2

func (p *Datapoint) ReadField2(iprot thrift.TProtocol) error

func (*Datapoint) ReadField3

func (p *Datapoint) ReadField3(iprot thrift.TProtocol) error

func (*Datapoint) ReadField4

func (p *Datapoint) ReadField4(iprot thrift.TProtocol) error

func (*Datapoint) String

func (p *Datapoint) String() string

func (*Datapoint) Write

func (p *Datapoint) Write(oprot thrift.TProtocol) error

type DebugIndexMemorySegmentsRequest added in v0.15.0

type DebugIndexMemorySegmentsRequest struct {
	Directory string `thrift:"directory,1,required" db:"directory" json:"directory"`
}

Attributes:

  • Directory
var NodeDebugIndexMemorySegmentsArgs_Req_DEFAULT *DebugIndexMemorySegmentsRequest

func NewDebugIndexMemorySegmentsRequest added in v0.15.0

func NewDebugIndexMemorySegmentsRequest() *DebugIndexMemorySegmentsRequest

func (*DebugIndexMemorySegmentsRequest) GetDirectory added in v0.15.0

func (p *DebugIndexMemorySegmentsRequest) GetDirectory() string

func (*DebugIndexMemorySegmentsRequest) Read added in v0.15.0

func (*DebugIndexMemorySegmentsRequest) ReadField1 added in v0.15.0

func (*DebugIndexMemorySegmentsRequest) String added in v0.15.0

func (*DebugIndexMemorySegmentsRequest) Write added in v0.15.0

type DebugIndexMemorySegmentsResult_ added in v0.15.0

type DebugIndexMemorySegmentsResult_ struct {
}
var NodeDebugIndexMemorySegmentsResult_Success_DEFAULT *DebugIndexMemorySegmentsResult_

func NewDebugIndexMemorySegmentsResult_ added in v0.15.0

func NewDebugIndexMemorySegmentsResult_() *DebugIndexMemorySegmentsResult_

func (*DebugIndexMemorySegmentsResult_) Read added in v0.15.0

func (*DebugIndexMemorySegmentsResult_) String added in v0.15.0

func (*DebugIndexMemorySegmentsResult_) Write added in v0.15.0

type DebugProfileStartRequest added in v0.15.5

type DebugProfileStartRequest struct {
	Name                                string  `thrift:"name,1,required" db:"name" json:"name"`
	FilePathTemplate                    string  `thrift:"filePathTemplate,2,required" db:"filePathTemplate" json:"filePathTemplate"`
	Interval                            *string `thrift:"interval,3" db:"interval" json:"interval,omitempty"`
	Duration                            *string `thrift:"duration,4" db:"duration" json:"duration,omitempty"`
	Debug                               *int64  `thrift:"debug,5" db:"debug" json:"debug,omitempty"`
	ConditionalNumGoroutinesGreaterThan *int64  `` /* 140-byte string literal not displayed */
	ConditionalNumGoroutinesLessThan    *int64  `` /* 131-byte string literal not displayed */
	ConditionalIsOverloaded             *bool   `thrift:"conditionalIsOverloaded,8" db:"conditionalIsOverloaded" json:"conditionalIsOverloaded,omitempty"`
}

Attributes:

  • Name
  • FilePathTemplate
  • Interval
  • Duration
  • Debug
  • ConditionalNumGoroutinesGreaterThan
  • ConditionalNumGoroutinesLessThan
  • ConditionalIsOverloaded
var NodeDebugProfileStartArgs_Req_DEFAULT *DebugProfileStartRequest

func NewDebugProfileStartRequest added in v0.15.5

func NewDebugProfileStartRequest() *DebugProfileStartRequest

func (*DebugProfileStartRequest) GetConditionalIsOverloaded added in v0.15.5

func (p *DebugProfileStartRequest) GetConditionalIsOverloaded() bool

func (*DebugProfileStartRequest) GetConditionalNumGoroutinesGreaterThan added in v0.15.5

func (p *DebugProfileStartRequest) GetConditionalNumGoroutinesGreaterThan() int64

func (*DebugProfileStartRequest) GetConditionalNumGoroutinesLessThan added in v0.15.5

func (p *DebugProfileStartRequest) GetConditionalNumGoroutinesLessThan() int64

func (*DebugProfileStartRequest) GetDebug added in v0.15.5

func (p *DebugProfileStartRequest) GetDebug() int64

func (*DebugProfileStartRequest) GetDuration added in v0.15.5

func (p *DebugProfileStartRequest) GetDuration() string

func (*DebugProfileStartRequest) GetFilePathTemplate added in v0.15.5

func (p *DebugProfileStartRequest) GetFilePathTemplate() string

func (*DebugProfileStartRequest) GetInterval added in v0.15.5

func (p *DebugProfileStartRequest) GetInterval() string

func (*DebugProfileStartRequest) GetName added in v0.15.5

func (p *DebugProfileStartRequest) GetName() string

func (*DebugProfileStartRequest) IsSetConditionalIsOverloaded added in v0.15.5

func (p *DebugProfileStartRequest) IsSetConditionalIsOverloaded() bool

func (*DebugProfileStartRequest) IsSetConditionalNumGoroutinesGreaterThan added in v0.15.5

func (p *DebugProfileStartRequest) IsSetConditionalNumGoroutinesGreaterThan() bool

func (*DebugProfileStartRequest) IsSetConditionalNumGoroutinesLessThan added in v0.15.5

func (p *DebugProfileStartRequest) IsSetConditionalNumGoroutinesLessThan() bool

func (*DebugProfileStartRequest) IsSetDebug added in v0.15.5

func (p *DebugProfileStartRequest) IsSetDebug() bool

func (*DebugProfileStartRequest) IsSetDuration added in v0.15.5

func (p *DebugProfileStartRequest) IsSetDuration() bool

func (*DebugProfileStartRequest) IsSetInterval added in v0.15.5

func (p *DebugProfileStartRequest) IsSetInterval() bool

func (*DebugProfileStartRequest) Read added in v0.15.5

func (*DebugProfileStartRequest) ReadField1 added in v0.15.5

func (p *DebugProfileStartRequest) ReadField1(iprot thrift.TProtocol) error

func (*DebugProfileStartRequest) ReadField2 added in v0.15.5

func (p *DebugProfileStartRequest) ReadField2(iprot thrift.TProtocol) error

func (*DebugProfileStartRequest) ReadField3 added in v0.15.5

func (p *DebugProfileStartRequest) ReadField3(iprot thrift.TProtocol) error

func (*DebugProfileStartRequest) ReadField4 added in v0.15.5

func (p *DebugProfileStartRequest) ReadField4(iprot thrift.TProtocol) error

func (*DebugProfileStartRequest) ReadField5 added in v0.15.5

func (p *DebugProfileStartRequest) ReadField5(iprot thrift.TProtocol) error

func (*DebugProfileStartRequest) ReadField6 added in v0.15.5

func (p *DebugProfileStartRequest) ReadField6(iprot thrift.TProtocol) error

func (*DebugProfileStartRequest) ReadField7 added in v0.15.5

func (p *DebugProfileStartRequest) ReadField7(iprot thrift.TProtocol) error

func (*DebugProfileStartRequest) ReadField8 added in v0.15.5

func (p *DebugProfileStartRequest) ReadField8(iprot thrift.TProtocol) error

func (*DebugProfileStartRequest) String added in v0.15.5

func (p *DebugProfileStartRequest) String() string

func (*DebugProfileStartRequest) Write added in v0.15.5

type DebugProfileStartResult_ added in v0.15.5

type DebugProfileStartResult_ struct {
}
var NodeDebugProfileStartResult_Success_DEFAULT *DebugProfileStartResult_

func NewDebugProfileStartResult_ added in v0.15.5

func NewDebugProfileStartResult_() *DebugProfileStartResult_

func (*DebugProfileStartResult_) Read added in v0.15.5

func (*DebugProfileStartResult_) String added in v0.15.5

func (p *DebugProfileStartResult_) String() string

func (*DebugProfileStartResult_) Write added in v0.15.5

type DebugProfileStopRequest added in v0.15.5

type DebugProfileStopRequest struct {
	Name string `thrift:"name,1,required" db:"name" json:"name"`
}

Attributes:

  • Name
var NodeDebugProfileStopArgs_Req_DEFAULT *DebugProfileStopRequest

func NewDebugProfileStopRequest added in v0.15.5

func NewDebugProfileStopRequest() *DebugProfileStopRequest

func (*DebugProfileStopRequest) GetName added in v0.15.5

func (p *DebugProfileStopRequest) GetName() string

func (*DebugProfileStopRequest) Read added in v0.15.5

func (*DebugProfileStopRequest) ReadField1 added in v0.15.5

func (p *DebugProfileStopRequest) ReadField1(iprot thrift.TProtocol) error

func (*DebugProfileStopRequest) String added in v0.15.5

func (p *DebugProfileStopRequest) String() string

func (*DebugProfileStopRequest) Write added in v0.15.5

type DebugProfileStopResult_ added in v0.15.5

type DebugProfileStopResult_ struct {
}
var NodeDebugProfileStopResult_Success_DEFAULT *DebugProfileStopResult_

func NewDebugProfileStopResult_ added in v0.15.5

func NewDebugProfileStopResult_() *DebugProfileStopResult_

func (*DebugProfileStopResult_) Read added in v0.15.5

func (*DebugProfileStopResult_) String added in v0.15.5

func (p *DebugProfileStopResult_) String() string

func (*DebugProfileStopResult_) Write added in v0.15.5

type DisjunctionQuery

type DisjunctionQuery struct {
	Queries []*Query `thrift:"queries,1,required" db:"queries" json:"queries"`
}

Attributes:

  • Queries
var Query_Disjunction_DEFAULT *DisjunctionQuery

func NewDisjunctionQuery

func NewDisjunctionQuery() *DisjunctionQuery

func (*DisjunctionQuery) GetQueries

func (p *DisjunctionQuery) GetQueries() []*Query

func (*DisjunctionQuery) Read

func (p *DisjunctionQuery) Read(iprot thrift.TProtocol) error

func (*DisjunctionQuery) ReadField1

func (p *DisjunctionQuery) ReadField1(iprot thrift.TProtocol) error

func (*DisjunctionQuery) String

func (p *DisjunctionQuery) String() string

func (*DisjunctionQuery) Write

func (p *DisjunctionQuery) Write(oprot thrift.TProtocol) error

type Error

type Error struct {
	Type    ErrorType `thrift:"type,1,required" db:"type" json:"type"`
	Message string    `thrift:"message,2,required" db:"message" json:"message"`
}

Attributes:

  • Type
  • Message
var BlockMetadataV2_Err_DEFAULT *Error
var Block_Err_DEFAULT *Error
var ClusterAggregateResult_Err_DEFAULT *Error
var ClusterFetchResult_Err_DEFAULT *Error
var ClusterHealthResult_Err_DEFAULT *Error
var ClusterQueryResult_Err_DEFAULT *Error
var ClusterTruncateResult_Err_DEFAULT *Error
var ClusterWriteResult_Err_DEFAULT *Error
var ClusterWriteTaggedResult_Err_DEFAULT *Error
var FetchRawResult__Err_DEFAULT *Error
var FetchTaggedIDResult__Err_DEFAULT *Error
var NodeAggregateRawResult_Err_DEFAULT *Error
var NodeAggregateResult_Err_DEFAULT *Error
var NodeAggregateTilesResult_Err_DEFAULT *Error
var NodeBootstrappedInPlacementOrNoPlacementResult_Err_DEFAULT *Error
var NodeBootstrappedResult_Err_DEFAULT *Error
var NodeDebugIndexMemorySegmentsResult_Err_DEFAULT *Error
var NodeDebugProfileStartResult_Err_DEFAULT *Error
var NodeDebugProfileStopResult_Err_DEFAULT *Error
var NodeFetchBatchRawResult_Err_DEFAULT *Error
var NodeFetchBatchRawV2Result_Err_DEFAULT *Error
var NodeFetchBlocksMetadataRawV2Result_Err_DEFAULT *Error
var NodeFetchBlocksRawResult_Err_DEFAULT *Error
var NodeFetchResult_Err_DEFAULT *Error
var NodeFetchTaggedResult_Err_DEFAULT *Error
var NodeGetPersistRateLimitResult_Err_DEFAULT *Error
var NodeGetWriteNewSeriesAsyncResult_Err_DEFAULT *Error
var NodeGetWriteNewSeriesBackoffDurationResult_Err_DEFAULT *Error
var NodeGetWriteNewSeriesLimitPerShardPerSecondResult_Err_DEFAULT *Error
var NodeHealthResult_Err_DEFAULT *Error
var NodeQueryResult_Err_DEFAULT *Error
var NodeRepairResult_Err_DEFAULT *Error
var NodeSetPersistRateLimitResult_Err_DEFAULT *Error
var NodeSetWriteNewSeriesAsyncResult_Err_DEFAULT *Error
var NodeSetWriteNewSeriesBackoffDurationResult_Err_DEFAULT *Error
var NodeSetWriteNewSeriesLimitPerShardPerSecondResult_Err_DEFAULT *Error
var NodeTruncateResult_Err_DEFAULT *Error
var NodeWriteResult_Err_DEFAULT *Error
var NodeWriteTaggedResult_Err_DEFAULT *Error
var WriteBatchRawError_Err_DEFAULT *Error

func NewError

func NewError() *Error

func (*Error) Error

func (p *Error) Error() string

func (*Error) GetMessage

func (p *Error) GetMessage() string

func (*Error) GetType

func (p *Error) GetType() ErrorType

func (*Error) Read

func (p *Error) Read(iprot thrift.TProtocol) error

func (*Error) ReadField1

func (p *Error) ReadField1(iprot thrift.TProtocol) error

func (*Error) ReadField2

func (p *Error) ReadField2(iprot thrift.TProtocol) error

func (*Error) String

func (p *Error) String() string

func (*Error) Write

func (p *Error) Write(oprot thrift.TProtocol) error

type ErrorType

type ErrorType int64
const (
	ErrorType_INTERNAL_ERROR ErrorType = 0
	ErrorType_BAD_REQUEST    ErrorType = 1
)

func ErrorTypeFromString

func ErrorTypeFromString(s string) (ErrorType, error)

func ErrorTypePtr

func ErrorTypePtr(v ErrorType) *ErrorType

func (ErrorType) MarshalText

func (p ErrorType) MarshalText() ([]byte, error)

func (*ErrorType) Scan

func (p *ErrorType) Scan(value interface{}) error

func (ErrorType) String

func (p ErrorType) String() string

func (*ErrorType) UnmarshalText

func (p *ErrorType) UnmarshalText(text []byte) error

func (*ErrorType) Value

func (p *ErrorType) Value() (driver.Value, error)

type FetchBatchRawRequest

type FetchBatchRawRequest struct {
	RangeStart    int64    `thrift:"rangeStart,1,required" db:"rangeStart" json:"rangeStart"`
	RangeEnd      int64    `thrift:"rangeEnd,2,required" db:"rangeEnd" json:"rangeEnd"`
	NameSpace     []byte   `thrift:"nameSpace,3,required" db:"nameSpace" json:"nameSpace"`
	Ids           [][]byte `thrift:"ids,4,required" db:"ids" json:"ids"`
	RangeTimeType TimeType `thrift:"rangeTimeType,5" db:"rangeTimeType" json:"rangeTimeType,omitempty"`
}

Attributes:

  • RangeStart
  • RangeEnd
  • NameSpace
  • Ids
  • RangeTimeType
var NodeFetchBatchRawArgs_Req_DEFAULT *FetchBatchRawRequest

func NewFetchBatchRawRequest

func NewFetchBatchRawRequest() *FetchBatchRawRequest

func (*FetchBatchRawRequest) GetIds

func (p *FetchBatchRawRequest) GetIds() [][]byte

func (*FetchBatchRawRequest) GetNameSpace

func (p *FetchBatchRawRequest) GetNameSpace() []byte

func (*FetchBatchRawRequest) GetRangeEnd

func (p *FetchBatchRawRequest) GetRangeEnd() int64

func (*FetchBatchRawRequest) GetRangeStart

func (p *FetchBatchRawRequest) GetRangeStart() int64

func (*FetchBatchRawRequest) GetRangeTimeType

func (p *FetchBatchRawRequest) GetRangeTimeType() TimeType

func (*FetchBatchRawRequest) IsSetRangeTimeType

func (p *FetchBatchRawRequest) IsSetRangeTimeType() bool

func (*FetchBatchRawRequest) Read

func (p *FetchBatchRawRequest) Read(iprot thrift.TProtocol) error

func (*FetchBatchRawRequest) ReadField1

func (p *FetchBatchRawRequest) ReadField1(iprot thrift.TProtocol) error

func (*FetchBatchRawRequest) ReadField2

func (p *FetchBatchRawRequest) ReadField2(iprot thrift.TProtocol) error

func (*FetchBatchRawRequest) ReadField3

func (p *FetchBatchRawRequest) ReadField3(iprot thrift.TProtocol) error

func (*FetchBatchRawRequest) ReadField4

func (p *FetchBatchRawRequest) ReadField4(iprot thrift.TProtocol) error

func (*FetchBatchRawRequest) ReadField5

func (p *FetchBatchRawRequest) ReadField5(iprot thrift.TProtocol) error

func (*FetchBatchRawRequest) String

func (p *FetchBatchRawRequest) String() string

func (*FetchBatchRawRequest) Write

func (p *FetchBatchRawRequest) Write(oprot thrift.TProtocol) error

type FetchBatchRawResult_

type FetchBatchRawResult_ struct {
	Elements []*FetchRawResult_ `thrift:"elements,1,required" db:"elements" json:"elements"`
}

Attributes:

  • Elements
var NodeFetchBatchRawResult_Success_DEFAULT *FetchBatchRawResult_
var NodeFetchBatchRawV2Result_Success_DEFAULT *FetchBatchRawResult_

func NewFetchBatchRawResult_

func NewFetchBatchRawResult_() *FetchBatchRawResult_

func (*FetchBatchRawResult_) GetElements

func (p *FetchBatchRawResult_) GetElements() []*FetchRawResult_

func (*FetchBatchRawResult_) Read

func (p *FetchBatchRawResult_) Read(iprot thrift.TProtocol) error

func (*FetchBatchRawResult_) ReadField1

func (p *FetchBatchRawResult_) ReadField1(iprot thrift.TProtocol) error

func (*FetchBatchRawResult_) String

func (p *FetchBatchRawResult_) String() string

func (*FetchBatchRawResult_) Write

func (p *FetchBatchRawResult_) Write(oprot thrift.TProtocol) error

type FetchBatchRawV2Request added in v0.14.0

type FetchBatchRawV2Request struct {
	NameSpaces [][]byte                         `thrift:"nameSpaces,1,required" db:"nameSpaces" json:"nameSpaces"`
	Elements   []*FetchBatchRawV2RequestElement `thrift:"elements,2,required" db:"elements" json:"elements"`
}

Attributes:

  • NameSpaces
  • Elements
var NodeFetchBatchRawV2Args_Req_DEFAULT *FetchBatchRawV2Request

func NewFetchBatchRawV2Request added in v0.14.0

func NewFetchBatchRawV2Request() *FetchBatchRawV2Request

func (*FetchBatchRawV2Request) GetElements added in v0.14.0

func (*FetchBatchRawV2Request) GetNameSpaces added in v0.14.0

func (p *FetchBatchRawV2Request) GetNameSpaces() [][]byte

func (*FetchBatchRawV2Request) Read added in v0.14.0

func (*FetchBatchRawV2Request) ReadField1 added in v0.14.0

func (p *FetchBatchRawV2Request) ReadField1(iprot thrift.TProtocol) error

func (*FetchBatchRawV2Request) ReadField2 added in v0.14.0

func (p *FetchBatchRawV2Request) ReadField2(iprot thrift.TProtocol) error

func (*FetchBatchRawV2Request) String added in v0.14.0

func (p *FetchBatchRawV2Request) String() string

func (*FetchBatchRawV2Request) Write added in v0.14.0

func (p *FetchBatchRawV2Request) Write(oprot thrift.TProtocol) error

type FetchBatchRawV2RequestElement added in v0.14.0

type FetchBatchRawV2RequestElement struct {
	NameSpace     int64    `thrift:"nameSpace,1,required" db:"nameSpace" json:"nameSpace"`
	RangeStart    int64    `thrift:"rangeStart,2,required" db:"rangeStart" json:"rangeStart"`
	RangeEnd      int64    `thrift:"rangeEnd,3,required" db:"rangeEnd" json:"rangeEnd"`
	ID            []byte   `thrift:"id,4,required" db:"id" json:"id"`
	RangeTimeType TimeType `thrift:"rangeTimeType,5" db:"rangeTimeType" json:"rangeTimeType,omitempty"`
}

Attributes:

  • NameSpace
  • RangeStart
  • RangeEnd
  • ID
  • RangeTimeType

func NewFetchBatchRawV2RequestElement added in v0.14.0

func NewFetchBatchRawV2RequestElement() *FetchBatchRawV2RequestElement

func (*FetchBatchRawV2RequestElement) GetID added in v0.14.0

func (p *FetchBatchRawV2RequestElement) GetID() []byte

func (*FetchBatchRawV2RequestElement) GetNameSpace added in v0.14.0

func (p *FetchBatchRawV2RequestElement) GetNameSpace() int64

func (*FetchBatchRawV2RequestElement) GetRangeEnd added in v0.14.0

func (p *FetchBatchRawV2RequestElement) GetRangeEnd() int64

func (*FetchBatchRawV2RequestElement) GetRangeStart added in v0.14.0

func (p *FetchBatchRawV2RequestElement) GetRangeStart() int64

func (*FetchBatchRawV2RequestElement) GetRangeTimeType added in v0.14.0

func (p *FetchBatchRawV2RequestElement) GetRangeTimeType() TimeType

func (*FetchBatchRawV2RequestElement) IsSetRangeTimeType added in v0.14.0

func (p *FetchBatchRawV2RequestElement) IsSetRangeTimeType() bool

func (*FetchBatchRawV2RequestElement) Read added in v0.14.0

func (*FetchBatchRawV2RequestElement) ReadField1 added in v0.14.0

func (p *FetchBatchRawV2RequestElement) ReadField1(iprot thrift.TProtocol) error

func (*FetchBatchRawV2RequestElement) ReadField2 added in v0.14.0

func (p *FetchBatchRawV2RequestElement) ReadField2(iprot thrift.TProtocol) error

func (*FetchBatchRawV2RequestElement) ReadField3 added in v0.14.0

func (p *FetchBatchRawV2RequestElement) ReadField3(iprot thrift.TProtocol) error

func (*FetchBatchRawV2RequestElement) ReadField4 added in v0.14.0

func (p *FetchBatchRawV2RequestElement) ReadField4(iprot thrift.TProtocol) error

func (*FetchBatchRawV2RequestElement) ReadField5 added in v0.14.0

func (p *FetchBatchRawV2RequestElement) ReadField5(iprot thrift.TProtocol) error

func (*FetchBatchRawV2RequestElement) String added in v0.14.0

func (*FetchBatchRawV2RequestElement) Write added in v0.14.0

type FetchBlocksMetadataRawV2Request

type FetchBlocksMetadataRawV2Request struct {
	NameSpace        []byte `thrift:"nameSpace,1,required" db:"nameSpace" json:"nameSpace"`
	Shard            int32  `thrift:"shard,2,required" db:"shard" json:"shard"`
	RangeStart       int64  `thrift:"rangeStart,3,required" db:"rangeStart" json:"rangeStart"`
	RangeEnd         int64  `thrift:"rangeEnd,4,required" db:"rangeEnd" json:"rangeEnd"`
	Limit            int64  `thrift:"limit,5,required" db:"limit" json:"limit"`
	PageToken        []byte `thrift:"pageToken,6" db:"pageToken" json:"pageToken,omitempty"`
	IncludeSizes     *bool  `thrift:"includeSizes,7" db:"includeSizes" json:"includeSizes,omitempty"`
	IncludeChecksums *bool  `thrift:"includeChecksums,8" db:"includeChecksums" json:"includeChecksums,omitempty"`
	IncludeLastRead  *bool  `thrift:"includeLastRead,9" db:"includeLastRead" json:"includeLastRead,omitempty"`
}

Attributes:

  • NameSpace
  • Shard
  • RangeStart
  • RangeEnd
  • Limit
  • PageToken
  • IncludeSizes
  • IncludeChecksums
  • IncludeLastRead
var NodeFetchBlocksMetadataRawV2Args_Req_DEFAULT *FetchBlocksMetadataRawV2Request

func NewFetchBlocksMetadataRawV2Request

func NewFetchBlocksMetadataRawV2Request() *FetchBlocksMetadataRawV2Request

func (*FetchBlocksMetadataRawV2Request) GetIncludeChecksums

func (p *FetchBlocksMetadataRawV2Request) GetIncludeChecksums() bool

func (*FetchBlocksMetadataRawV2Request) GetIncludeLastRead

func (p *FetchBlocksMetadataRawV2Request) GetIncludeLastRead() bool

func (*FetchBlocksMetadataRawV2Request) GetIncludeSizes

func (p *FetchBlocksMetadataRawV2Request) GetIncludeSizes() bool

func (*FetchBlocksMetadataRawV2Request) GetLimit

func (p *FetchBlocksMetadataRawV2Request) GetLimit() int64

func (*FetchBlocksMetadataRawV2Request) GetNameSpace

func (p *FetchBlocksMetadataRawV2Request) GetNameSpace() []byte

func (*FetchBlocksMetadataRawV2Request) GetPageToken

func (p *FetchBlocksMetadataRawV2Request) GetPageToken() []byte

func (*FetchBlocksMetadataRawV2Request) GetRangeEnd

func (p *FetchBlocksMetadataRawV2Request) GetRangeEnd() int64

func (*FetchBlocksMetadataRawV2Request) GetRangeStart

func (p *FetchBlocksMetadataRawV2Request) GetRangeStart() int64

func (*FetchBlocksMetadataRawV2Request) GetShard

func (p *FetchBlocksMetadataRawV2Request) GetShard() int32

func (*FetchBlocksMetadataRawV2Request) IsSetIncludeChecksums

func (p *FetchBlocksMetadataRawV2Request) IsSetIncludeChecksums() bool

func (*FetchBlocksMetadataRawV2Request) IsSetIncludeLastRead

func (p *FetchBlocksMetadataRawV2Request) IsSetIncludeLastRead() bool

func (*FetchBlocksMetadataRawV2Request) IsSetIncludeSizes

func (p *FetchBlocksMetadataRawV2Request) IsSetIncludeSizes() bool

func (*FetchBlocksMetadataRawV2Request) IsSetPageToken

func (p *FetchBlocksMetadataRawV2Request) IsSetPageToken() bool

func (*FetchBlocksMetadataRawV2Request) Read

func (*FetchBlocksMetadataRawV2Request) ReadField1

func (*FetchBlocksMetadataRawV2Request) ReadField2

func (*FetchBlocksMetadataRawV2Request) ReadField3

func (*FetchBlocksMetadataRawV2Request) ReadField4

func (*FetchBlocksMetadataRawV2Request) ReadField5

func (*FetchBlocksMetadataRawV2Request) ReadField6

func (*FetchBlocksMetadataRawV2Request) ReadField7

func (*FetchBlocksMetadataRawV2Request) ReadField8

func (*FetchBlocksMetadataRawV2Request) ReadField9

func (*FetchBlocksMetadataRawV2Request) String

func (*FetchBlocksMetadataRawV2Request) Write

type FetchBlocksMetadataRawV2Result_

type FetchBlocksMetadataRawV2Result_ struct {
	Elements      []*BlockMetadataV2 `thrift:"elements,1,required" db:"elements" json:"elements"`
	NextPageToken []byte             `thrift:"nextPageToken,2" db:"nextPageToken" json:"nextPageToken,omitempty"`
}

Attributes:

  • Elements
  • NextPageToken
var NodeFetchBlocksMetadataRawV2Result_Success_DEFAULT *FetchBlocksMetadataRawV2Result_

func NewFetchBlocksMetadataRawV2Result_

func NewFetchBlocksMetadataRawV2Result_() *FetchBlocksMetadataRawV2Result_

func (*FetchBlocksMetadataRawV2Result_) GetElements

func (*FetchBlocksMetadataRawV2Result_) GetNextPageToken

func (p *FetchBlocksMetadataRawV2Result_) GetNextPageToken() []byte

func (*FetchBlocksMetadataRawV2Result_) IsSetNextPageToken

func (p *FetchBlocksMetadataRawV2Result_) IsSetNextPageToken() bool

func (*FetchBlocksMetadataRawV2Result_) Read

func (*FetchBlocksMetadataRawV2Result_) ReadField1

func (*FetchBlocksMetadataRawV2Result_) ReadField2

func (*FetchBlocksMetadataRawV2Result_) String

func (*FetchBlocksMetadataRawV2Result_) Write

type FetchBlocksRawRequest

type FetchBlocksRawRequest struct {
	NameSpace []byte                          `thrift:"nameSpace,1,required" db:"nameSpace" json:"nameSpace"`
	Shard     int32                           `thrift:"shard,2,required" db:"shard" json:"shard"`
	Elements  []*FetchBlocksRawRequestElement `thrift:"elements,3,required" db:"elements" json:"elements"`
}

Attributes:

  • NameSpace
  • Shard
  • Elements
var NodeFetchBlocksRawArgs_Req_DEFAULT *FetchBlocksRawRequest

func NewFetchBlocksRawRequest

func NewFetchBlocksRawRequest() *FetchBlocksRawRequest

func (*FetchBlocksRawRequest) GetElements

func (*FetchBlocksRawRequest) GetNameSpace

func (p *FetchBlocksRawRequest) GetNameSpace() []byte

func (*FetchBlocksRawRequest) GetShard

func (p *FetchBlocksRawRequest) GetShard() int32

func (*FetchBlocksRawRequest) Read

func (*FetchBlocksRawRequest) ReadField1

func (p *FetchBlocksRawRequest) ReadField1(iprot thrift.TProtocol) error

func (*FetchBlocksRawRequest) ReadField2

func (p *FetchBlocksRawRequest) ReadField2(iprot thrift.TProtocol) error

func (*FetchBlocksRawRequest) ReadField3

func (p *FetchBlocksRawRequest) ReadField3(iprot thrift.TProtocol) error

func (*FetchBlocksRawRequest) String

func (p *FetchBlocksRawRequest) String() string

func (*FetchBlocksRawRequest) Write

func (p *FetchBlocksRawRequest) Write(oprot thrift.TProtocol) error

type FetchBlocksRawRequestElement

type FetchBlocksRawRequestElement struct {
	ID     []byte  `thrift:"id,1,required" db:"id" json:"id"`
	Starts []int64 `thrift:"starts,2,required" db:"starts" json:"starts"`
}

Attributes:

  • ID
  • Starts

func NewFetchBlocksRawRequestElement

func NewFetchBlocksRawRequestElement() *FetchBlocksRawRequestElement

func (*FetchBlocksRawRequestElement) GetID

func (p *FetchBlocksRawRequestElement) GetID() []byte

func (*FetchBlocksRawRequestElement) GetStarts

func (p *FetchBlocksRawRequestElement) GetStarts() []int64

func (*FetchBlocksRawRequestElement) Read

func (*FetchBlocksRawRequestElement) ReadField1

func (p *FetchBlocksRawRequestElement) ReadField1(iprot thrift.TProtocol) error

func (*FetchBlocksRawRequestElement) ReadField2

func (p *FetchBlocksRawRequestElement) ReadField2(iprot thrift.TProtocol) error

func (*FetchBlocksRawRequestElement) String

func (*FetchBlocksRawRequestElement) Write

type FetchBlocksRawResult_

type FetchBlocksRawResult_ struct {
	Elements []*Blocks `thrift:"elements,1,required" db:"elements" json:"elements"`
}

Attributes:

  • Elements
var NodeFetchBlocksRawResult_Success_DEFAULT *FetchBlocksRawResult_

func NewFetchBlocksRawResult_

func NewFetchBlocksRawResult_() *FetchBlocksRawResult_

func (*FetchBlocksRawResult_) GetElements

func (p *FetchBlocksRawResult_) GetElements() []*Blocks

func (*FetchBlocksRawResult_) Read

func (*FetchBlocksRawResult_) ReadField1

func (p *FetchBlocksRawResult_) ReadField1(iprot thrift.TProtocol) error

func (*FetchBlocksRawResult_) String

func (p *FetchBlocksRawResult_) String() string

func (*FetchBlocksRawResult_) Write

func (p *FetchBlocksRawResult_) Write(oprot thrift.TProtocol) error

type FetchRawResult_

type FetchRawResult_ struct {
	Segments []*Segments `thrift:"segments,1,required" db:"segments" json:"segments"`
	Err      *Error      `thrift:"err,2" db:"err" json:"err,omitempty"`
}

Attributes:

  • Segments
  • Err

func NewFetchRawResult_

func NewFetchRawResult_() *FetchRawResult_

func (*FetchRawResult_) GetErr

func (p *FetchRawResult_) GetErr() *Error

func (*FetchRawResult_) GetSegments

func (p *FetchRawResult_) GetSegments() []*Segments

func (*FetchRawResult_) IsSetErr

func (p *FetchRawResult_) IsSetErr() bool

func (*FetchRawResult_) Read

func (p *FetchRawResult_) Read(iprot thrift.TProtocol) error

func (*FetchRawResult_) ReadField1

func (p *FetchRawResult_) ReadField1(iprot thrift.TProtocol) error

func (*FetchRawResult_) ReadField2

func (p *FetchRawResult_) ReadField2(iprot thrift.TProtocol) error

func (*FetchRawResult_) String

func (p *FetchRawResult_) String() string

func (*FetchRawResult_) Write

func (p *FetchRawResult_) Write(oprot thrift.TProtocol) error

type FetchRequest

type FetchRequest struct {
	RangeStart     int64    `thrift:"rangeStart,1,required" db:"rangeStart" json:"rangeStart"`
	RangeEnd       int64    `thrift:"rangeEnd,2,required" db:"rangeEnd" json:"rangeEnd"`
	NameSpace      string   `thrift:"nameSpace,3,required" db:"nameSpace" json:"nameSpace"`
	ID             string   `thrift:"id,4,required" db:"id" json:"id"`
	RangeType      TimeType `thrift:"rangeType,5" db:"rangeType" json:"rangeType,omitempty"`
	ResultTimeType TimeType `thrift:"resultTimeType,6" db:"resultTimeType" json:"resultTimeType,omitempty"`
}

Attributes:

  • RangeStart
  • RangeEnd
  • NameSpace
  • ID
  • RangeType
  • ResultTimeType
var ClusterFetchArgs_Req_DEFAULT *FetchRequest
var NodeFetchArgs_Req_DEFAULT *FetchRequest

func NewFetchRequest

func NewFetchRequest() *FetchRequest

func (*FetchRequest) GetID

func (p *FetchRequest) GetID() string

func (*FetchRequest) GetNameSpace

func (p *FetchRequest) GetNameSpace() string

func (*FetchRequest) GetRangeEnd

func (p *FetchRequest) GetRangeEnd() int64

func (*FetchRequest) GetRangeStart

func (p *FetchRequest) GetRangeStart() int64

func (*FetchRequest) GetRangeType

func (p *FetchRequest) GetRangeType() TimeType

func (*FetchRequest) GetResultTimeType

func (p *FetchRequest) GetResultTimeType() TimeType

func (*FetchRequest) IsSetRangeType

func (p *FetchRequest) IsSetRangeType() bool

func (*FetchRequest) IsSetResultTimeType

func (p *FetchRequest) IsSetResultTimeType() bool

func (*FetchRequest) Read

func (p *FetchRequest) Read(iprot thrift.TProtocol) error

func (*FetchRequest) ReadField1

func (p *FetchRequest) ReadField1(iprot thrift.TProtocol) error

func (*FetchRequest) ReadField2

func (p *FetchRequest) ReadField2(iprot thrift.TProtocol) error

func (*FetchRequest) ReadField3

func (p *FetchRequest) ReadField3(iprot thrift.TProtocol) error

func (*FetchRequest) ReadField4

func (p *FetchRequest) ReadField4(iprot thrift.TProtocol) error

func (*FetchRequest) ReadField5

func (p *FetchRequest) ReadField5(iprot thrift.TProtocol) error

func (*FetchRequest) ReadField6

func (p *FetchRequest) ReadField6(iprot thrift.TProtocol) error

func (*FetchRequest) String

func (p *FetchRequest) String() string

func (*FetchRequest) Write

func (p *FetchRequest) Write(oprot thrift.TProtocol) error

type FetchResult_

type FetchResult_ struct {
	Datapoints []*Datapoint `thrift:"datapoints,1,required" db:"datapoints" json:"datapoints"`
}

Attributes:

  • Datapoints
var ClusterFetchResult_Success_DEFAULT *FetchResult_
var NodeFetchResult_Success_DEFAULT *FetchResult_

func NewFetchResult_

func NewFetchResult_() *FetchResult_

func (*FetchResult_) GetDatapoints

func (p *FetchResult_) GetDatapoints() []*Datapoint

func (*FetchResult_) Read

func (p *FetchResult_) Read(iprot thrift.TProtocol) error

func (*FetchResult_) ReadField1

func (p *FetchResult_) ReadField1(iprot thrift.TProtocol) error

func (*FetchResult_) String

func (p *FetchResult_) String() string

func (*FetchResult_) Write

func (p *FetchResult_) Write(oprot thrift.TProtocol) error

type FetchTaggedIDResult_

type FetchTaggedIDResult_ struct {
	ID          []byte      `thrift:"id,1,required" db:"id" json:"id"`
	NameSpace   []byte      `thrift:"nameSpace,2,required" db:"nameSpace" json:"nameSpace"`
	EncodedTags []byte      `thrift:"encodedTags,3,required" db:"encodedTags" json:"encodedTags"`
	Segments    []*Segments `thrift:"segments,4" db:"segments" json:"segments,omitempty"`
	Err         *Error      `thrift:"err,5" db:"err" json:"err,omitempty"`
}

Attributes:

  • ID
  • NameSpace
  • EncodedTags
  • Segments
  • Err

func NewFetchTaggedIDResult_

func NewFetchTaggedIDResult_() *FetchTaggedIDResult_

func (*FetchTaggedIDResult_) GetEncodedTags

func (p *FetchTaggedIDResult_) GetEncodedTags() []byte

func (*FetchTaggedIDResult_) GetErr

func (p *FetchTaggedIDResult_) GetErr() *Error

func (*FetchTaggedIDResult_) GetID

func (p *FetchTaggedIDResult_) GetID() []byte

func (*FetchTaggedIDResult_) GetNameSpace

func (p *FetchTaggedIDResult_) GetNameSpace() []byte

func (*FetchTaggedIDResult_) GetSegments

func (p *FetchTaggedIDResult_) GetSegments() []*Segments

func (*FetchTaggedIDResult_) IsSetErr

func (p *FetchTaggedIDResult_) IsSetErr() bool

func (*FetchTaggedIDResult_) IsSetSegments

func (p *FetchTaggedIDResult_) IsSetSegments() bool

func (*FetchTaggedIDResult_) Read

func (p *FetchTaggedIDResult_) Read(iprot thrift.TProtocol) error

func (*FetchTaggedIDResult_) ReadField1

func (p *FetchTaggedIDResult_) ReadField1(iprot thrift.TProtocol) error

func (*FetchTaggedIDResult_) ReadField2

func (p *FetchTaggedIDResult_) ReadField2(iprot thrift.TProtocol) error

func (*FetchTaggedIDResult_) ReadField3

func (p *FetchTaggedIDResult_) ReadField3(iprot thrift.TProtocol) error

func (*FetchTaggedIDResult_) ReadField4

func (p *FetchTaggedIDResult_) ReadField4(iprot thrift.TProtocol) error

func (*FetchTaggedIDResult_) ReadField5

func (p *FetchTaggedIDResult_) ReadField5(iprot thrift.TProtocol) error

func (*FetchTaggedIDResult_) String

func (p *FetchTaggedIDResult_) String() string

func (*FetchTaggedIDResult_) Write

func (p *FetchTaggedIDResult_) Write(oprot thrift.TProtocol) error

type FetchTaggedRequest

type FetchTaggedRequest struct {
	NameSpace         []byte   `thrift:"nameSpace,1,required" db:"nameSpace" json:"nameSpace"`
	Query             []byte   `thrift:"query,2,required" db:"query" json:"query"`
	RangeStart        int64    `thrift:"rangeStart,3,required" db:"rangeStart" json:"rangeStart"`
	RangeEnd          int64    `thrift:"rangeEnd,4,required" db:"rangeEnd" json:"rangeEnd"`
	FetchData         bool     `thrift:"fetchData,5,required" db:"fetchData" json:"fetchData"`
	Limit             *int64   `thrift:"limit,6" db:"limit" json:"limit,omitempty"`
	RangeTimeType     TimeType `thrift:"rangeTimeType,7" db:"rangeTimeType" json:"rangeTimeType,omitempty"`
	RequireExhaustive bool     `thrift:"requireExhaustive,8" db:"requireExhaustive" json:"requireExhaustive,omitempty"`
	DocsLimit         *int64   `thrift:"docsLimit,9" db:"docsLimit" json:"docsLimit,omitempty"`
}

Attributes:

  • NameSpace
  • Query
  • RangeStart
  • RangeEnd
  • FetchData
  • Limit
  • RangeTimeType
  • RequireExhaustive
  • DocsLimit
var NodeFetchTaggedArgs_Req_DEFAULT *FetchTaggedRequest

func NewFetchTaggedRequest

func NewFetchTaggedRequest() *FetchTaggedRequest

func (*FetchTaggedRequest) GetDocsLimit added in v0.15.3

func (p *FetchTaggedRequest) GetDocsLimit() int64

func (*FetchTaggedRequest) GetFetchData

func (p *FetchTaggedRequest) GetFetchData() bool

func (*FetchTaggedRequest) GetLimit

func (p *FetchTaggedRequest) GetLimit() int64

func (*FetchTaggedRequest) GetNameSpace

func (p *FetchTaggedRequest) GetNameSpace() []byte

func (*FetchTaggedRequest) GetQuery

func (p *FetchTaggedRequest) GetQuery() []byte

func (*FetchTaggedRequest) GetRangeEnd

func (p *FetchTaggedRequest) GetRangeEnd() int64

func (*FetchTaggedRequest) GetRangeStart

func (p *FetchTaggedRequest) GetRangeStart() int64

func (*FetchTaggedRequest) GetRangeTimeType

func (p *FetchTaggedRequest) GetRangeTimeType() TimeType

func (*FetchTaggedRequest) GetRequireExhaustive added in v0.15.1

func (p *FetchTaggedRequest) GetRequireExhaustive() bool

func (*FetchTaggedRequest) IsSetDocsLimit added in v0.15.3

func (p *FetchTaggedRequest) IsSetDocsLimit() bool

func (*FetchTaggedRequest) IsSetLimit

func (p *FetchTaggedRequest) IsSetLimit() bool

func (*FetchTaggedRequest) IsSetRangeTimeType

func (p *FetchTaggedRequest) IsSetRangeTimeType() bool

func (*FetchTaggedRequest) IsSetRequireExhaustive added in v0.15.1

func (p *FetchTaggedRequest) IsSetRequireExhaustive() bool

func (*FetchTaggedRequest) Read

func (p *FetchTaggedRequest) Read(iprot thrift.TProtocol) error

func (*FetchTaggedRequest) ReadField1

func (p *FetchTaggedRequest) ReadField1(iprot thrift.TProtocol) error

func (*FetchTaggedRequest) ReadField2

func (p *FetchTaggedRequest) ReadField2(iprot thrift.TProtocol) error

func (*FetchTaggedRequest) ReadField3

func (p *FetchTaggedRequest) ReadField3(iprot thrift.TProtocol) error

func (*FetchTaggedRequest) ReadField4

func (p *FetchTaggedRequest) ReadField4(iprot thrift.TProtocol) error

func (*FetchTaggedRequest) ReadField5

func (p *FetchTaggedRequest) ReadField5(iprot thrift.TProtocol) error

func (*FetchTaggedRequest) ReadField6

func (p *FetchTaggedRequest) ReadField6(iprot thrift.TProtocol) error

func (*FetchTaggedRequest) ReadField7

func (p *FetchTaggedRequest) ReadField7(iprot thrift.TProtocol) error

func (*FetchTaggedRequest) ReadField8 added in v0.15.1

func (p *FetchTaggedRequest) ReadField8(iprot thrift.TProtocol) error

func (*FetchTaggedRequest) ReadField9 added in v0.15.3

func (p *FetchTaggedRequest) ReadField9(iprot thrift.TProtocol) error

func (*FetchTaggedRequest) String

func (p *FetchTaggedRequest) String() string

func (*FetchTaggedRequest) Write

func (p *FetchTaggedRequest) Write(oprot thrift.TProtocol) error

type FetchTaggedResult_

type FetchTaggedResult_ struct {
	Elements   []*FetchTaggedIDResult_ `thrift:"elements,1,required" db:"elements" json:"elements"`
	Exhaustive bool                    `thrift:"exhaustive,2,required" db:"exhaustive" json:"exhaustive"`
}

Attributes:

  • Elements
  • Exhaustive
var NodeFetchTaggedResult_Success_DEFAULT *FetchTaggedResult_

func NewFetchTaggedResult_

func NewFetchTaggedResult_() *FetchTaggedResult_

func (*FetchTaggedResult_) GetElements

func (p *FetchTaggedResult_) GetElements() []*FetchTaggedIDResult_

func (*FetchTaggedResult_) GetExhaustive

func (p *FetchTaggedResult_) GetExhaustive() bool

func (*FetchTaggedResult_) Read

func (p *FetchTaggedResult_) Read(iprot thrift.TProtocol) error

func (*FetchTaggedResult_) ReadField1

func (p *FetchTaggedResult_) ReadField1(iprot thrift.TProtocol) error

func (*FetchTaggedResult_) ReadField2

func (p *FetchTaggedResult_) ReadField2(iprot thrift.TProtocol) error

func (*FetchTaggedResult_) String

func (p *FetchTaggedResult_) String() string

func (*FetchTaggedResult_) Write

func (p *FetchTaggedResult_) Write(oprot thrift.TProtocol) error

type FieldQuery added in v0.8.1

type FieldQuery struct {
	Field string `thrift:"field,1,required" db:"field" json:"field"`
}

Attributes:

  • Field
var Query_Field_DEFAULT *FieldQuery

func NewFieldQuery added in v0.8.1

func NewFieldQuery() *FieldQuery

func (*FieldQuery) GetField added in v0.8.1

func (p *FieldQuery) GetField() string

func (*FieldQuery) Read added in v0.8.1

func (p *FieldQuery) Read(iprot thrift.TProtocol) error

func (*FieldQuery) ReadField1 added in v0.8.1

func (p *FieldQuery) ReadField1(iprot thrift.TProtocol) error

func (*FieldQuery) String added in v0.8.1

func (p *FieldQuery) String() string

func (*FieldQuery) Write added in v0.8.1

func (p *FieldQuery) Write(oprot thrift.TProtocol) error

type HealthResult_

type HealthResult_ struct {
	Ok     bool   `thrift:"ok,1,required" db:"ok" json:"ok"`
	Status string `thrift:"status,2,required" db:"status" json:"status"`
}

Attributes:

  • Ok
  • Status
var ClusterHealthResult_Success_DEFAULT *HealthResult_

func NewHealthResult_

func NewHealthResult_() *HealthResult_

func (*HealthResult_) GetOk

func (p *HealthResult_) GetOk() bool

func (*HealthResult_) GetStatus

func (p *HealthResult_) GetStatus() string

func (*HealthResult_) Read

func (p *HealthResult_) Read(iprot thrift.TProtocol) error

func (*HealthResult_) ReadField1

func (p *HealthResult_) ReadField1(iprot thrift.TProtocol) error

func (*HealthResult_) ReadField2

func (p *HealthResult_) ReadField2(iprot thrift.TProtocol) error

func (*HealthResult_) String

func (p *HealthResult_) String() string

func (*HealthResult_) Write

func (p *HealthResult_) Write(oprot thrift.TProtocol) error

type MockTChanCluster

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

MockTChanCluster is a mock of TChanCluster interface

func NewMockTChanCluster

func NewMockTChanCluster(ctrl *gomock.Controller) *MockTChanCluster

NewMockTChanCluster creates a new mock instance

func (*MockTChanCluster) Aggregate added in v0.7.3

Aggregate mocks base method

func (*MockTChanCluster) EXPECT

EXPECT returns an object that allows the caller to indicate expected use

func (*MockTChanCluster) Fetch

Fetch mocks base method

func (*MockTChanCluster) Health

func (m *MockTChanCluster) Health(ctx thrift.Context) (*HealthResult_, error)

Health mocks base method

func (*MockTChanCluster) Query

Query mocks base method

func (*MockTChanCluster) Truncate

Truncate mocks base method

func (*MockTChanCluster) Write

func (m *MockTChanCluster) Write(ctx thrift.Context, req *WriteRequest) error

Write mocks base method

func (*MockTChanCluster) WriteTagged

func (m *MockTChanCluster) WriteTagged(ctx thrift.Context, req *WriteTaggedRequest) error

WriteTagged mocks base method

type MockTChanClusterMockRecorder

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

MockTChanClusterMockRecorder is the mock recorder for MockTChanCluster

func (*MockTChanClusterMockRecorder) Aggregate added in v0.7.3

func (mr *MockTChanClusterMockRecorder) Aggregate(ctx, req interface{}) *gomock.Call

Aggregate indicates an expected call of Aggregate

func (*MockTChanClusterMockRecorder) Fetch

func (mr *MockTChanClusterMockRecorder) Fetch(ctx, req interface{}) *gomock.Call

Fetch indicates an expected call of Fetch

func (*MockTChanClusterMockRecorder) Health

func (mr *MockTChanClusterMockRecorder) Health(ctx interface{}) *gomock.Call

Health indicates an expected call of Health

func (*MockTChanClusterMockRecorder) Query

func (mr *MockTChanClusterMockRecorder) Query(ctx, req interface{}) *gomock.Call

Query indicates an expected call of Query

func (*MockTChanClusterMockRecorder) Truncate

func (mr *MockTChanClusterMockRecorder) Truncate(ctx, req interface{}) *gomock.Call

Truncate indicates an expected call of Truncate

func (*MockTChanClusterMockRecorder) Write

func (mr *MockTChanClusterMockRecorder) Write(ctx, req interface{}) *gomock.Call

Write indicates an expected call of Write

func (*MockTChanClusterMockRecorder) WriteTagged

func (mr *MockTChanClusterMockRecorder) WriteTagged(ctx, req interface{}) *gomock.Call

WriteTagged indicates an expected call of WriteTagged

type MockTChanNode

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

MockTChanNode is a mock of TChanNode interface

func NewMockTChanNode

func NewMockTChanNode(ctrl *gomock.Controller) *MockTChanNode

NewMockTChanNode creates a new mock instance

func (*MockTChanNode) Aggregate added in v0.7.3

Aggregate mocks base method

func (*MockTChanNode) AggregateRaw added in v0.7.3

AggregateRaw mocks base method

func (*MockTChanNode) AggregateTiles added in v0.15.14

AggregateTiles mocks base method

func (*MockTChanNode) Bootstrapped added in v0.4.6

func (m *MockTChanNode) Bootstrapped(ctx thrift.Context) (*NodeBootstrappedResult_, error)

Bootstrapped mocks base method

func (*MockTChanNode) BootstrappedInPlacementOrNoPlacement added in v0.9.0

func (m *MockTChanNode) BootstrappedInPlacementOrNoPlacement(ctx thrift.Context) (*NodeBootstrappedInPlacementOrNoPlacementResult_, error)

BootstrappedInPlacementOrNoPlacement mocks base method

func (*MockTChanNode) DebugIndexMemorySegments added in v0.15.0

DebugIndexMemorySegments mocks base method

func (*MockTChanNode) DebugProfileStart added in v0.15.5

DebugProfileStart mocks base method

func (*MockTChanNode) DebugProfileStop added in v0.15.5

DebugProfileStop mocks base method

func (*MockTChanNode) EXPECT

EXPECT returns an object that allows the caller to indicate expected use

func (*MockTChanNode) Fetch

func (m *MockTChanNode) Fetch(ctx thrift.Context, req *FetchRequest) (*FetchResult_, error)

Fetch mocks base method

func (*MockTChanNode) FetchBatchRaw

FetchBatchRaw mocks base method

func (*MockTChanNode) FetchBatchRawV2 added in v0.14.0

FetchBatchRawV2 mocks base method

func (*MockTChanNode) FetchBlocksMetadataRawV2

FetchBlocksMetadataRawV2 mocks base method

func (*MockTChanNode) FetchBlocksRaw

FetchBlocksRaw mocks base method

func (*MockTChanNode) FetchTagged

FetchTagged mocks base method

func (*MockTChanNode) GetPersistRateLimit

func (m *MockTChanNode) GetPersistRateLimit(ctx thrift.Context) (*NodePersistRateLimitResult_, error)

GetPersistRateLimit mocks base method

func (*MockTChanNode) GetWriteNewSeriesAsync

func (m *MockTChanNode) GetWriteNewSeriesAsync(ctx thrift.Context) (*NodeWriteNewSeriesAsyncResult_, error)

GetWriteNewSeriesAsync mocks base method

func (*MockTChanNode) GetWriteNewSeriesBackoffDuration

func (m *MockTChanNode) GetWriteNewSeriesBackoffDuration(ctx thrift.Context) (*NodeWriteNewSeriesBackoffDurationResult_, error)

GetWriteNewSeriesBackoffDuration mocks base method

func (*MockTChanNode) GetWriteNewSeriesLimitPerShardPerSecond

func (m *MockTChanNode) GetWriteNewSeriesLimitPerShardPerSecond(ctx thrift.Context) (*NodeWriteNewSeriesLimitPerShardPerSecondResult_, error)

GetWriteNewSeriesLimitPerShardPerSecond mocks base method

func (*MockTChanNode) Health

func (m *MockTChanNode) Health(ctx thrift.Context) (*NodeHealthResult_, error)

Health mocks base method

func (*MockTChanNode) Query

func (m *MockTChanNode) Query(ctx thrift.Context, req *QueryRequest) (*QueryResult_, error)

Query mocks base method

func (*MockTChanNode) Repair

func (m *MockTChanNode) Repair(ctx thrift.Context) error

Repair mocks base method

func (*MockTChanNode) SetPersistRateLimit

SetPersistRateLimit mocks base method

func (*MockTChanNode) SetWriteNewSeriesAsync

SetWriteNewSeriesAsync mocks base method

func (*MockTChanNode) SetWriteNewSeriesBackoffDuration

SetWriteNewSeriesBackoffDuration mocks base method

func (*MockTChanNode) SetWriteNewSeriesLimitPerShardPerSecond

SetWriteNewSeriesLimitPerShardPerSecond mocks base method

func (*MockTChanNode) Truncate

func (m *MockTChanNode) Truncate(ctx thrift.Context, req *TruncateRequest) (*TruncateResult_, error)

Truncate mocks base method

func (*MockTChanNode) Write

func (m *MockTChanNode) Write(ctx thrift.Context, req *WriteRequest) error

Write mocks base method

func (*MockTChanNode) WriteBatchRaw

func (m *MockTChanNode) WriteBatchRaw(ctx thrift.Context, req *WriteBatchRawRequest) error

WriteBatchRaw mocks base method

func (*MockTChanNode) WriteBatchRawV2 added in v0.14.0

func (m *MockTChanNode) WriteBatchRawV2(ctx thrift.Context, req *WriteBatchRawV2Request) error

WriteBatchRawV2 mocks base method

func (*MockTChanNode) WriteTagged

func (m *MockTChanNode) WriteTagged(ctx thrift.Context, req *WriteTaggedRequest) error

WriteTagged mocks base method

func (*MockTChanNode) WriteTaggedBatchRaw

func (m *MockTChanNode) WriteTaggedBatchRaw(ctx thrift.Context, req *WriteTaggedBatchRawRequest) error

WriteTaggedBatchRaw mocks base method

func (*MockTChanNode) WriteTaggedBatchRawV2 added in v0.14.0

func (m *MockTChanNode) WriteTaggedBatchRawV2(ctx thrift.Context, req *WriteTaggedBatchRawV2Request) error

WriteTaggedBatchRawV2 mocks base method

type MockTChanNodeMockRecorder

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

MockTChanNodeMockRecorder is the mock recorder for MockTChanNode

func (*MockTChanNodeMockRecorder) Aggregate added in v0.7.3

func (mr *MockTChanNodeMockRecorder) Aggregate(ctx, req interface{}) *gomock.Call

Aggregate indicates an expected call of Aggregate

func (*MockTChanNodeMockRecorder) AggregateRaw added in v0.7.3

func (mr *MockTChanNodeMockRecorder) AggregateRaw(ctx, req interface{}) *gomock.Call

AggregateRaw indicates an expected call of AggregateRaw

func (*MockTChanNodeMockRecorder) AggregateTiles added in v0.15.14

func (mr *MockTChanNodeMockRecorder) AggregateTiles(ctx, req interface{}) *gomock.Call

AggregateTiles indicates an expected call of AggregateTiles

func (*MockTChanNodeMockRecorder) Bootstrapped added in v0.4.6

func (mr *MockTChanNodeMockRecorder) Bootstrapped(ctx interface{}) *gomock.Call

Bootstrapped indicates an expected call of Bootstrapped

func (*MockTChanNodeMockRecorder) BootstrappedInPlacementOrNoPlacement added in v0.9.0

func (mr *MockTChanNodeMockRecorder) BootstrappedInPlacementOrNoPlacement(ctx interface{}) *gomock.Call

BootstrappedInPlacementOrNoPlacement indicates an expected call of BootstrappedInPlacementOrNoPlacement

func (*MockTChanNodeMockRecorder) DebugIndexMemorySegments added in v0.15.0

func (mr *MockTChanNodeMockRecorder) DebugIndexMemorySegments(ctx, req interface{}) *gomock.Call

DebugIndexMemorySegments indicates an expected call of DebugIndexMemorySegments

func (*MockTChanNodeMockRecorder) DebugProfileStart added in v0.15.5

func (mr *MockTChanNodeMockRecorder) DebugProfileStart(ctx, req interface{}) *gomock.Call

DebugProfileStart indicates an expected call of DebugProfileStart

func (*MockTChanNodeMockRecorder) DebugProfileStop added in v0.15.5

func (mr *MockTChanNodeMockRecorder) DebugProfileStop(ctx, req interface{}) *gomock.Call

DebugProfileStop indicates an expected call of DebugProfileStop

func (*MockTChanNodeMockRecorder) Fetch

func (mr *MockTChanNodeMockRecorder) Fetch(ctx, req interface{}) *gomock.Call

Fetch indicates an expected call of Fetch

func (*MockTChanNodeMockRecorder) FetchBatchRaw

func (mr *MockTChanNodeMockRecorder) FetchBatchRaw(ctx, req interface{}) *gomock.Call

FetchBatchRaw indicates an expected call of FetchBatchRaw

func (*MockTChanNodeMockRecorder) FetchBatchRawV2 added in v0.14.0

func (mr *MockTChanNodeMockRecorder) FetchBatchRawV2(ctx, req interface{}) *gomock.Call

FetchBatchRawV2 indicates an expected call of FetchBatchRawV2

func (*MockTChanNodeMockRecorder) FetchBlocksMetadataRawV2

func (mr *MockTChanNodeMockRecorder) FetchBlocksMetadataRawV2(ctx, req interface{}) *gomock.Call

FetchBlocksMetadataRawV2 indicates an expected call of FetchBlocksMetadataRawV2

func (*MockTChanNodeMockRecorder) FetchBlocksRaw

func (mr *MockTChanNodeMockRecorder) FetchBlocksRaw(ctx, req interface{}) *gomock.Call

FetchBlocksRaw indicates an expected call of FetchBlocksRaw

func (*MockTChanNodeMockRecorder) FetchTagged

func (mr *MockTChanNodeMockRecorder) FetchTagged(ctx, req interface{}) *gomock.Call

FetchTagged indicates an expected call of FetchTagged

func (*MockTChanNodeMockRecorder) GetPersistRateLimit

func (mr *MockTChanNodeMockRecorder) GetPersistRateLimit(ctx interface{}) *gomock.Call

GetPersistRateLimit indicates an expected call of GetPersistRateLimit

func (*MockTChanNodeMockRecorder) GetWriteNewSeriesAsync

func (mr *MockTChanNodeMockRecorder) GetWriteNewSeriesAsync(ctx interface{}) *gomock.Call

GetWriteNewSeriesAsync indicates an expected call of GetWriteNewSeriesAsync

func (*MockTChanNodeMockRecorder) GetWriteNewSeriesBackoffDuration

func (mr *MockTChanNodeMockRecorder) GetWriteNewSeriesBackoffDuration(ctx interface{}) *gomock.Call

GetWriteNewSeriesBackoffDuration indicates an expected call of GetWriteNewSeriesBackoffDuration

func (*MockTChanNodeMockRecorder) GetWriteNewSeriesLimitPerShardPerSecond

func (mr *MockTChanNodeMockRecorder) GetWriteNewSeriesLimitPerShardPerSecond(ctx interface{}) *gomock.Call

GetWriteNewSeriesLimitPerShardPerSecond indicates an expected call of GetWriteNewSeriesLimitPerShardPerSecond

func (*MockTChanNodeMockRecorder) Health

func (mr *MockTChanNodeMockRecorder) Health(ctx interface{}) *gomock.Call

Health indicates an expected call of Health

func (*MockTChanNodeMockRecorder) Query

func (mr *MockTChanNodeMockRecorder) Query(ctx, req interface{}) *gomock.Call

Query indicates an expected call of Query

func (*MockTChanNodeMockRecorder) Repair

func (mr *MockTChanNodeMockRecorder) Repair(ctx interface{}) *gomock.Call

Repair indicates an expected call of Repair

func (*MockTChanNodeMockRecorder) SetPersistRateLimit

func (mr *MockTChanNodeMockRecorder) SetPersistRateLimit(ctx, req interface{}) *gomock.Call

SetPersistRateLimit indicates an expected call of SetPersistRateLimit

func (*MockTChanNodeMockRecorder) SetWriteNewSeriesAsync

func (mr *MockTChanNodeMockRecorder) SetWriteNewSeriesAsync(ctx, req interface{}) *gomock.Call

SetWriteNewSeriesAsync indicates an expected call of SetWriteNewSeriesAsync

func (*MockTChanNodeMockRecorder) SetWriteNewSeriesBackoffDuration

func (mr *MockTChanNodeMockRecorder) SetWriteNewSeriesBackoffDuration(ctx, req interface{}) *gomock.Call

SetWriteNewSeriesBackoffDuration indicates an expected call of SetWriteNewSeriesBackoffDuration

func (*MockTChanNodeMockRecorder) SetWriteNewSeriesLimitPerShardPerSecond

func (mr *MockTChanNodeMockRecorder) SetWriteNewSeriesLimitPerShardPerSecond(ctx, req interface{}) *gomock.Call

SetWriteNewSeriesLimitPerShardPerSecond indicates an expected call of SetWriteNewSeriesLimitPerShardPerSecond

func (*MockTChanNodeMockRecorder) Truncate

func (mr *MockTChanNodeMockRecorder) Truncate(ctx, req interface{}) *gomock.Call

Truncate indicates an expected call of Truncate

func (*MockTChanNodeMockRecorder) Write

func (mr *MockTChanNodeMockRecorder) Write(ctx, req interface{}) *gomock.Call

Write indicates an expected call of Write

func (*MockTChanNodeMockRecorder) WriteBatchRaw

func (mr *MockTChanNodeMockRecorder) WriteBatchRaw(ctx, req interface{}) *gomock.Call

WriteBatchRaw indicates an expected call of WriteBatchRaw

func (*MockTChanNodeMockRecorder) WriteBatchRawV2 added in v0.14.0

func (mr *MockTChanNodeMockRecorder) WriteBatchRawV2(ctx, req interface{}) *gomock.Call

WriteBatchRawV2 indicates an expected call of WriteBatchRawV2

func (*MockTChanNodeMockRecorder) WriteTagged

func (mr *MockTChanNodeMockRecorder) WriteTagged(ctx, req interface{}) *gomock.Call

WriteTagged indicates an expected call of WriteTagged

func (*MockTChanNodeMockRecorder) WriteTaggedBatchRaw

func (mr *MockTChanNodeMockRecorder) WriteTaggedBatchRaw(ctx, req interface{}) *gomock.Call

WriteTaggedBatchRaw indicates an expected call of WriteTaggedBatchRaw

func (*MockTChanNodeMockRecorder) WriteTaggedBatchRawV2 added in v0.14.0

func (mr *MockTChanNodeMockRecorder) WriteTaggedBatchRawV2(ctx, req interface{}) *gomock.Call

WriteTaggedBatchRawV2 indicates an expected call of WriteTaggedBatchRawV2

type NegationQuery

type NegationQuery struct {
	Query *Query `thrift:"query,1,required" db:"query" json:"query"`
}

Attributes:

  • Query
var Query_Negation_DEFAULT *NegationQuery

func NewNegationQuery

func NewNegationQuery() *NegationQuery

func (*NegationQuery) GetQuery

func (p *NegationQuery) GetQuery() *Query

func (*NegationQuery) IsSetQuery

func (p *NegationQuery) IsSetQuery() bool

func (*NegationQuery) Read

func (p *NegationQuery) Read(iprot thrift.TProtocol) error

func (*NegationQuery) ReadField1

func (p *NegationQuery) ReadField1(iprot thrift.TProtocol) error

func (*NegationQuery) String

func (p *NegationQuery) String() string

func (*NegationQuery) Write

func (p *NegationQuery) Write(oprot thrift.TProtocol) error

type Node

type Node interface {
	// Parameters:
	//  - Req
	Query(req *QueryRequest) (r *QueryResult_, err error)
	// Parameters:
	//  - Req
	Aggregate(req *AggregateQueryRequest) (r *AggregateQueryResult_, err error)
	// Parameters:
	//  - Req
	Fetch(req *FetchRequest) (r *FetchResult_, err error)
	// Parameters:
	//  - Req
	Write(req *WriteRequest) (err error)
	// Parameters:
	//  - Req
	WriteTagged(req *WriteTaggedRequest) (err error)
	// Parameters:
	//  - Req
	AggregateRaw(req *AggregateQueryRawRequest) (r *AggregateQueryRawResult_, err error)
	// Parameters:
	//  - Req
	FetchBatchRaw(req *FetchBatchRawRequest) (r *FetchBatchRawResult_, err error)
	// Parameters:
	//  - Req
	FetchBatchRawV2(req *FetchBatchRawV2Request) (r *FetchBatchRawResult_, err error)
	// Parameters:
	//  - Req
	FetchBlocksRaw(req *FetchBlocksRawRequest) (r *FetchBlocksRawResult_, err error)
	// Parameters:
	//  - Req
	FetchTagged(req *FetchTaggedRequest) (r *FetchTaggedResult_, err error)
	// Parameters:
	//  - Req
	FetchBlocksMetadataRawV2(req *FetchBlocksMetadataRawV2Request) (r *FetchBlocksMetadataRawV2Result_, err error)
	// Parameters:
	//  - Req
	WriteBatchRaw(req *WriteBatchRawRequest) (err error)
	// Parameters:
	//  - Req
	WriteBatchRawV2(req *WriteBatchRawV2Request) (err error)
	// Parameters:
	//  - Req
	WriteTaggedBatchRaw(req *WriteTaggedBatchRawRequest) (err error)
	// Parameters:
	//  - Req
	WriteTaggedBatchRawV2(req *WriteTaggedBatchRawV2Request) (err error)
	Repair() (err error)
	// Parameters:
	//  - Req
	Truncate(req *TruncateRequest) (r *TruncateResult_, err error)
	// Parameters:
	//  - Req
	AggregateTiles(req *AggregateTilesRequest) (r *AggregateTilesResult_, err error)
	Health() (r *NodeHealthResult_, err error)
	Bootstrapped() (r *NodeBootstrappedResult_, err error)
	BootstrappedInPlacementOrNoPlacement() (r *NodeBootstrappedInPlacementOrNoPlacementResult_, err error)
	GetPersistRateLimit() (r *NodePersistRateLimitResult_, err error)
	// Parameters:
	//  - Req
	SetPersistRateLimit(req *NodeSetPersistRateLimitRequest) (r *NodePersistRateLimitResult_, err error)
	GetWriteNewSeriesAsync() (r *NodeWriteNewSeriesAsyncResult_, err error)
	// Parameters:
	//  - Req
	SetWriteNewSeriesAsync(req *NodeSetWriteNewSeriesAsyncRequest) (r *NodeWriteNewSeriesAsyncResult_, err error)
	GetWriteNewSeriesBackoffDuration() (r *NodeWriteNewSeriesBackoffDurationResult_, err error)
	// Parameters:
	//  - Req
	SetWriteNewSeriesBackoffDuration(req *NodeSetWriteNewSeriesBackoffDurationRequest) (r *NodeWriteNewSeriesBackoffDurationResult_, err error)
	GetWriteNewSeriesLimitPerShardPerSecond() (r *NodeWriteNewSeriesLimitPerShardPerSecondResult_, err error)
	// Parameters:
	//  - Req
	SetWriteNewSeriesLimitPerShardPerSecond(req *NodeSetWriteNewSeriesLimitPerShardPerSecondRequest) (r *NodeWriteNewSeriesLimitPerShardPerSecondResult_, err error)
	// Parameters:
	//  - Req
	DebugProfileStart(req *DebugProfileStartRequest) (r *DebugProfileStartResult_, err error)
	// Parameters:
	//  - Req
	DebugProfileStop(req *DebugProfileStopRequest) (r *DebugProfileStopResult_, err error)
	// Parameters:
	//  - Req
	DebugIndexMemorySegments(req *DebugIndexMemorySegmentsRequest) (r *DebugIndexMemorySegmentsResult_, err error)
}

type NodeAggregateArgs added in v0.7.3

type NodeAggregateArgs struct {
	Req *AggregateQueryRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeAggregateArgs added in v0.7.3

func NewNodeAggregateArgs() *NodeAggregateArgs

func (*NodeAggregateArgs) GetReq added in v0.7.3

func (*NodeAggregateArgs) IsSetReq added in v0.7.3

func (p *NodeAggregateArgs) IsSetReq() bool

func (*NodeAggregateArgs) Read added in v0.7.3

func (p *NodeAggregateArgs) Read(iprot thrift.TProtocol) error

func (*NodeAggregateArgs) ReadField1 added in v0.7.3

func (p *NodeAggregateArgs) ReadField1(iprot thrift.TProtocol) error

func (*NodeAggregateArgs) String added in v0.7.3

func (p *NodeAggregateArgs) String() string

func (*NodeAggregateArgs) Write added in v0.7.3

func (p *NodeAggregateArgs) Write(oprot thrift.TProtocol) error

type NodeAggregateRawArgs added in v0.7.3

type NodeAggregateRawArgs struct {
	Req *AggregateQueryRawRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeAggregateRawArgs added in v0.7.3

func NewNodeAggregateRawArgs() *NodeAggregateRawArgs

func (*NodeAggregateRawArgs) GetReq added in v0.7.3

func (*NodeAggregateRawArgs) IsSetReq added in v0.7.3

func (p *NodeAggregateRawArgs) IsSetReq() bool

func (*NodeAggregateRawArgs) Read added in v0.7.3

func (p *NodeAggregateRawArgs) Read(iprot thrift.TProtocol) error

func (*NodeAggregateRawArgs) ReadField1 added in v0.7.3

func (p *NodeAggregateRawArgs) ReadField1(iprot thrift.TProtocol) error

func (*NodeAggregateRawArgs) String added in v0.7.3

func (p *NodeAggregateRawArgs) String() string

func (*NodeAggregateRawArgs) Write added in v0.7.3

func (p *NodeAggregateRawArgs) Write(oprot thrift.TProtocol) error

type NodeAggregateRawResult added in v0.7.3

type NodeAggregateRawResult struct {
	Success *AggregateQueryRawResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                    `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeAggregateRawResult added in v0.7.3

func NewNodeAggregateRawResult() *NodeAggregateRawResult

func (*NodeAggregateRawResult) GetErr added in v0.7.3

func (p *NodeAggregateRawResult) GetErr() *Error

func (*NodeAggregateRawResult) GetSuccess added in v0.7.3

func (*NodeAggregateRawResult) IsSetErr added in v0.7.3

func (p *NodeAggregateRawResult) IsSetErr() bool

func (*NodeAggregateRawResult) IsSetSuccess added in v0.7.3

func (p *NodeAggregateRawResult) IsSetSuccess() bool

func (*NodeAggregateRawResult) Read added in v0.7.3

func (*NodeAggregateRawResult) ReadField0 added in v0.7.3

func (p *NodeAggregateRawResult) ReadField0(iprot thrift.TProtocol) error

func (*NodeAggregateRawResult) ReadField1 added in v0.7.3

func (p *NodeAggregateRawResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeAggregateRawResult) String added in v0.7.3

func (p *NodeAggregateRawResult) String() string

func (*NodeAggregateRawResult) Write added in v0.7.3

func (p *NodeAggregateRawResult) Write(oprot thrift.TProtocol) error

type NodeAggregateResult added in v0.7.3

type NodeAggregateResult struct {
	Success *AggregateQueryResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                 `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeAggregateResult added in v0.7.3

func NewNodeAggregateResult() *NodeAggregateResult

func (*NodeAggregateResult) GetErr added in v0.7.3

func (p *NodeAggregateResult) GetErr() *Error

func (*NodeAggregateResult) GetSuccess added in v0.7.3

func (p *NodeAggregateResult) GetSuccess() *AggregateQueryResult_

func (*NodeAggregateResult) IsSetErr added in v0.7.3

func (p *NodeAggregateResult) IsSetErr() bool

func (*NodeAggregateResult) IsSetSuccess added in v0.7.3

func (p *NodeAggregateResult) IsSetSuccess() bool

func (*NodeAggregateResult) Read added in v0.7.3

func (p *NodeAggregateResult) Read(iprot thrift.TProtocol) error

func (*NodeAggregateResult) ReadField0 added in v0.7.3

func (p *NodeAggregateResult) ReadField0(iprot thrift.TProtocol) error

func (*NodeAggregateResult) ReadField1 added in v0.7.3

func (p *NodeAggregateResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeAggregateResult) String added in v0.7.3

func (p *NodeAggregateResult) String() string

func (*NodeAggregateResult) Write added in v0.7.3

func (p *NodeAggregateResult) Write(oprot thrift.TProtocol) error

type NodeAggregateTilesArgs added in v0.15.14

type NodeAggregateTilesArgs struct {
	Req *AggregateTilesRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeAggregateTilesArgs added in v0.15.14

func NewNodeAggregateTilesArgs() *NodeAggregateTilesArgs

func (*NodeAggregateTilesArgs) GetReq added in v0.15.14

func (*NodeAggregateTilesArgs) IsSetReq added in v0.15.14

func (p *NodeAggregateTilesArgs) IsSetReq() bool

func (*NodeAggregateTilesArgs) Read added in v0.15.14

func (*NodeAggregateTilesArgs) ReadField1 added in v0.15.14

func (p *NodeAggregateTilesArgs) ReadField1(iprot thrift.TProtocol) error

func (*NodeAggregateTilesArgs) String added in v0.15.14

func (p *NodeAggregateTilesArgs) String() string

func (*NodeAggregateTilesArgs) Write added in v0.15.14

func (p *NodeAggregateTilesArgs) Write(oprot thrift.TProtocol) error

type NodeAggregateTilesResult added in v0.15.14

type NodeAggregateTilesResult struct {
	Success *AggregateTilesResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                 `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeAggregateTilesResult added in v0.15.14

func NewNodeAggregateTilesResult() *NodeAggregateTilesResult

func (*NodeAggregateTilesResult) GetErr added in v0.15.14

func (p *NodeAggregateTilesResult) GetErr() *Error

func (*NodeAggregateTilesResult) GetSuccess added in v0.15.14

func (*NodeAggregateTilesResult) IsSetErr added in v0.15.14

func (p *NodeAggregateTilesResult) IsSetErr() bool

func (*NodeAggregateTilesResult) IsSetSuccess added in v0.15.14

func (p *NodeAggregateTilesResult) IsSetSuccess() bool

func (*NodeAggregateTilesResult) Read added in v0.15.14

func (*NodeAggregateTilesResult) ReadField0 added in v0.15.14

func (p *NodeAggregateTilesResult) ReadField0(iprot thrift.TProtocol) error

func (*NodeAggregateTilesResult) ReadField1 added in v0.15.14

func (p *NodeAggregateTilesResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeAggregateTilesResult) String added in v0.15.14

func (p *NodeAggregateTilesResult) String() string

func (*NodeAggregateTilesResult) Write added in v0.15.14

type NodeBootstrappedArgs added in v0.4.6

type NodeBootstrappedArgs struct {
}

func NewNodeBootstrappedArgs added in v0.4.6

func NewNodeBootstrappedArgs() *NodeBootstrappedArgs

func (*NodeBootstrappedArgs) Read added in v0.4.6

func (p *NodeBootstrappedArgs) Read(iprot thrift.TProtocol) error

func (*NodeBootstrappedArgs) String added in v0.4.6

func (p *NodeBootstrappedArgs) String() string

func (*NodeBootstrappedArgs) Write added in v0.4.6

func (p *NodeBootstrappedArgs) Write(oprot thrift.TProtocol) error

type NodeBootstrappedInPlacementOrNoPlacementArgs added in v0.9.0

type NodeBootstrappedInPlacementOrNoPlacementArgs struct {
}

func NewNodeBootstrappedInPlacementOrNoPlacementArgs added in v0.9.0

func NewNodeBootstrappedInPlacementOrNoPlacementArgs() *NodeBootstrappedInPlacementOrNoPlacementArgs

func (*NodeBootstrappedInPlacementOrNoPlacementArgs) Read added in v0.9.0

func (*NodeBootstrappedInPlacementOrNoPlacementArgs) String added in v0.9.0

func (*NodeBootstrappedInPlacementOrNoPlacementArgs) Write added in v0.9.0

type NodeBootstrappedInPlacementOrNoPlacementResult added in v0.9.0

type NodeBootstrappedInPlacementOrNoPlacementResult struct {
	Success *NodeBootstrappedInPlacementOrNoPlacementResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                                           `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeBootstrappedInPlacementOrNoPlacementResult added in v0.9.0

func NewNodeBootstrappedInPlacementOrNoPlacementResult() *NodeBootstrappedInPlacementOrNoPlacementResult

func (*NodeBootstrappedInPlacementOrNoPlacementResult) GetErr added in v0.9.0

func (*NodeBootstrappedInPlacementOrNoPlacementResult) GetSuccess added in v0.9.0

func (*NodeBootstrappedInPlacementOrNoPlacementResult) IsSetErr added in v0.9.0

func (*NodeBootstrappedInPlacementOrNoPlacementResult) IsSetSuccess added in v0.9.0

func (*NodeBootstrappedInPlacementOrNoPlacementResult) Read added in v0.9.0

func (*NodeBootstrappedInPlacementOrNoPlacementResult) ReadField0 added in v0.9.0

func (*NodeBootstrappedInPlacementOrNoPlacementResult) ReadField1 added in v0.9.0

func (*NodeBootstrappedInPlacementOrNoPlacementResult) String added in v0.9.0

func (*NodeBootstrappedInPlacementOrNoPlacementResult) Write added in v0.9.0

type NodeBootstrappedInPlacementOrNoPlacementResult_ added in v0.9.0

type NodeBootstrappedInPlacementOrNoPlacementResult_ struct {
}
var NodeBootstrappedInPlacementOrNoPlacementResult_Success_DEFAULT *NodeBootstrappedInPlacementOrNoPlacementResult_

func NewNodeBootstrappedInPlacementOrNoPlacementResult_ added in v0.9.0

func NewNodeBootstrappedInPlacementOrNoPlacementResult_() *NodeBootstrappedInPlacementOrNoPlacementResult_

func (*NodeBootstrappedInPlacementOrNoPlacementResult_) Read added in v0.9.0

func (*NodeBootstrappedInPlacementOrNoPlacementResult_) String added in v0.9.0

func (*NodeBootstrappedInPlacementOrNoPlacementResult_) Write added in v0.9.0

type NodeBootstrappedResult added in v0.4.6

type NodeBootstrappedResult struct {
	Success *NodeBootstrappedResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                   `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeBootstrappedResult added in v0.4.6

func NewNodeBootstrappedResult() *NodeBootstrappedResult

func (*NodeBootstrappedResult) GetErr added in v0.4.6

func (p *NodeBootstrappedResult) GetErr() *Error

func (*NodeBootstrappedResult) GetSuccess added in v0.4.6

func (*NodeBootstrappedResult) IsSetErr added in v0.4.6

func (p *NodeBootstrappedResult) IsSetErr() bool

func (*NodeBootstrappedResult) IsSetSuccess added in v0.4.6

func (p *NodeBootstrappedResult) IsSetSuccess() bool

func (*NodeBootstrappedResult) Read added in v0.4.6

func (*NodeBootstrappedResult) ReadField0 added in v0.4.6

func (p *NodeBootstrappedResult) ReadField0(iprot thrift.TProtocol) error

func (*NodeBootstrappedResult) ReadField1 added in v0.4.6

func (p *NodeBootstrappedResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeBootstrappedResult) String added in v0.4.6

func (p *NodeBootstrappedResult) String() string

func (*NodeBootstrappedResult) Write added in v0.4.6

func (p *NodeBootstrappedResult) Write(oprot thrift.TProtocol) error

type NodeBootstrappedResult_ added in v0.4.6

type NodeBootstrappedResult_ struct {
}
var NodeBootstrappedResult_Success_DEFAULT *NodeBootstrappedResult_

func NewNodeBootstrappedResult_ added in v0.4.6

func NewNodeBootstrappedResult_() *NodeBootstrappedResult_

func (*NodeBootstrappedResult_) Read added in v0.4.6

func (*NodeBootstrappedResult_) String added in v0.4.6

func (p *NodeBootstrappedResult_) String() string

func (*NodeBootstrappedResult_) Write added in v0.4.6

type NodeClient

type NodeClient struct {
	Transport       thrift.TTransport
	ProtocolFactory thrift.TProtocolFactory
	InputProtocol   thrift.TProtocol
	OutputProtocol  thrift.TProtocol
	SeqId           int32
}

func NewNodeClientProtocol

func NewNodeClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *NodeClient

func (*NodeClient) Aggregate added in v0.7.3

func (p *NodeClient) Aggregate(req *AggregateQueryRequest) (r *AggregateQueryResult_, err error)

Parameters:

  • Req

func (*NodeClient) AggregateRaw added in v0.7.3

func (p *NodeClient) AggregateRaw(req *AggregateQueryRawRequest) (r *AggregateQueryRawResult_, err error)

Parameters:

  • Req

func (*NodeClient) AggregateTiles added in v0.15.14

func (p *NodeClient) AggregateTiles(req *AggregateTilesRequest) (r *AggregateTilesResult_, err error)

Parameters:

  • Req

func (*NodeClient) Bootstrapped added in v0.4.6

func (p *NodeClient) Bootstrapped() (r *NodeBootstrappedResult_, err error)

func (*NodeClient) BootstrappedInPlacementOrNoPlacement added in v0.9.0

func (p *NodeClient) BootstrappedInPlacementOrNoPlacement() (r *NodeBootstrappedInPlacementOrNoPlacementResult_, err error)

func (*NodeClient) DebugIndexMemorySegments added in v0.15.0

func (p *NodeClient) DebugIndexMemorySegments(req *DebugIndexMemorySegmentsRequest) (r *DebugIndexMemorySegmentsResult_, err error)

Parameters:

  • Req

func (*NodeClient) DebugProfileStart added in v0.15.5

func (p *NodeClient) DebugProfileStart(req *DebugProfileStartRequest) (r *DebugProfileStartResult_, err error)

Parameters:

  • Req

func (*NodeClient) DebugProfileStop added in v0.15.5

func (p *NodeClient) DebugProfileStop(req *DebugProfileStopRequest) (r *DebugProfileStopResult_, err error)

Parameters:

  • Req

func (*NodeClient) Fetch

func (p *NodeClient) Fetch(req *FetchRequest) (r *FetchResult_, err error)

Parameters:

  • Req

func (*NodeClient) FetchBatchRaw

func (p *NodeClient) FetchBatchRaw(req *FetchBatchRawRequest) (r *FetchBatchRawResult_, err error)

Parameters:

  • Req

func (*NodeClient) FetchBatchRawV2 added in v0.14.0

func (p *NodeClient) FetchBatchRawV2(req *FetchBatchRawV2Request) (r *FetchBatchRawResult_, err error)

Parameters:

  • Req

func (*NodeClient) FetchBlocksMetadataRawV2

func (p *NodeClient) FetchBlocksMetadataRawV2(req *FetchBlocksMetadataRawV2Request) (r *FetchBlocksMetadataRawV2Result_, err error)

Parameters:

  • Req

func (*NodeClient) FetchBlocksRaw

func (p *NodeClient) FetchBlocksRaw(req *FetchBlocksRawRequest) (r *FetchBlocksRawResult_, err error)

Parameters:

  • Req

func (*NodeClient) FetchTagged

func (p *NodeClient) FetchTagged(req *FetchTaggedRequest) (r *FetchTaggedResult_, err error)

Parameters:

  • Req

func (*NodeClient) GetPersistRateLimit

func (p *NodeClient) GetPersistRateLimit() (r *NodePersistRateLimitResult_, err error)

func (*NodeClient) GetWriteNewSeriesAsync

func (p *NodeClient) GetWriteNewSeriesAsync() (r *NodeWriteNewSeriesAsyncResult_, err error)

func (*NodeClient) GetWriteNewSeriesBackoffDuration

func (p *NodeClient) GetWriteNewSeriesBackoffDuration() (r *NodeWriteNewSeriesBackoffDurationResult_, err error)

func (*NodeClient) GetWriteNewSeriesLimitPerShardPerSecond

func (p *NodeClient) GetWriteNewSeriesLimitPerShardPerSecond() (r *NodeWriteNewSeriesLimitPerShardPerSecondResult_, err error)

func (*NodeClient) Health

func (p *NodeClient) Health() (r *NodeHealthResult_, err error)

func (*NodeClient) Query

func (p *NodeClient) Query(req *QueryRequest) (r *QueryResult_, err error)

Parameters:

  • Req

func (*NodeClient) Repair

func (p *NodeClient) Repair() (err error)

func (*NodeClient) SetPersistRateLimit

func (p *NodeClient) SetPersistRateLimit(req *NodeSetPersistRateLimitRequest) (r *NodePersistRateLimitResult_, err error)

Parameters:

  • Req

func (*NodeClient) SetWriteNewSeriesAsync

func (p *NodeClient) SetWriteNewSeriesAsync(req *NodeSetWriteNewSeriesAsyncRequest) (r *NodeWriteNewSeriesAsyncResult_, err error)

Parameters:

  • Req

func (*NodeClient) SetWriteNewSeriesBackoffDuration

Parameters:

  • Req

func (*NodeClient) SetWriteNewSeriesLimitPerShardPerSecond

Parameters:

  • Req

func (*NodeClient) Truncate

func (p *NodeClient) Truncate(req *TruncateRequest) (r *TruncateResult_, err error)

Parameters:

  • Req

func (*NodeClient) Write

func (p *NodeClient) Write(req *WriteRequest) (err error)

Parameters:

  • Req

func (*NodeClient) WriteBatchRaw

func (p *NodeClient) WriteBatchRaw(req *WriteBatchRawRequest) (err error)

Parameters:

  • Req

func (*NodeClient) WriteBatchRawV2 added in v0.14.0

func (p *NodeClient) WriteBatchRawV2(req *WriteBatchRawV2Request) (err error)

Parameters:

  • Req

func (*NodeClient) WriteTagged

func (p *NodeClient) WriteTagged(req *WriteTaggedRequest) (err error)

Parameters:

  • Req

func (*NodeClient) WriteTaggedBatchRaw

func (p *NodeClient) WriteTaggedBatchRaw(req *WriteTaggedBatchRawRequest) (err error)

Parameters:

  • Req

func (*NodeClient) WriteTaggedBatchRawV2 added in v0.14.0

func (p *NodeClient) WriteTaggedBatchRawV2(req *WriteTaggedBatchRawV2Request) (err error)

Parameters:

  • Req

type NodeDebugIndexMemorySegmentsArgs added in v0.15.0

type NodeDebugIndexMemorySegmentsArgs struct {
	Req *DebugIndexMemorySegmentsRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeDebugIndexMemorySegmentsArgs added in v0.15.0

func NewNodeDebugIndexMemorySegmentsArgs() *NodeDebugIndexMemorySegmentsArgs

func (*NodeDebugIndexMemorySegmentsArgs) GetReq added in v0.15.0

func (*NodeDebugIndexMemorySegmentsArgs) IsSetReq added in v0.15.0

func (p *NodeDebugIndexMemorySegmentsArgs) IsSetReq() bool

func (*NodeDebugIndexMemorySegmentsArgs) Read added in v0.15.0

func (*NodeDebugIndexMemorySegmentsArgs) ReadField1 added in v0.15.0

func (*NodeDebugIndexMemorySegmentsArgs) String added in v0.15.0

func (*NodeDebugIndexMemorySegmentsArgs) Write added in v0.15.0

type NodeDebugIndexMemorySegmentsResult added in v0.15.0

type NodeDebugIndexMemorySegmentsResult struct {
	Success *DebugIndexMemorySegmentsResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                           `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeDebugIndexMemorySegmentsResult added in v0.15.0

func NewNodeDebugIndexMemorySegmentsResult() *NodeDebugIndexMemorySegmentsResult

func (*NodeDebugIndexMemorySegmentsResult) GetErr added in v0.15.0

func (*NodeDebugIndexMemorySegmentsResult) GetSuccess added in v0.15.0

func (*NodeDebugIndexMemorySegmentsResult) IsSetErr added in v0.15.0

func (*NodeDebugIndexMemorySegmentsResult) IsSetSuccess added in v0.15.0

func (p *NodeDebugIndexMemorySegmentsResult) IsSetSuccess() bool

func (*NodeDebugIndexMemorySegmentsResult) Read added in v0.15.0

func (*NodeDebugIndexMemorySegmentsResult) ReadField0 added in v0.15.0

func (*NodeDebugIndexMemorySegmentsResult) ReadField1 added in v0.15.0

func (*NodeDebugIndexMemorySegmentsResult) String added in v0.15.0

func (*NodeDebugIndexMemorySegmentsResult) Write added in v0.15.0

type NodeDebugProfileStartArgs added in v0.15.5

type NodeDebugProfileStartArgs struct {
	Req *DebugProfileStartRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeDebugProfileStartArgs added in v0.15.5

func NewNodeDebugProfileStartArgs() *NodeDebugProfileStartArgs

func (*NodeDebugProfileStartArgs) GetReq added in v0.15.5

func (*NodeDebugProfileStartArgs) IsSetReq added in v0.15.5

func (p *NodeDebugProfileStartArgs) IsSetReq() bool

func (*NodeDebugProfileStartArgs) Read added in v0.15.5

func (*NodeDebugProfileStartArgs) ReadField1 added in v0.15.5

func (p *NodeDebugProfileStartArgs) ReadField1(iprot thrift.TProtocol) error

func (*NodeDebugProfileStartArgs) String added in v0.15.5

func (p *NodeDebugProfileStartArgs) String() string

func (*NodeDebugProfileStartArgs) Write added in v0.15.5

type NodeDebugProfileStartResult added in v0.15.5

type NodeDebugProfileStartResult struct {
	Success *DebugProfileStartResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                    `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeDebugProfileStartResult added in v0.15.5

func NewNodeDebugProfileStartResult() *NodeDebugProfileStartResult

func (*NodeDebugProfileStartResult) GetErr added in v0.15.5

func (p *NodeDebugProfileStartResult) GetErr() *Error

func (*NodeDebugProfileStartResult) GetSuccess added in v0.15.5

func (*NodeDebugProfileStartResult) IsSetErr added in v0.15.5

func (p *NodeDebugProfileStartResult) IsSetErr() bool

func (*NodeDebugProfileStartResult) IsSetSuccess added in v0.15.5

func (p *NodeDebugProfileStartResult) IsSetSuccess() bool

func (*NodeDebugProfileStartResult) Read added in v0.15.5

func (*NodeDebugProfileStartResult) ReadField0 added in v0.15.5

func (p *NodeDebugProfileStartResult) ReadField0(iprot thrift.TProtocol) error

func (*NodeDebugProfileStartResult) ReadField1 added in v0.15.5

func (p *NodeDebugProfileStartResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeDebugProfileStartResult) String added in v0.15.5

func (p *NodeDebugProfileStartResult) String() string

func (*NodeDebugProfileStartResult) Write added in v0.15.5

type NodeDebugProfileStopArgs added in v0.15.5

type NodeDebugProfileStopArgs struct {
	Req *DebugProfileStopRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeDebugProfileStopArgs added in v0.15.5

func NewNodeDebugProfileStopArgs() *NodeDebugProfileStopArgs

func (*NodeDebugProfileStopArgs) GetReq added in v0.15.5

func (*NodeDebugProfileStopArgs) IsSetReq added in v0.15.5

func (p *NodeDebugProfileStopArgs) IsSetReq() bool

func (*NodeDebugProfileStopArgs) Read added in v0.15.5

func (*NodeDebugProfileStopArgs) ReadField1 added in v0.15.5

func (p *NodeDebugProfileStopArgs) ReadField1(iprot thrift.TProtocol) error

func (*NodeDebugProfileStopArgs) String added in v0.15.5

func (p *NodeDebugProfileStopArgs) String() string

func (*NodeDebugProfileStopArgs) Write added in v0.15.5

type NodeDebugProfileStopResult added in v0.15.5

type NodeDebugProfileStopResult struct {
	Success *DebugProfileStopResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                   `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeDebugProfileStopResult added in v0.15.5

func NewNodeDebugProfileStopResult() *NodeDebugProfileStopResult

func (*NodeDebugProfileStopResult) GetErr added in v0.15.5

func (p *NodeDebugProfileStopResult) GetErr() *Error

func (*NodeDebugProfileStopResult) GetSuccess added in v0.15.5

func (*NodeDebugProfileStopResult) IsSetErr added in v0.15.5

func (p *NodeDebugProfileStopResult) IsSetErr() bool

func (*NodeDebugProfileStopResult) IsSetSuccess added in v0.15.5

func (p *NodeDebugProfileStopResult) IsSetSuccess() bool

func (*NodeDebugProfileStopResult) Read added in v0.15.5

func (*NodeDebugProfileStopResult) ReadField0 added in v0.15.5

func (p *NodeDebugProfileStopResult) ReadField0(iprot thrift.TProtocol) error

func (*NodeDebugProfileStopResult) ReadField1 added in v0.15.5

func (p *NodeDebugProfileStopResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeDebugProfileStopResult) String added in v0.15.5

func (p *NodeDebugProfileStopResult) String() string

func (*NodeDebugProfileStopResult) Write added in v0.15.5

type NodeFetchArgs

type NodeFetchArgs struct {
	Req *FetchRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeFetchArgs

func NewNodeFetchArgs() *NodeFetchArgs

func (*NodeFetchArgs) GetReq

func (p *NodeFetchArgs) GetReq() *FetchRequest

func (*NodeFetchArgs) IsSetReq

func (p *NodeFetchArgs) IsSetReq() bool

func (*NodeFetchArgs) Read

func (p *NodeFetchArgs) Read(iprot thrift.TProtocol) error

func (*NodeFetchArgs) ReadField1

func (p *NodeFetchArgs) ReadField1(iprot thrift.TProtocol) error

func (*NodeFetchArgs) String

func (p *NodeFetchArgs) String() string

func (*NodeFetchArgs) Write

func (p *NodeFetchArgs) Write(oprot thrift.TProtocol) error

type NodeFetchBatchRawArgs

type NodeFetchBatchRawArgs struct {
	Req *FetchBatchRawRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeFetchBatchRawArgs

func NewNodeFetchBatchRawArgs() *NodeFetchBatchRawArgs

func (*NodeFetchBatchRawArgs) GetReq

func (*NodeFetchBatchRawArgs) IsSetReq

func (p *NodeFetchBatchRawArgs) IsSetReq() bool

func (*NodeFetchBatchRawArgs) Read

func (*NodeFetchBatchRawArgs) ReadField1

func (p *NodeFetchBatchRawArgs) ReadField1(iprot thrift.TProtocol) error

func (*NodeFetchBatchRawArgs) String

func (p *NodeFetchBatchRawArgs) String() string

func (*NodeFetchBatchRawArgs) Write

func (p *NodeFetchBatchRawArgs) Write(oprot thrift.TProtocol) error

type NodeFetchBatchRawResult

type NodeFetchBatchRawResult struct {
	Success *FetchBatchRawResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeFetchBatchRawResult

func NewNodeFetchBatchRawResult() *NodeFetchBatchRawResult

func (*NodeFetchBatchRawResult) GetErr

func (p *NodeFetchBatchRawResult) GetErr() *Error

func (*NodeFetchBatchRawResult) GetSuccess

func (*NodeFetchBatchRawResult) IsSetErr

func (p *NodeFetchBatchRawResult) IsSetErr() bool

func (*NodeFetchBatchRawResult) IsSetSuccess

func (p *NodeFetchBatchRawResult) IsSetSuccess() bool

func (*NodeFetchBatchRawResult) Read

func (*NodeFetchBatchRawResult) ReadField0

func (p *NodeFetchBatchRawResult) ReadField0(iprot thrift.TProtocol) error

func (*NodeFetchBatchRawResult) ReadField1

func (p *NodeFetchBatchRawResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeFetchBatchRawResult) String

func (p *NodeFetchBatchRawResult) String() string

func (*NodeFetchBatchRawResult) Write

type NodeFetchBatchRawV2Args added in v0.14.0

type NodeFetchBatchRawV2Args struct {
	Req *FetchBatchRawV2Request `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeFetchBatchRawV2Args added in v0.14.0

func NewNodeFetchBatchRawV2Args() *NodeFetchBatchRawV2Args

func (*NodeFetchBatchRawV2Args) GetReq added in v0.14.0

func (*NodeFetchBatchRawV2Args) IsSetReq added in v0.14.0

func (p *NodeFetchBatchRawV2Args) IsSetReq() bool

func (*NodeFetchBatchRawV2Args) Read added in v0.14.0

func (*NodeFetchBatchRawV2Args) ReadField1 added in v0.14.0

func (p *NodeFetchBatchRawV2Args) ReadField1(iprot thrift.TProtocol) error

func (*NodeFetchBatchRawV2Args) String added in v0.14.0

func (p *NodeFetchBatchRawV2Args) String() string

func (*NodeFetchBatchRawV2Args) Write added in v0.14.0

type NodeFetchBatchRawV2Result added in v0.14.0

type NodeFetchBatchRawV2Result struct {
	Success *FetchBatchRawResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeFetchBatchRawV2Result added in v0.14.0

func NewNodeFetchBatchRawV2Result() *NodeFetchBatchRawV2Result

func (*NodeFetchBatchRawV2Result) GetErr added in v0.14.0

func (p *NodeFetchBatchRawV2Result) GetErr() *Error

func (*NodeFetchBatchRawV2Result) GetSuccess added in v0.14.0

func (*NodeFetchBatchRawV2Result) IsSetErr added in v0.14.0

func (p *NodeFetchBatchRawV2Result) IsSetErr() bool

func (*NodeFetchBatchRawV2Result) IsSetSuccess added in v0.14.0

func (p *NodeFetchBatchRawV2Result) IsSetSuccess() bool

func (*NodeFetchBatchRawV2Result) Read added in v0.14.0

func (*NodeFetchBatchRawV2Result) ReadField0 added in v0.14.0

func (p *NodeFetchBatchRawV2Result) ReadField0(iprot thrift.TProtocol) error

func (*NodeFetchBatchRawV2Result) ReadField1 added in v0.14.0

func (p *NodeFetchBatchRawV2Result) ReadField1(iprot thrift.TProtocol) error

func (*NodeFetchBatchRawV2Result) String added in v0.14.0

func (p *NodeFetchBatchRawV2Result) String() string

func (*NodeFetchBatchRawV2Result) Write added in v0.14.0

type NodeFetchBlocksMetadataRawV2Args

type NodeFetchBlocksMetadataRawV2Args struct {
	Req *FetchBlocksMetadataRawV2Request `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeFetchBlocksMetadataRawV2Args

func NewNodeFetchBlocksMetadataRawV2Args() *NodeFetchBlocksMetadataRawV2Args

func (*NodeFetchBlocksMetadataRawV2Args) GetReq

func (*NodeFetchBlocksMetadataRawV2Args) IsSetReq

func (p *NodeFetchBlocksMetadataRawV2Args) IsSetReq() bool

func (*NodeFetchBlocksMetadataRawV2Args) Read

func (*NodeFetchBlocksMetadataRawV2Args) ReadField1

func (*NodeFetchBlocksMetadataRawV2Args) String

func (*NodeFetchBlocksMetadataRawV2Args) Write

type NodeFetchBlocksMetadataRawV2Result

type NodeFetchBlocksMetadataRawV2Result struct {
	Success *FetchBlocksMetadataRawV2Result_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                           `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeFetchBlocksMetadataRawV2Result

func NewNodeFetchBlocksMetadataRawV2Result() *NodeFetchBlocksMetadataRawV2Result

func (*NodeFetchBlocksMetadataRawV2Result) GetErr

func (*NodeFetchBlocksMetadataRawV2Result) GetSuccess

func (*NodeFetchBlocksMetadataRawV2Result) IsSetErr

func (*NodeFetchBlocksMetadataRawV2Result) IsSetSuccess

func (p *NodeFetchBlocksMetadataRawV2Result) IsSetSuccess() bool

func (*NodeFetchBlocksMetadataRawV2Result) Read

func (*NodeFetchBlocksMetadataRawV2Result) ReadField0

func (*NodeFetchBlocksMetadataRawV2Result) ReadField1

func (*NodeFetchBlocksMetadataRawV2Result) String

func (*NodeFetchBlocksMetadataRawV2Result) Write

type NodeFetchBlocksRawArgs

type NodeFetchBlocksRawArgs struct {
	Req *FetchBlocksRawRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeFetchBlocksRawArgs

func NewNodeFetchBlocksRawArgs() *NodeFetchBlocksRawArgs

func (*NodeFetchBlocksRawArgs) GetReq

func (*NodeFetchBlocksRawArgs) IsSetReq

func (p *NodeFetchBlocksRawArgs) IsSetReq() bool

func (*NodeFetchBlocksRawArgs) Read

func (*NodeFetchBlocksRawArgs) ReadField1

func (p *NodeFetchBlocksRawArgs) ReadField1(iprot thrift.TProtocol) error

func (*NodeFetchBlocksRawArgs) String

func (p *NodeFetchBlocksRawArgs) String() string

func (*NodeFetchBlocksRawArgs) Write

func (p *NodeFetchBlocksRawArgs) Write(oprot thrift.TProtocol) error

type NodeFetchBlocksRawResult

type NodeFetchBlocksRawResult struct {
	Success *FetchBlocksRawResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                 `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeFetchBlocksRawResult

func NewNodeFetchBlocksRawResult() *NodeFetchBlocksRawResult

func (*NodeFetchBlocksRawResult) GetErr

func (p *NodeFetchBlocksRawResult) GetErr() *Error

func (*NodeFetchBlocksRawResult) GetSuccess

func (*NodeFetchBlocksRawResult) IsSetErr

func (p *NodeFetchBlocksRawResult) IsSetErr() bool

func (*NodeFetchBlocksRawResult) IsSetSuccess

func (p *NodeFetchBlocksRawResult) IsSetSuccess() bool

func (*NodeFetchBlocksRawResult) Read

func (*NodeFetchBlocksRawResult) ReadField0

func (p *NodeFetchBlocksRawResult) ReadField0(iprot thrift.TProtocol) error

func (*NodeFetchBlocksRawResult) ReadField1

func (p *NodeFetchBlocksRawResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeFetchBlocksRawResult) String

func (p *NodeFetchBlocksRawResult) String() string

func (*NodeFetchBlocksRawResult) Write

type NodeFetchResult

type NodeFetchResult struct {
	Success *FetchResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error        `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeFetchResult

func NewNodeFetchResult() *NodeFetchResult

func (*NodeFetchResult) GetErr

func (p *NodeFetchResult) GetErr() *Error

func (*NodeFetchResult) GetSuccess

func (p *NodeFetchResult) GetSuccess() *FetchResult_

func (*NodeFetchResult) IsSetErr

func (p *NodeFetchResult) IsSetErr() bool

func (*NodeFetchResult) IsSetSuccess

func (p *NodeFetchResult) IsSetSuccess() bool

func (*NodeFetchResult) Read

func (p *NodeFetchResult) Read(iprot thrift.TProtocol) error

func (*NodeFetchResult) ReadField0

func (p *NodeFetchResult) ReadField0(iprot thrift.TProtocol) error

func (*NodeFetchResult) ReadField1

func (p *NodeFetchResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeFetchResult) String

func (p *NodeFetchResult) String() string

func (*NodeFetchResult) Write

func (p *NodeFetchResult) Write(oprot thrift.TProtocol) error

type NodeFetchTaggedArgs

type NodeFetchTaggedArgs struct {
	Req *FetchTaggedRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeFetchTaggedArgs

func NewNodeFetchTaggedArgs() *NodeFetchTaggedArgs

func (*NodeFetchTaggedArgs) GetReq

func (*NodeFetchTaggedArgs) IsSetReq

func (p *NodeFetchTaggedArgs) IsSetReq() bool

func (*NodeFetchTaggedArgs) Read

func (p *NodeFetchTaggedArgs) Read(iprot thrift.TProtocol) error

func (*NodeFetchTaggedArgs) ReadField1

func (p *NodeFetchTaggedArgs) ReadField1(iprot thrift.TProtocol) error

func (*NodeFetchTaggedArgs) String

func (p *NodeFetchTaggedArgs) String() string

func (*NodeFetchTaggedArgs) Write

func (p *NodeFetchTaggedArgs) Write(oprot thrift.TProtocol) error

type NodeFetchTaggedResult

type NodeFetchTaggedResult struct {
	Success *FetchTaggedResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error              `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeFetchTaggedResult

func NewNodeFetchTaggedResult() *NodeFetchTaggedResult

func (*NodeFetchTaggedResult) GetErr

func (p *NodeFetchTaggedResult) GetErr() *Error

func (*NodeFetchTaggedResult) GetSuccess

func (p *NodeFetchTaggedResult) GetSuccess() *FetchTaggedResult_

func (*NodeFetchTaggedResult) IsSetErr

func (p *NodeFetchTaggedResult) IsSetErr() bool

func (*NodeFetchTaggedResult) IsSetSuccess

func (p *NodeFetchTaggedResult) IsSetSuccess() bool

func (*NodeFetchTaggedResult) Read

func (*NodeFetchTaggedResult) ReadField0

func (p *NodeFetchTaggedResult) ReadField0(iprot thrift.TProtocol) error

func (*NodeFetchTaggedResult) ReadField1

func (p *NodeFetchTaggedResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeFetchTaggedResult) String

func (p *NodeFetchTaggedResult) String() string

func (*NodeFetchTaggedResult) Write

func (p *NodeFetchTaggedResult) Write(oprot thrift.TProtocol) error

type NodeGetPersistRateLimitArgs

type NodeGetPersistRateLimitArgs struct {
}

func NewNodeGetPersistRateLimitArgs

func NewNodeGetPersistRateLimitArgs() *NodeGetPersistRateLimitArgs

func (*NodeGetPersistRateLimitArgs) Read

func (*NodeGetPersistRateLimitArgs) String

func (p *NodeGetPersistRateLimitArgs) String() string

func (*NodeGetPersistRateLimitArgs) Write

type NodeGetPersistRateLimitResult

type NodeGetPersistRateLimitResult struct {
	Success *NodePersistRateLimitResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                       `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeGetPersistRateLimitResult

func NewNodeGetPersistRateLimitResult() *NodeGetPersistRateLimitResult

func (*NodeGetPersistRateLimitResult) GetErr

func (p *NodeGetPersistRateLimitResult) GetErr() *Error

func (*NodeGetPersistRateLimitResult) GetSuccess

func (*NodeGetPersistRateLimitResult) IsSetErr

func (p *NodeGetPersistRateLimitResult) IsSetErr() bool

func (*NodeGetPersistRateLimitResult) IsSetSuccess

func (p *NodeGetPersistRateLimitResult) IsSetSuccess() bool

func (*NodeGetPersistRateLimitResult) Read

func (*NodeGetPersistRateLimitResult) ReadField0

func (p *NodeGetPersistRateLimitResult) ReadField0(iprot thrift.TProtocol) error

func (*NodeGetPersistRateLimitResult) ReadField1

func (p *NodeGetPersistRateLimitResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeGetPersistRateLimitResult) String

func (*NodeGetPersistRateLimitResult) Write

type NodeGetWriteNewSeriesAsyncArgs

type NodeGetWriteNewSeriesAsyncArgs struct {
}

func NewNodeGetWriteNewSeriesAsyncArgs

func NewNodeGetWriteNewSeriesAsyncArgs() *NodeGetWriteNewSeriesAsyncArgs

func (*NodeGetWriteNewSeriesAsyncArgs) Read

func (*NodeGetWriteNewSeriesAsyncArgs) String

func (*NodeGetWriteNewSeriesAsyncArgs) Write

type NodeGetWriteNewSeriesAsyncResult

type NodeGetWriteNewSeriesAsyncResult struct {
	Success *NodeWriteNewSeriesAsyncResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                          `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeGetWriteNewSeriesAsyncResult

func NewNodeGetWriteNewSeriesAsyncResult() *NodeGetWriteNewSeriesAsyncResult

func (*NodeGetWriteNewSeriesAsyncResult) GetErr

func (*NodeGetWriteNewSeriesAsyncResult) GetSuccess

func (*NodeGetWriteNewSeriesAsyncResult) IsSetErr

func (p *NodeGetWriteNewSeriesAsyncResult) IsSetErr() bool

func (*NodeGetWriteNewSeriesAsyncResult) IsSetSuccess

func (p *NodeGetWriteNewSeriesAsyncResult) IsSetSuccess() bool

func (*NodeGetWriteNewSeriesAsyncResult) Read

func (*NodeGetWriteNewSeriesAsyncResult) ReadField0

func (*NodeGetWriteNewSeriesAsyncResult) ReadField1

func (*NodeGetWriteNewSeriesAsyncResult) String

func (*NodeGetWriteNewSeriesAsyncResult) Write

type NodeGetWriteNewSeriesBackoffDurationArgs

type NodeGetWriteNewSeriesBackoffDurationArgs struct {
}

func NewNodeGetWriteNewSeriesBackoffDurationArgs

func NewNodeGetWriteNewSeriesBackoffDurationArgs() *NodeGetWriteNewSeriesBackoffDurationArgs

func (*NodeGetWriteNewSeriesBackoffDurationArgs) Read

func (*NodeGetWriteNewSeriesBackoffDurationArgs) String

func (*NodeGetWriteNewSeriesBackoffDurationArgs) Write

type NodeGetWriteNewSeriesBackoffDurationResult

type NodeGetWriteNewSeriesBackoffDurationResult struct {
	Success *NodeWriteNewSeriesBackoffDurationResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                                    `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeGetWriteNewSeriesBackoffDurationResult

func NewNodeGetWriteNewSeriesBackoffDurationResult() *NodeGetWriteNewSeriesBackoffDurationResult

func (*NodeGetWriteNewSeriesBackoffDurationResult) GetErr

func (*NodeGetWriteNewSeriesBackoffDurationResult) GetSuccess

func (*NodeGetWriteNewSeriesBackoffDurationResult) IsSetErr

func (*NodeGetWriteNewSeriesBackoffDurationResult) IsSetSuccess

func (*NodeGetWriteNewSeriesBackoffDurationResult) Read

func (*NodeGetWriteNewSeriesBackoffDurationResult) ReadField0

func (*NodeGetWriteNewSeriesBackoffDurationResult) ReadField1

func (*NodeGetWriteNewSeriesBackoffDurationResult) String

func (*NodeGetWriteNewSeriesBackoffDurationResult) Write

type NodeGetWriteNewSeriesLimitPerShardPerSecondArgs

type NodeGetWriteNewSeriesLimitPerShardPerSecondArgs struct {
}

func NewNodeGetWriteNewSeriesLimitPerShardPerSecondArgs

func NewNodeGetWriteNewSeriesLimitPerShardPerSecondArgs() *NodeGetWriteNewSeriesLimitPerShardPerSecondArgs

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondArgs) Read

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondArgs) String

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondArgs) Write

type NodeGetWriteNewSeriesLimitPerShardPerSecondResult

type NodeGetWriteNewSeriesLimitPerShardPerSecondResult struct {
	Success *NodeWriteNewSeriesLimitPerShardPerSecondResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                                           `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeGetWriteNewSeriesLimitPerShardPerSecondResult

func NewNodeGetWriteNewSeriesLimitPerShardPerSecondResult() *NodeGetWriteNewSeriesLimitPerShardPerSecondResult

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondResult) GetErr

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondResult) GetSuccess

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondResult) IsSetErr

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondResult) IsSetSuccess

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondResult) Read

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondResult) ReadField0

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondResult) ReadField1

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondResult) String

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondResult) Write

type NodeHealthArgs

type NodeHealthArgs struct {
}

func NewNodeHealthArgs

func NewNodeHealthArgs() *NodeHealthArgs

func (*NodeHealthArgs) Read

func (p *NodeHealthArgs) Read(iprot thrift.TProtocol) error

func (*NodeHealthArgs) String

func (p *NodeHealthArgs) String() string

func (*NodeHealthArgs) Write

func (p *NodeHealthArgs) Write(oprot thrift.TProtocol) error

type NodeHealthResult

type NodeHealthResult struct {
	Success *NodeHealthResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error             `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeHealthResult

func NewNodeHealthResult() *NodeHealthResult

func (*NodeHealthResult) GetErr

func (p *NodeHealthResult) GetErr() *Error

func (*NodeHealthResult) GetSuccess

func (p *NodeHealthResult) GetSuccess() *NodeHealthResult_

func (*NodeHealthResult) IsSetErr

func (p *NodeHealthResult) IsSetErr() bool

func (*NodeHealthResult) IsSetSuccess

func (p *NodeHealthResult) IsSetSuccess() bool

func (*NodeHealthResult) Read

func (p *NodeHealthResult) Read(iprot thrift.TProtocol) error

func (*NodeHealthResult) ReadField0

func (p *NodeHealthResult) ReadField0(iprot thrift.TProtocol) error

func (*NodeHealthResult) ReadField1

func (p *NodeHealthResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeHealthResult) String

func (p *NodeHealthResult) String() string

func (*NodeHealthResult) Write

func (p *NodeHealthResult) Write(oprot thrift.TProtocol) error

type NodeHealthResult_

type NodeHealthResult_ struct {
	Ok           bool              `thrift:"ok,1,required" db:"ok" json:"ok"`
	Status       string            `thrift:"status,2,required" db:"status" json:"status"`
	Bootstrapped bool              `thrift:"bootstrapped,3,required" db:"bootstrapped" json:"bootstrapped"`
	Metadata     map[string]string `thrift:"metadata,4" db:"metadata" json:"metadata,omitempty"`
}

Attributes:

  • Ok
  • Status
  • Bootstrapped
  • Metadata
var NodeHealthResult_Success_DEFAULT *NodeHealthResult_

func NewNodeHealthResult_

func NewNodeHealthResult_() *NodeHealthResult_

func (*NodeHealthResult_) GetBootstrapped

func (p *NodeHealthResult_) GetBootstrapped() bool

func (*NodeHealthResult_) GetMetadata added in v0.15.0

func (p *NodeHealthResult_) GetMetadata() map[string]string

func (*NodeHealthResult_) GetOk

func (p *NodeHealthResult_) GetOk() bool

func (*NodeHealthResult_) GetStatus

func (p *NodeHealthResult_) GetStatus() string

func (*NodeHealthResult_) IsSetMetadata added in v0.15.0

func (p *NodeHealthResult_) IsSetMetadata() bool

func (*NodeHealthResult_) Read

func (p *NodeHealthResult_) Read(iprot thrift.TProtocol) error

func (*NodeHealthResult_) ReadField1

func (p *NodeHealthResult_) ReadField1(iprot thrift.TProtocol) error

func (*NodeHealthResult_) ReadField2

func (p *NodeHealthResult_) ReadField2(iprot thrift.TProtocol) error

func (*NodeHealthResult_) ReadField3

func (p *NodeHealthResult_) ReadField3(iprot thrift.TProtocol) error

func (*NodeHealthResult_) ReadField4 added in v0.15.0

func (p *NodeHealthResult_) ReadField4(iprot thrift.TProtocol) error

func (*NodeHealthResult_) String

func (p *NodeHealthResult_) String() string

func (*NodeHealthResult_) Write

func (p *NodeHealthResult_) Write(oprot thrift.TProtocol) error

type NodePersistRateLimitResult_

type NodePersistRateLimitResult_ struct {
	LimitEnabled    bool    `thrift:"limitEnabled,1,required" db:"limitEnabled" json:"limitEnabled"`
	LimitMbps       float64 `thrift:"limitMbps,2,required" db:"limitMbps" json:"limitMbps"`
	LimitCheckEvery int64   `thrift:"limitCheckEvery,3,required" db:"limitCheckEvery" json:"limitCheckEvery"`
}

Attributes:

  • LimitEnabled
  • LimitMbps
  • LimitCheckEvery
var NodeGetPersistRateLimitResult_Success_DEFAULT *NodePersistRateLimitResult_
var NodeSetPersistRateLimitResult_Success_DEFAULT *NodePersistRateLimitResult_

func NewNodePersistRateLimitResult_

func NewNodePersistRateLimitResult_() *NodePersistRateLimitResult_

func (*NodePersistRateLimitResult_) GetLimitCheckEvery

func (p *NodePersistRateLimitResult_) GetLimitCheckEvery() int64

func (*NodePersistRateLimitResult_) GetLimitEnabled

func (p *NodePersistRateLimitResult_) GetLimitEnabled() bool

func (*NodePersistRateLimitResult_) GetLimitMbps

func (p *NodePersistRateLimitResult_) GetLimitMbps() float64

func (*NodePersistRateLimitResult_) Read

func (*NodePersistRateLimitResult_) ReadField1

func (p *NodePersistRateLimitResult_) ReadField1(iprot thrift.TProtocol) error

func (*NodePersistRateLimitResult_) ReadField2

func (p *NodePersistRateLimitResult_) ReadField2(iprot thrift.TProtocol) error

func (*NodePersistRateLimitResult_) ReadField3

func (p *NodePersistRateLimitResult_) ReadField3(iprot thrift.TProtocol) error

func (*NodePersistRateLimitResult_) String

func (p *NodePersistRateLimitResult_) String() string

func (*NodePersistRateLimitResult_) Write

type NodeProcessor

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

func NewNodeProcessor

func NewNodeProcessor(handler Node) *NodeProcessor

func (*NodeProcessor) AddToProcessorMap

func (p *NodeProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*NodeProcessor) GetProcessorFunction

func (p *NodeProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*NodeProcessor) Process

func (p *NodeProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*NodeProcessor) ProcessorMap

func (p *NodeProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type NodeQueryArgs

type NodeQueryArgs struct {
	Req *QueryRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeQueryArgs

func NewNodeQueryArgs() *NodeQueryArgs

func (*NodeQueryArgs) GetReq

func (p *NodeQueryArgs) GetReq() *QueryRequest

func (*NodeQueryArgs) IsSetReq

func (p *NodeQueryArgs) IsSetReq() bool

func (*NodeQueryArgs) Read

func (p *NodeQueryArgs) Read(iprot thrift.TProtocol) error

func (*NodeQueryArgs) ReadField1

func (p *NodeQueryArgs) ReadField1(iprot thrift.TProtocol) error

func (*NodeQueryArgs) String

func (p *NodeQueryArgs) String() string

func (*NodeQueryArgs) Write

func (p *NodeQueryArgs) Write(oprot thrift.TProtocol) error

type NodeQueryResult

type NodeQueryResult struct {
	Success *QueryResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error        `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeQueryResult

func NewNodeQueryResult() *NodeQueryResult

func (*NodeQueryResult) GetErr

func (p *NodeQueryResult) GetErr() *Error

func (*NodeQueryResult) GetSuccess

func (p *NodeQueryResult) GetSuccess() *QueryResult_

func (*NodeQueryResult) IsSetErr

func (p *NodeQueryResult) IsSetErr() bool

func (*NodeQueryResult) IsSetSuccess

func (p *NodeQueryResult) IsSetSuccess() bool

func (*NodeQueryResult) Read

func (p *NodeQueryResult) Read(iprot thrift.TProtocol) error

func (*NodeQueryResult) ReadField0

func (p *NodeQueryResult) ReadField0(iprot thrift.TProtocol) error

func (*NodeQueryResult) ReadField1

func (p *NodeQueryResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeQueryResult) String

func (p *NodeQueryResult) String() string

func (*NodeQueryResult) Write

func (p *NodeQueryResult) Write(oprot thrift.TProtocol) error

type NodeRepairArgs

type NodeRepairArgs struct {
}

func NewNodeRepairArgs

func NewNodeRepairArgs() *NodeRepairArgs

func (*NodeRepairArgs) Read

func (p *NodeRepairArgs) Read(iprot thrift.TProtocol) error

func (*NodeRepairArgs) String

func (p *NodeRepairArgs) String() string

func (*NodeRepairArgs) Write

func (p *NodeRepairArgs) Write(oprot thrift.TProtocol) error

type NodeRepairResult

type NodeRepairResult struct {
	Err *Error `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Err

func NewNodeRepairResult

func NewNodeRepairResult() *NodeRepairResult

func (*NodeRepairResult) GetErr

func (p *NodeRepairResult) GetErr() *Error

func (*NodeRepairResult) IsSetErr

func (p *NodeRepairResult) IsSetErr() bool

func (*NodeRepairResult) Read

func (p *NodeRepairResult) Read(iprot thrift.TProtocol) error

func (*NodeRepairResult) ReadField1

func (p *NodeRepairResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeRepairResult) String

func (p *NodeRepairResult) String() string

func (*NodeRepairResult) Write

func (p *NodeRepairResult) Write(oprot thrift.TProtocol) error

type NodeSetPersistRateLimitArgs

type NodeSetPersistRateLimitArgs struct {
	Req *NodeSetPersistRateLimitRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeSetPersistRateLimitArgs

func NewNodeSetPersistRateLimitArgs() *NodeSetPersistRateLimitArgs

func (*NodeSetPersistRateLimitArgs) GetReq

func (*NodeSetPersistRateLimitArgs) IsSetReq

func (p *NodeSetPersistRateLimitArgs) IsSetReq() bool

func (*NodeSetPersistRateLimitArgs) Read

func (*NodeSetPersistRateLimitArgs) ReadField1

func (p *NodeSetPersistRateLimitArgs) ReadField1(iprot thrift.TProtocol) error

func (*NodeSetPersistRateLimitArgs) String

func (p *NodeSetPersistRateLimitArgs) String() string

func (*NodeSetPersistRateLimitArgs) Write

type NodeSetPersistRateLimitRequest

type NodeSetPersistRateLimitRequest struct {
	LimitEnabled    *bool    `thrift:"limitEnabled,1" db:"limitEnabled" json:"limitEnabled,omitempty"`
	LimitMbps       *float64 `thrift:"limitMbps,2" db:"limitMbps" json:"limitMbps,omitempty"`
	LimitCheckEvery *int64   `thrift:"limitCheckEvery,3" db:"limitCheckEvery" json:"limitCheckEvery,omitempty"`
}

Attributes:

  • LimitEnabled
  • LimitMbps
  • LimitCheckEvery
var NodeSetPersistRateLimitArgs_Req_DEFAULT *NodeSetPersistRateLimitRequest

func NewNodeSetPersistRateLimitRequest

func NewNodeSetPersistRateLimitRequest() *NodeSetPersistRateLimitRequest

func (*NodeSetPersistRateLimitRequest) GetLimitCheckEvery

func (p *NodeSetPersistRateLimitRequest) GetLimitCheckEvery() int64

func (*NodeSetPersistRateLimitRequest) GetLimitEnabled

func (p *NodeSetPersistRateLimitRequest) GetLimitEnabled() bool

func (*NodeSetPersistRateLimitRequest) GetLimitMbps

func (p *NodeSetPersistRateLimitRequest) GetLimitMbps() float64

func (*NodeSetPersistRateLimitRequest) IsSetLimitCheckEvery

func (p *NodeSetPersistRateLimitRequest) IsSetLimitCheckEvery() bool

func (*NodeSetPersistRateLimitRequest) IsSetLimitEnabled

func (p *NodeSetPersistRateLimitRequest) IsSetLimitEnabled() bool

func (*NodeSetPersistRateLimitRequest) IsSetLimitMbps

func (p *NodeSetPersistRateLimitRequest) IsSetLimitMbps() bool

func (*NodeSetPersistRateLimitRequest) Read

func (*NodeSetPersistRateLimitRequest) ReadField1

func (*NodeSetPersistRateLimitRequest) ReadField2

func (*NodeSetPersistRateLimitRequest) ReadField3

func (*NodeSetPersistRateLimitRequest) String

func (*NodeSetPersistRateLimitRequest) Write

type NodeSetPersistRateLimitResult

type NodeSetPersistRateLimitResult struct {
	Success *NodePersistRateLimitResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                       `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeSetPersistRateLimitResult

func NewNodeSetPersistRateLimitResult() *NodeSetPersistRateLimitResult

func (*NodeSetPersistRateLimitResult) GetErr

func (p *NodeSetPersistRateLimitResult) GetErr() *Error

func (*NodeSetPersistRateLimitResult) GetSuccess

func (*NodeSetPersistRateLimitResult) IsSetErr

func (p *NodeSetPersistRateLimitResult) IsSetErr() bool

func (*NodeSetPersistRateLimitResult) IsSetSuccess

func (p *NodeSetPersistRateLimitResult) IsSetSuccess() bool

func (*NodeSetPersistRateLimitResult) Read

func (*NodeSetPersistRateLimitResult) ReadField0

func (p *NodeSetPersistRateLimitResult) ReadField0(iprot thrift.TProtocol) error

func (*NodeSetPersistRateLimitResult) ReadField1

func (p *NodeSetPersistRateLimitResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeSetPersistRateLimitResult) String

func (*NodeSetPersistRateLimitResult) Write

type NodeSetWriteNewSeriesAsyncArgs

type NodeSetWriteNewSeriesAsyncArgs struct {
	Req *NodeSetWriteNewSeriesAsyncRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeSetWriteNewSeriesAsyncArgs

func NewNodeSetWriteNewSeriesAsyncArgs() *NodeSetWriteNewSeriesAsyncArgs

func (*NodeSetWriteNewSeriesAsyncArgs) GetReq

func (*NodeSetWriteNewSeriesAsyncArgs) IsSetReq

func (p *NodeSetWriteNewSeriesAsyncArgs) IsSetReq() bool

func (*NodeSetWriteNewSeriesAsyncArgs) Read

func (*NodeSetWriteNewSeriesAsyncArgs) ReadField1

func (*NodeSetWriteNewSeriesAsyncArgs) String

func (*NodeSetWriteNewSeriesAsyncArgs) Write

type NodeSetWriteNewSeriesAsyncRequest

type NodeSetWriteNewSeriesAsyncRequest struct {
	WriteNewSeriesAsync bool `thrift:"writeNewSeriesAsync,1,required" db:"writeNewSeriesAsync" json:"writeNewSeriesAsync"`
}

Attributes:

  • WriteNewSeriesAsync
var NodeSetWriteNewSeriesAsyncArgs_Req_DEFAULT *NodeSetWriteNewSeriesAsyncRequest

func NewNodeSetWriteNewSeriesAsyncRequest

func NewNodeSetWriteNewSeriesAsyncRequest() *NodeSetWriteNewSeriesAsyncRequest

func (*NodeSetWriteNewSeriesAsyncRequest) GetWriteNewSeriesAsync

func (p *NodeSetWriteNewSeriesAsyncRequest) GetWriteNewSeriesAsync() bool

func (*NodeSetWriteNewSeriesAsyncRequest) Read

func (*NodeSetWriteNewSeriesAsyncRequest) ReadField1

func (*NodeSetWriteNewSeriesAsyncRequest) String

func (*NodeSetWriteNewSeriesAsyncRequest) Write

type NodeSetWriteNewSeriesAsyncResult

type NodeSetWriteNewSeriesAsyncResult struct {
	Success *NodeWriteNewSeriesAsyncResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                          `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeSetWriteNewSeriesAsyncResult

func NewNodeSetWriteNewSeriesAsyncResult() *NodeSetWriteNewSeriesAsyncResult

func (*NodeSetWriteNewSeriesAsyncResult) GetErr

func (*NodeSetWriteNewSeriesAsyncResult) GetSuccess

func (*NodeSetWriteNewSeriesAsyncResult) IsSetErr

func (p *NodeSetWriteNewSeriesAsyncResult) IsSetErr() bool

func (*NodeSetWriteNewSeriesAsyncResult) IsSetSuccess

func (p *NodeSetWriteNewSeriesAsyncResult) IsSetSuccess() bool

func (*NodeSetWriteNewSeriesAsyncResult) Read

func (*NodeSetWriteNewSeriesAsyncResult) ReadField0

func (*NodeSetWriteNewSeriesAsyncResult) ReadField1

func (*NodeSetWriteNewSeriesAsyncResult) String

func (*NodeSetWriteNewSeriesAsyncResult) Write

type NodeSetWriteNewSeriesBackoffDurationArgs

type NodeSetWriteNewSeriesBackoffDurationArgs struct {
	Req *NodeSetWriteNewSeriesBackoffDurationRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeSetWriteNewSeriesBackoffDurationArgs

func NewNodeSetWriteNewSeriesBackoffDurationArgs() *NodeSetWriteNewSeriesBackoffDurationArgs

func (*NodeSetWriteNewSeriesBackoffDurationArgs) GetReq

func (*NodeSetWriteNewSeriesBackoffDurationArgs) IsSetReq

func (*NodeSetWriteNewSeriesBackoffDurationArgs) Read

func (*NodeSetWriteNewSeriesBackoffDurationArgs) ReadField1

func (*NodeSetWriteNewSeriesBackoffDurationArgs) String

func (*NodeSetWriteNewSeriesBackoffDurationArgs) Write

type NodeSetWriteNewSeriesBackoffDurationRequest

type NodeSetWriteNewSeriesBackoffDurationRequest struct {
	WriteNewSeriesBackoffDuration int64    `thrift:"writeNewSeriesBackoffDuration,1,required" db:"writeNewSeriesBackoffDuration" json:"writeNewSeriesBackoffDuration"`
	DurationType                  TimeType `thrift:"durationType,2" db:"durationType" json:"durationType,omitempty"`
}

Attributes:

  • WriteNewSeriesBackoffDuration
  • DurationType
var NodeSetWriteNewSeriesBackoffDurationArgs_Req_DEFAULT *NodeSetWriteNewSeriesBackoffDurationRequest

func NewNodeSetWriteNewSeriesBackoffDurationRequest

func NewNodeSetWriteNewSeriesBackoffDurationRequest() *NodeSetWriteNewSeriesBackoffDurationRequest

func (*NodeSetWriteNewSeriesBackoffDurationRequest) GetDurationType

func (*NodeSetWriteNewSeriesBackoffDurationRequest) GetWriteNewSeriesBackoffDuration

func (p *NodeSetWriteNewSeriesBackoffDurationRequest) GetWriteNewSeriesBackoffDuration() int64

func (*NodeSetWriteNewSeriesBackoffDurationRequest) IsSetDurationType

func (p *NodeSetWriteNewSeriesBackoffDurationRequest) IsSetDurationType() bool

func (*NodeSetWriteNewSeriesBackoffDurationRequest) Read

func (*NodeSetWriteNewSeriesBackoffDurationRequest) ReadField1

func (*NodeSetWriteNewSeriesBackoffDurationRequest) ReadField2

func (*NodeSetWriteNewSeriesBackoffDurationRequest) String

func (*NodeSetWriteNewSeriesBackoffDurationRequest) Write

type NodeSetWriteNewSeriesBackoffDurationResult

type NodeSetWriteNewSeriesBackoffDurationResult struct {
	Success *NodeWriteNewSeriesBackoffDurationResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                                    `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeSetWriteNewSeriesBackoffDurationResult

func NewNodeSetWriteNewSeriesBackoffDurationResult() *NodeSetWriteNewSeriesBackoffDurationResult

func (*NodeSetWriteNewSeriesBackoffDurationResult) GetErr

func (*NodeSetWriteNewSeriesBackoffDurationResult) GetSuccess

func (*NodeSetWriteNewSeriesBackoffDurationResult) IsSetErr

func (*NodeSetWriteNewSeriesBackoffDurationResult) IsSetSuccess

func (*NodeSetWriteNewSeriesBackoffDurationResult) Read

func (*NodeSetWriteNewSeriesBackoffDurationResult) ReadField0

func (*NodeSetWriteNewSeriesBackoffDurationResult) ReadField1

func (*NodeSetWriteNewSeriesBackoffDurationResult) String

func (*NodeSetWriteNewSeriesBackoffDurationResult) Write

type NodeSetWriteNewSeriesLimitPerShardPerSecondArgs

type NodeSetWriteNewSeriesLimitPerShardPerSecondArgs struct {
	Req *NodeSetWriteNewSeriesLimitPerShardPerSecondRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeSetWriteNewSeriesLimitPerShardPerSecondArgs

func NewNodeSetWriteNewSeriesLimitPerShardPerSecondArgs() *NodeSetWriteNewSeriesLimitPerShardPerSecondArgs

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondArgs) GetReq

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondArgs) IsSetReq

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondArgs) Read

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondArgs) ReadField1

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondArgs) String

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondArgs) Write

type NodeSetWriteNewSeriesLimitPerShardPerSecondRequest

type NodeSetWriteNewSeriesLimitPerShardPerSecondRequest struct {
	WriteNewSeriesLimitPerShardPerSecond int64 `` /* 142-byte string literal not displayed */
}

Attributes:

  • WriteNewSeriesLimitPerShardPerSecond
var NodeSetWriteNewSeriesLimitPerShardPerSecondArgs_Req_DEFAULT *NodeSetWriteNewSeriesLimitPerShardPerSecondRequest

func NewNodeSetWriteNewSeriesLimitPerShardPerSecondRequest

func NewNodeSetWriteNewSeriesLimitPerShardPerSecondRequest() *NodeSetWriteNewSeriesLimitPerShardPerSecondRequest

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondRequest) GetWriteNewSeriesLimitPerShardPerSecond

func (p *NodeSetWriteNewSeriesLimitPerShardPerSecondRequest) GetWriteNewSeriesLimitPerShardPerSecond() int64

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondRequest) Read

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondRequest) ReadField1

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondRequest) String

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondRequest) Write

type NodeSetWriteNewSeriesLimitPerShardPerSecondResult

type NodeSetWriteNewSeriesLimitPerShardPerSecondResult struct {
	Success *NodeWriteNewSeriesLimitPerShardPerSecondResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error                                           `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeSetWriteNewSeriesLimitPerShardPerSecondResult

func NewNodeSetWriteNewSeriesLimitPerShardPerSecondResult() *NodeSetWriteNewSeriesLimitPerShardPerSecondResult

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondResult) GetErr

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondResult) GetSuccess

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondResult) IsSetErr

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondResult) IsSetSuccess

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondResult) Read

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondResult) ReadField0

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondResult) ReadField1

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondResult) String

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondResult) Write

type NodeTruncateArgs

type NodeTruncateArgs struct {
	Req *TruncateRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeTruncateArgs

func NewNodeTruncateArgs() *NodeTruncateArgs

func (*NodeTruncateArgs) GetReq

func (p *NodeTruncateArgs) GetReq() *TruncateRequest

func (*NodeTruncateArgs) IsSetReq

func (p *NodeTruncateArgs) IsSetReq() bool

func (*NodeTruncateArgs) Read

func (p *NodeTruncateArgs) Read(iprot thrift.TProtocol) error

func (*NodeTruncateArgs) ReadField1

func (p *NodeTruncateArgs) ReadField1(iprot thrift.TProtocol) error

func (*NodeTruncateArgs) String

func (p *NodeTruncateArgs) String() string

func (*NodeTruncateArgs) Write

func (p *NodeTruncateArgs) Write(oprot thrift.TProtocol) error

type NodeTruncateResult

type NodeTruncateResult struct {
	Success *TruncateResult_ `thrift:"success,0" db:"success" json:"success,omitempty"`
	Err     *Error           `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Success
  • Err

func NewNodeTruncateResult

func NewNodeTruncateResult() *NodeTruncateResult

func (*NodeTruncateResult) GetErr

func (p *NodeTruncateResult) GetErr() *Error

func (*NodeTruncateResult) GetSuccess

func (p *NodeTruncateResult) GetSuccess() *TruncateResult_

func (*NodeTruncateResult) IsSetErr

func (p *NodeTruncateResult) IsSetErr() bool

func (*NodeTruncateResult) IsSetSuccess

func (p *NodeTruncateResult) IsSetSuccess() bool

func (*NodeTruncateResult) Read

func (p *NodeTruncateResult) Read(iprot thrift.TProtocol) error

func (*NodeTruncateResult) ReadField0

func (p *NodeTruncateResult) ReadField0(iprot thrift.TProtocol) error

func (*NodeTruncateResult) ReadField1

func (p *NodeTruncateResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeTruncateResult) String

func (p *NodeTruncateResult) String() string

func (*NodeTruncateResult) Write

func (p *NodeTruncateResult) Write(oprot thrift.TProtocol) error

type NodeWriteArgs

type NodeWriteArgs struct {
	Req *WriteRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeWriteArgs

func NewNodeWriteArgs() *NodeWriteArgs

func (*NodeWriteArgs) GetReq

func (p *NodeWriteArgs) GetReq() *WriteRequest

func (*NodeWriteArgs) IsSetReq

func (p *NodeWriteArgs) IsSetReq() bool

func (*NodeWriteArgs) Read

func (p *NodeWriteArgs) Read(iprot thrift.TProtocol) error

func (*NodeWriteArgs) ReadField1

func (p *NodeWriteArgs) ReadField1(iprot thrift.TProtocol) error

func (*NodeWriteArgs) String

func (p *NodeWriteArgs) String() string

func (*NodeWriteArgs) Write

func (p *NodeWriteArgs) Write(oprot thrift.TProtocol) error

type NodeWriteBatchRawArgs

type NodeWriteBatchRawArgs struct {
	Req *WriteBatchRawRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeWriteBatchRawArgs

func NewNodeWriteBatchRawArgs() *NodeWriteBatchRawArgs

func (*NodeWriteBatchRawArgs) GetReq

func (*NodeWriteBatchRawArgs) IsSetReq

func (p *NodeWriteBatchRawArgs) IsSetReq() bool

func (*NodeWriteBatchRawArgs) Read

func (*NodeWriteBatchRawArgs) ReadField1

func (p *NodeWriteBatchRawArgs) ReadField1(iprot thrift.TProtocol) error

func (*NodeWriteBatchRawArgs) String

func (p *NodeWriteBatchRawArgs) String() string

func (*NodeWriteBatchRawArgs) Write

func (p *NodeWriteBatchRawArgs) Write(oprot thrift.TProtocol) error

type NodeWriteBatchRawResult

type NodeWriteBatchRawResult struct {
	Err *WriteBatchRawErrors `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Err

func NewNodeWriteBatchRawResult

func NewNodeWriteBatchRawResult() *NodeWriteBatchRawResult

func (*NodeWriteBatchRawResult) GetErr

func (*NodeWriteBatchRawResult) IsSetErr

func (p *NodeWriteBatchRawResult) IsSetErr() bool

func (*NodeWriteBatchRawResult) Read

func (*NodeWriteBatchRawResult) ReadField1

func (p *NodeWriteBatchRawResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeWriteBatchRawResult) String

func (p *NodeWriteBatchRawResult) String() string

func (*NodeWriteBatchRawResult) Write

type NodeWriteBatchRawV2Args added in v0.14.0

type NodeWriteBatchRawV2Args struct {
	Req *WriteBatchRawV2Request `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeWriteBatchRawV2Args added in v0.14.0

func NewNodeWriteBatchRawV2Args() *NodeWriteBatchRawV2Args

func (*NodeWriteBatchRawV2Args) GetReq added in v0.14.0

func (*NodeWriteBatchRawV2Args) IsSetReq added in v0.14.0

func (p *NodeWriteBatchRawV2Args) IsSetReq() bool

func (*NodeWriteBatchRawV2Args) Read added in v0.14.0

func (*NodeWriteBatchRawV2Args) ReadField1 added in v0.14.0

func (p *NodeWriteBatchRawV2Args) ReadField1(iprot thrift.TProtocol) error

func (*NodeWriteBatchRawV2Args) String added in v0.14.0

func (p *NodeWriteBatchRawV2Args) String() string

func (*NodeWriteBatchRawV2Args) Write added in v0.14.0

type NodeWriteBatchRawV2Result added in v0.14.0

type NodeWriteBatchRawV2Result struct {
	Err *WriteBatchRawErrors `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Err

func NewNodeWriteBatchRawV2Result added in v0.14.0

func NewNodeWriteBatchRawV2Result() *NodeWriteBatchRawV2Result

func (*NodeWriteBatchRawV2Result) GetErr added in v0.14.0

func (*NodeWriteBatchRawV2Result) IsSetErr added in v0.14.0

func (p *NodeWriteBatchRawV2Result) IsSetErr() bool

func (*NodeWriteBatchRawV2Result) Read added in v0.14.0

func (*NodeWriteBatchRawV2Result) ReadField1 added in v0.14.0

func (p *NodeWriteBatchRawV2Result) ReadField1(iprot thrift.TProtocol) error

func (*NodeWriteBatchRawV2Result) String added in v0.14.0

func (p *NodeWriteBatchRawV2Result) String() string

func (*NodeWriteBatchRawV2Result) Write added in v0.14.0

type NodeWriteNewSeriesAsyncResult_

type NodeWriteNewSeriesAsyncResult_ struct {
	WriteNewSeriesAsync bool `thrift:"writeNewSeriesAsync,1,required" db:"writeNewSeriesAsync" json:"writeNewSeriesAsync"`
}

Attributes:

  • WriteNewSeriesAsync
var NodeGetWriteNewSeriesAsyncResult_Success_DEFAULT *NodeWriteNewSeriesAsyncResult_
var NodeSetWriteNewSeriesAsyncResult_Success_DEFAULT *NodeWriteNewSeriesAsyncResult_

func NewNodeWriteNewSeriesAsyncResult_

func NewNodeWriteNewSeriesAsyncResult_() *NodeWriteNewSeriesAsyncResult_

func (*NodeWriteNewSeriesAsyncResult_) GetWriteNewSeriesAsync

func (p *NodeWriteNewSeriesAsyncResult_) GetWriteNewSeriesAsync() bool

func (*NodeWriteNewSeriesAsyncResult_) Read

func (*NodeWriteNewSeriesAsyncResult_) ReadField1

func (*NodeWriteNewSeriesAsyncResult_) String

func (*NodeWriteNewSeriesAsyncResult_) Write

type NodeWriteNewSeriesBackoffDurationResult_

type NodeWriteNewSeriesBackoffDurationResult_ struct {
	WriteNewSeriesBackoffDuration int64    `thrift:"writeNewSeriesBackoffDuration,1,required" db:"writeNewSeriesBackoffDuration" json:"writeNewSeriesBackoffDuration"`
	DurationType                  TimeType `thrift:"durationType,2,required" db:"durationType" json:"durationType"`
}

Attributes:

  • WriteNewSeriesBackoffDuration
  • DurationType
var NodeGetWriteNewSeriesBackoffDurationResult_Success_DEFAULT *NodeWriteNewSeriesBackoffDurationResult_
var NodeSetWriteNewSeriesBackoffDurationResult_Success_DEFAULT *NodeWriteNewSeriesBackoffDurationResult_

func NewNodeWriteNewSeriesBackoffDurationResult_

func NewNodeWriteNewSeriesBackoffDurationResult_() *NodeWriteNewSeriesBackoffDurationResult_

func (*NodeWriteNewSeriesBackoffDurationResult_) GetDurationType

func (*NodeWriteNewSeriesBackoffDurationResult_) GetWriteNewSeriesBackoffDuration

func (p *NodeWriteNewSeriesBackoffDurationResult_) GetWriteNewSeriesBackoffDuration() int64

func (*NodeWriteNewSeriesBackoffDurationResult_) Read

func (*NodeWriteNewSeriesBackoffDurationResult_) ReadField1

func (*NodeWriteNewSeriesBackoffDurationResult_) ReadField2

func (*NodeWriteNewSeriesBackoffDurationResult_) String

func (*NodeWriteNewSeriesBackoffDurationResult_) Write

type NodeWriteNewSeriesLimitPerShardPerSecondResult_

type NodeWriteNewSeriesLimitPerShardPerSecondResult_ struct {
	WriteNewSeriesLimitPerShardPerSecond int64 `` /* 142-byte string literal not displayed */
}

Attributes:

  • WriteNewSeriesLimitPerShardPerSecond
var NodeGetWriteNewSeriesLimitPerShardPerSecondResult_Success_DEFAULT *NodeWriteNewSeriesLimitPerShardPerSecondResult_
var NodeSetWriteNewSeriesLimitPerShardPerSecondResult_Success_DEFAULT *NodeWriteNewSeriesLimitPerShardPerSecondResult_

func NewNodeWriteNewSeriesLimitPerShardPerSecondResult_

func NewNodeWriteNewSeriesLimitPerShardPerSecondResult_() *NodeWriteNewSeriesLimitPerShardPerSecondResult_

func (*NodeWriteNewSeriesLimitPerShardPerSecondResult_) GetWriteNewSeriesLimitPerShardPerSecond

func (p *NodeWriteNewSeriesLimitPerShardPerSecondResult_) GetWriteNewSeriesLimitPerShardPerSecond() int64

func (*NodeWriteNewSeriesLimitPerShardPerSecondResult_) Read

func (*NodeWriteNewSeriesLimitPerShardPerSecondResult_) ReadField1

func (*NodeWriteNewSeriesLimitPerShardPerSecondResult_) String

func (*NodeWriteNewSeriesLimitPerShardPerSecondResult_) Write

type NodeWriteResult

type NodeWriteResult struct {
	Err *Error `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Err

func NewNodeWriteResult

func NewNodeWriteResult() *NodeWriteResult

func (*NodeWriteResult) GetErr

func (p *NodeWriteResult) GetErr() *Error

func (*NodeWriteResult) IsSetErr

func (p *NodeWriteResult) IsSetErr() bool

func (*NodeWriteResult) Read

func (p *NodeWriteResult) Read(iprot thrift.TProtocol) error

func (*NodeWriteResult) ReadField1

func (p *NodeWriteResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeWriteResult) String

func (p *NodeWriteResult) String() string

func (*NodeWriteResult) Write

func (p *NodeWriteResult) Write(oprot thrift.TProtocol) error

type NodeWriteTaggedArgs

type NodeWriteTaggedArgs struct {
	Req *WriteTaggedRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeWriteTaggedArgs

func NewNodeWriteTaggedArgs() *NodeWriteTaggedArgs

func (*NodeWriteTaggedArgs) GetReq

func (*NodeWriteTaggedArgs) IsSetReq

func (p *NodeWriteTaggedArgs) IsSetReq() bool

func (*NodeWriteTaggedArgs) Read

func (p *NodeWriteTaggedArgs) Read(iprot thrift.TProtocol) error

func (*NodeWriteTaggedArgs) ReadField1

func (p *NodeWriteTaggedArgs) ReadField1(iprot thrift.TProtocol) error

func (*NodeWriteTaggedArgs) String

func (p *NodeWriteTaggedArgs) String() string

func (*NodeWriteTaggedArgs) Write

func (p *NodeWriteTaggedArgs) Write(oprot thrift.TProtocol) error

type NodeWriteTaggedBatchRawArgs

type NodeWriteTaggedBatchRawArgs struct {
	Req *WriteTaggedBatchRawRequest `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeWriteTaggedBatchRawArgs

func NewNodeWriteTaggedBatchRawArgs() *NodeWriteTaggedBatchRawArgs

func (*NodeWriteTaggedBatchRawArgs) GetReq

func (*NodeWriteTaggedBatchRawArgs) IsSetReq

func (p *NodeWriteTaggedBatchRawArgs) IsSetReq() bool

func (*NodeWriteTaggedBatchRawArgs) Read

func (*NodeWriteTaggedBatchRawArgs) ReadField1

func (p *NodeWriteTaggedBatchRawArgs) ReadField1(iprot thrift.TProtocol) error

func (*NodeWriteTaggedBatchRawArgs) String

func (p *NodeWriteTaggedBatchRawArgs) String() string

func (*NodeWriteTaggedBatchRawArgs) Write

type NodeWriteTaggedBatchRawResult

type NodeWriteTaggedBatchRawResult struct {
	Err *WriteBatchRawErrors `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Err

func NewNodeWriteTaggedBatchRawResult

func NewNodeWriteTaggedBatchRawResult() *NodeWriteTaggedBatchRawResult

func (*NodeWriteTaggedBatchRawResult) GetErr

func (*NodeWriteTaggedBatchRawResult) IsSetErr

func (p *NodeWriteTaggedBatchRawResult) IsSetErr() bool

func (*NodeWriteTaggedBatchRawResult) Read

func (*NodeWriteTaggedBatchRawResult) ReadField1

func (p *NodeWriteTaggedBatchRawResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeWriteTaggedBatchRawResult) String

func (*NodeWriteTaggedBatchRawResult) Write

type NodeWriteTaggedBatchRawV2Args added in v0.14.0

type NodeWriteTaggedBatchRawV2Args struct {
	Req *WriteTaggedBatchRawV2Request `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewNodeWriteTaggedBatchRawV2Args added in v0.14.0

func NewNodeWriteTaggedBatchRawV2Args() *NodeWriteTaggedBatchRawV2Args

func (*NodeWriteTaggedBatchRawV2Args) GetReq added in v0.14.0

func (*NodeWriteTaggedBatchRawV2Args) IsSetReq added in v0.14.0

func (p *NodeWriteTaggedBatchRawV2Args) IsSetReq() bool

func (*NodeWriteTaggedBatchRawV2Args) Read added in v0.14.0

func (*NodeWriteTaggedBatchRawV2Args) ReadField1 added in v0.14.0

func (p *NodeWriteTaggedBatchRawV2Args) ReadField1(iprot thrift.TProtocol) error

func (*NodeWriteTaggedBatchRawV2Args) String added in v0.14.0

func (*NodeWriteTaggedBatchRawV2Args) Write added in v0.14.0

type NodeWriteTaggedBatchRawV2Result added in v0.14.0

type NodeWriteTaggedBatchRawV2Result struct {
	Err *WriteBatchRawErrors `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Err

func NewNodeWriteTaggedBatchRawV2Result added in v0.14.0

func NewNodeWriteTaggedBatchRawV2Result() *NodeWriteTaggedBatchRawV2Result

func (*NodeWriteTaggedBatchRawV2Result) GetErr added in v0.14.0

func (*NodeWriteTaggedBatchRawV2Result) IsSetErr added in v0.14.0

func (p *NodeWriteTaggedBatchRawV2Result) IsSetErr() bool

func (*NodeWriteTaggedBatchRawV2Result) Read added in v0.14.0

func (*NodeWriteTaggedBatchRawV2Result) ReadField1 added in v0.14.0

func (*NodeWriteTaggedBatchRawV2Result) String added in v0.14.0

func (*NodeWriteTaggedBatchRawV2Result) Write added in v0.14.0

type NodeWriteTaggedResult

type NodeWriteTaggedResult struct {
	Err *Error `thrift:"err,1" db:"err" json:"err,omitempty"`
}

Attributes:

  • Err

func NewNodeWriteTaggedResult

func NewNodeWriteTaggedResult() *NodeWriteTaggedResult

func (*NodeWriteTaggedResult) GetErr

func (p *NodeWriteTaggedResult) GetErr() *Error

func (*NodeWriteTaggedResult) IsSetErr

func (p *NodeWriteTaggedResult) IsSetErr() bool

func (*NodeWriteTaggedResult) Read

func (*NodeWriteTaggedResult) ReadField1

func (p *NodeWriteTaggedResult) ReadField1(iprot thrift.TProtocol) error

func (*NodeWriteTaggedResult) String

func (p *NodeWriteTaggedResult) String() string

func (*NodeWriteTaggedResult) Write

func (p *NodeWriteTaggedResult) Write(oprot thrift.TProtocol) error

type Query

type Query struct {
	Term        *TermQuery        `thrift:"term,1" db:"term" json:"term,omitempty"`
	Regexp      *RegexpQuery      `thrift:"regexp,2" db:"regexp" json:"regexp,omitempty"`
	Negation    *NegationQuery    `thrift:"negation,3" db:"negation" json:"negation,omitempty"`
	Conjunction *ConjunctionQuery `thrift:"conjunction,4" db:"conjunction" json:"conjunction,omitempty"`
	Disjunction *DisjunctionQuery `thrift:"disjunction,5" db:"disjunction" json:"disjunction,omitempty"`
	All         *AllQuery         `thrift:"all,6" db:"all" json:"all,omitempty"`
	Field       *FieldQuery       `thrift:"field,7" db:"field" json:"field,omitempty"`
}

Attributes:

  • Term
  • Regexp
  • Negation
  • Conjunction
  • Disjunction
  • All
  • Field
var AggregateQueryRequest_Query_DEFAULT *Query
var NegationQuery_Query_DEFAULT *Query
var QueryRequest_Query_DEFAULT *Query

func NewQuery

func NewQuery() *Query

func (*Query) GetAll added in v0.8.0

func (p *Query) GetAll() *AllQuery

func (*Query) GetConjunction

func (p *Query) GetConjunction() *ConjunctionQuery

func (*Query) GetDisjunction

func (p *Query) GetDisjunction() *DisjunctionQuery

func (*Query) GetField added in v0.8.1

func (p *Query) GetField() *FieldQuery

func (*Query) GetNegation

func (p *Query) GetNegation() *NegationQuery

func (*Query) GetRegexp

func (p *Query) GetRegexp() *RegexpQuery

func (*Query) GetTerm

func (p *Query) GetTerm() *TermQuery

func (*Query) IsSetAll added in v0.8.0

func (p *Query) IsSetAll() bool

func (*Query) IsSetConjunction

func (p *Query) IsSetConjunction() bool

func (*Query) IsSetDisjunction

func (p *Query) IsSetDisjunction() bool

func (*Query) IsSetField added in v0.8.1

func (p *Query) IsSetField() bool

func (*Query) IsSetNegation

func (p *Query) IsSetNegation() bool

func (*Query) IsSetRegexp

func (p *Query) IsSetRegexp() bool

func (*Query) IsSetTerm

func (p *Query) IsSetTerm() bool

func (*Query) Read

func (p *Query) Read(iprot thrift.TProtocol) error

func (*Query) ReadField1

func (p *Query) ReadField1(iprot thrift.TProtocol) error

func (*Query) ReadField2

func (p *Query) ReadField2(iprot thrift.TProtocol) error

func (*Query) ReadField3

func (p *Query) ReadField3(iprot thrift.TProtocol) error

func (*Query) ReadField4

func (p *Query) ReadField4(iprot thrift.TProtocol) error

func (*Query) ReadField5

func (p *Query) ReadField5(iprot thrift.TProtocol) error

func (*Query) ReadField6 added in v0.8.0

func (p *Query) ReadField6(iprot thrift.TProtocol) error

func (*Query) ReadField7 added in v0.8.1

func (p *Query) ReadField7(iprot thrift.TProtocol) error

func (*Query) String

func (p *Query) String() string

func (*Query) Write

func (p *Query) Write(oprot thrift.TProtocol) error

type QueryRequest

type QueryRequest struct {
	Query          *Query   `thrift:"query,1,required" db:"query" json:"query"`
	RangeStart     int64    `thrift:"rangeStart,2,required" db:"rangeStart" json:"rangeStart"`
	RangeEnd       int64    `thrift:"rangeEnd,3,required" db:"rangeEnd" json:"rangeEnd"`
	NameSpace      string   `thrift:"nameSpace,4,required" db:"nameSpace" json:"nameSpace"`
	Limit          *int64   `thrift:"limit,5" db:"limit" json:"limit,omitempty"`
	NoData         *bool    `thrift:"noData,6" db:"noData" json:"noData,omitempty"`
	RangeType      TimeType `thrift:"rangeType,7" db:"rangeType" json:"rangeType,omitempty"`
	ResultTimeType TimeType `thrift:"resultTimeType,8" db:"resultTimeType" json:"resultTimeType,omitempty"`
}

Attributes:

  • Query
  • RangeStart
  • RangeEnd
  • NameSpace
  • Limit
  • NoData
  • RangeType
  • ResultTimeType
var ClusterQueryArgs_Req_DEFAULT *QueryRequest
var NodeQueryArgs_Req_DEFAULT *QueryRequest

func NewQueryRequest

func NewQueryRequest() *QueryRequest

func (*QueryRequest) GetLimit

func (p *QueryRequest) GetLimit() int64

func (*QueryRequest) GetNameSpace

func (p *QueryRequest) GetNameSpace() string

func (*QueryRequest) GetNoData

func (p *QueryRequest) GetNoData() bool

func (*QueryRequest) GetQuery

func (p *QueryRequest) GetQuery() *Query

func (*QueryRequest) GetRangeEnd

func (p *QueryRequest) GetRangeEnd() int64

func (*QueryRequest) GetRangeStart

func (p *QueryRequest) GetRangeStart() int64

func (*QueryRequest) GetRangeType

func (p *QueryRequest) GetRangeType() TimeType

func (*QueryRequest) GetResultTimeType

func (p *QueryRequest) GetResultTimeType() TimeType

func (*QueryRequest) IsSetLimit

func (p *QueryRequest) IsSetLimit() bool

func (*QueryRequest) IsSetNoData

func (p *QueryRequest) IsSetNoData() bool

func (*QueryRequest) IsSetQuery

func (p *QueryRequest) IsSetQuery() bool

func (*QueryRequest) IsSetRangeType

func (p *QueryRequest) IsSetRangeType() bool

func (*QueryRequest) IsSetResultTimeType

func (p *QueryRequest) IsSetResultTimeType() bool

func (*QueryRequest) Read

func (p *QueryRequest) Read(iprot thrift.TProtocol) error

func (*QueryRequest) ReadField1

func (p *QueryRequest) ReadField1(iprot thrift.TProtocol) error

func (*QueryRequest) ReadField2

func (p *QueryRequest) ReadField2(iprot thrift.TProtocol) error

func (*QueryRequest) ReadField3

func (p *QueryRequest) ReadField3(iprot thrift.TProtocol) error

func (*QueryRequest) ReadField4

func (p *QueryRequest) ReadField4(iprot thrift.TProtocol) error

func (*QueryRequest) ReadField5

func (p *QueryRequest) ReadField5(iprot thrift.TProtocol) error

func (*QueryRequest) ReadField6

func (p *QueryRequest) ReadField6(iprot thrift.TProtocol) error

func (*QueryRequest) ReadField7

func (p *QueryRequest) ReadField7(iprot thrift.TProtocol) error

func (*QueryRequest) ReadField8

func (p *QueryRequest) ReadField8(iprot thrift.TProtocol) error

func (*QueryRequest) String

func (p *QueryRequest) String() string

func (*QueryRequest) Write

func (p *QueryRequest) Write(oprot thrift.TProtocol) error

type QueryResultElement

type QueryResultElement struct {
	ID         string       `thrift:"id,1,required" db:"id" json:"id"`
	Tags       []*Tag       `thrift:"tags,2,required" db:"tags" json:"tags"`
	Datapoints []*Datapoint `thrift:"datapoints,3,required" db:"datapoints" json:"datapoints"`
}

Attributes:

  • ID
  • Tags
  • Datapoints

func NewQueryResultElement

func NewQueryResultElement() *QueryResultElement

func (*QueryResultElement) GetDatapoints

func (p *QueryResultElement) GetDatapoints() []*Datapoint

func (*QueryResultElement) GetID

func (p *QueryResultElement) GetID() string

func (*QueryResultElement) GetTags

func (p *QueryResultElement) GetTags() []*Tag

func (*QueryResultElement) Read

func (p *QueryResultElement) Read(iprot thrift.TProtocol) error

func (*QueryResultElement) ReadField1

func (p *QueryResultElement) ReadField1(iprot thrift.TProtocol) error

func (*QueryResultElement) ReadField2

func (p *QueryResultElement) ReadField2(iprot thrift.TProtocol) error

func (*QueryResultElement) ReadField3

func (p *QueryResultElement) ReadField3(iprot thrift.TProtocol) error

func (*QueryResultElement) String

func (p *QueryResultElement) String() string

func (*QueryResultElement) Write

func (p *QueryResultElement) Write(oprot thrift.TProtocol) error

type QueryResult_

type QueryResult_ struct {
	Results    []*QueryResultElement `thrift:"results,1,required" db:"results" json:"results"`
	Exhaustive bool                  `thrift:"exhaustive,2,required" db:"exhaustive" json:"exhaustive"`
}

Attributes:

  • Results
  • Exhaustive
var ClusterQueryResult_Success_DEFAULT *QueryResult_
var NodeQueryResult_Success_DEFAULT *QueryResult_

func NewQueryResult_

func NewQueryResult_() *QueryResult_

func (*QueryResult_) GetExhaustive

func (p *QueryResult_) GetExhaustive() bool

func (*QueryResult_) GetResults

func (p *QueryResult_) GetResults() []*QueryResultElement

func (*QueryResult_) Read

func (p *QueryResult_) Read(iprot thrift.TProtocol) error

func (*QueryResult_) ReadField1

func (p *QueryResult_) ReadField1(iprot thrift.TProtocol) error

func (*QueryResult_) ReadField2

func (p *QueryResult_) ReadField2(iprot thrift.TProtocol) error

func (*QueryResult_) String

func (p *QueryResult_) String() string

func (*QueryResult_) Write

func (p *QueryResult_) Write(oprot thrift.TProtocol) error

type RegexpQuery

type RegexpQuery struct {
	Field  string `thrift:"field,1,required" db:"field" json:"field"`
	Regexp string `thrift:"regexp,2,required" db:"regexp" json:"regexp"`
}

Attributes:

  • Field
  • Regexp
var Query_Regexp_DEFAULT *RegexpQuery

func NewRegexpQuery

func NewRegexpQuery() *RegexpQuery

func (*RegexpQuery) GetField

func (p *RegexpQuery) GetField() string

func (*RegexpQuery) GetRegexp

func (p *RegexpQuery) GetRegexp() string

func (*RegexpQuery) Read

func (p *RegexpQuery) Read(iprot thrift.TProtocol) error

func (*RegexpQuery) ReadField1

func (p *RegexpQuery) ReadField1(iprot thrift.TProtocol) error

func (*RegexpQuery) ReadField2

func (p *RegexpQuery) ReadField2(iprot thrift.TProtocol) error

func (*RegexpQuery) String

func (p *RegexpQuery) String() string

func (*RegexpQuery) Write

func (p *RegexpQuery) Write(oprot thrift.TProtocol) error

type Segment

type Segment struct {
	Head      []byte `thrift:"head,1,required" db:"head" json:"head"`
	Tail      []byte `thrift:"tail,2,required" db:"tail" json:"tail"`
	StartTime *int64 `thrift:"startTime,3" db:"startTime" json:"startTime,omitempty"`
	BlockSize *int64 `thrift:"blockSize,4" db:"blockSize" json:"blockSize,omitempty"`
	Checksum  *int64 `thrift:"checksum,5" db:"checksum" json:"checksum,omitempty"`
}

Attributes:

  • Head
  • Tail
  • StartTime
  • BlockSize
  • Checksum
var Segments_Merged_DEFAULT *Segment

func NewSegment

func NewSegment() *Segment

func (*Segment) GetBlockSize

func (p *Segment) GetBlockSize() int64

func (*Segment) GetChecksum added in v0.15.0

func (p *Segment) GetChecksum() int64

func (*Segment) GetHead

func (p *Segment) GetHead() []byte

func (*Segment) GetStartTime

func (p *Segment) GetStartTime() int64

func (*Segment) GetTail

func (p *Segment) GetTail() []byte

func (*Segment) IsSetBlockSize

func (p *Segment) IsSetBlockSize() bool

func (*Segment) IsSetChecksum added in v0.15.0

func (p *Segment) IsSetChecksum() bool

func (*Segment) IsSetStartTime

func (p *Segment) IsSetStartTime() bool

func (*Segment) Read

func (p *Segment) Read(iprot thrift.TProtocol) error

func (*Segment) ReadField1

func (p *Segment) ReadField1(iprot thrift.TProtocol) error

func (*Segment) ReadField2

func (p *Segment) ReadField2(iprot thrift.TProtocol) error

func (*Segment) ReadField3

func (p *Segment) ReadField3(iprot thrift.TProtocol) error

func (*Segment) ReadField4

func (p *Segment) ReadField4(iprot thrift.TProtocol) error

func (*Segment) ReadField5 added in v0.15.0

func (p *Segment) ReadField5(iprot thrift.TProtocol) error

func (*Segment) String

func (p *Segment) String() string

func (*Segment) Write

func (p *Segment) Write(oprot thrift.TProtocol) error

type Segments

type Segments struct {
	Merged   *Segment   `thrift:"merged,1" db:"merged" json:"merged,omitempty"`
	Unmerged []*Segment `thrift:"unmerged,2" db:"unmerged" json:"unmerged,omitempty"`
}

Attributes:

  • Merged
  • Unmerged
var Block_Segments_DEFAULT *Segments

func NewSegments

func NewSegments() *Segments

func (*Segments) GetMerged

func (p *Segments) GetMerged() *Segment

func (*Segments) GetUnmerged

func (p *Segments) GetUnmerged() []*Segment

func (*Segments) IsSetMerged

func (p *Segments) IsSetMerged() bool

func (*Segments) IsSetUnmerged

func (p *Segments) IsSetUnmerged() bool

func (*Segments) Read

func (p *Segments) Read(iprot thrift.TProtocol) error

func (*Segments) ReadField1

func (p *Segments) ReadField1(iprot thrift.TProtocol) error

func (*Segments) ReadField2

func (p *Segments) ReadField2(iprot thrift.TProtocol) error

func (*Segments) String

func (p *Segments) String() string

func (*Segments) Write

func (p *Segments) Write(oprot thrift.TProtocol) error

type TChanCluster

type TChanCluster interface {
	Aggregate(ctx thrift.Context, req *AggregateQueryRequest) (*AggregateQueryResult_, error)
	Fetch(ctx thrift.Context, req *FetchRequest) (*FetchResult_, error)
	Health(ctx thrift.Context) (*HealthResult_, error)
	Query(ctx thrift.Context, req *QueryRequest) (*QueryResult_, error)
	Truncate(ctx thrift.Context, req *TruncateRequest) (*TruncateResult_, error)
	Write(ctx thrift.Context, req *WriteRequest) error
	WriteTagged(ctx thrift.Context, req *WriteTaggedRequest) error
}

TChanCluster is the interface that defines the server handler and client interface.

func NewTChanClusterClient

func NewTChanClusterClient(client thrift.TChanClient) TChanCluster

NewTChanClusterClient creates a client that can be used to make remote calls.

type TChanNode

type TChanNode interface {
	Aggregate(ctx thrift.Context, req *AggregateQueryRequest) (*AggregateQueryResult_, error)
	AggregateRaw(ctx thrift.Context, req *AggregateQueryRawRequest) (*AggregateQueryRawResult_, error)
	AggregateTiles(ctx thrift.Context, req *AggregateTilesRequest) (*AggregateTilesResult_, error)
	Bootstrapped(ctx thrift.Context) (*NodeBootstrappedResult_, error)
	BootstrappedInPlacementOrNoPlacement(ctx thrift.Context) (*NodeBootstrappedInPlacementOrNoPlacementResult_, error)
	DebugIndexMemorySegments(ctx thrift.Context, req *DebugIndexMemorySegmentsRequest) (*DebugIndexMemorySegmentsResult_, error)
	DebugProfileStart(ctx thrift.Context, req *DebugProfileStartRequest) (*DebugProfileStartResult_, error)
	DebugProfileStop(ctx thrift.Context, req *DebugProfileStopRequest) (*DebugProfileStopResult_, error)
	Fetch(ctx thrift.Context, req *FetchRequest) (*FetchResult_, error)
	FetchBatchRaw(ctx thrift.Context, req *FetchBatchRawRequest) (*FetchBatchRawResult_, error)
	FetchBatchRawV2(ctx thrift.Context, req *FetchBatchRawV2Request) (*FetchBatchRawResult_, error)
	FetchBlocksMetadataRawV2(ctx thrift.Context, req *FetchBlocksMetadataRawV2Request) (*FetchBlocksMetadataRawV2Result_, error)
	FetchBlocksRaw(ctx thrift.Context, req *FetchBlocksRawRequest) (*FetchBlocksRawResult_, error)
	FetchTagged(ctx thrift.Context, req *FetchTaggedRequest) (*FetchTaggedResult_, error)
	GetPersistRateLimit(ctx thrift.Context) (*NodePersistRateLimitResult_, error)
	GetWriteNewSeriesAsync(ctx thrift.Context) (*NodeWriteNewSeriesAsyncResult_, error)
	GetWriteNewSeriesBackoffDuration(ctx thrift.Context) (*NodeWriteNewSeriesBackoffDurationResult_, error)
	GetWriteNewSeriesLimitPerShardPerSecond(ctx thrift.Context) (*NodeWriteNewSeriesLimitPerShardPerSecondResult_, error)
	Health(ctx thrift.Context) (*NodeHealthResult_, error)
	Query(ctx thrift.Context, req *QueryRequest) (*QueryResult_, error)
	Repair(ctx thrift.Context) error
	SetPersistRateLimit(ctx thrift.Context, req *NodeSetPersistRateLimitRequest) (*NodePersistRateLimitResult_, error)
	SetWriteNewSeriesAsync(ctx thrift.Context, req *NodeSetWriteNewSeriesAsyncRequest) (*NodeWriteNewSeriesAsyncResult_, error)
	SetWriteNewSeriesBackoffDuration(ctx thrift.Context, req *NodeSetWriteNewSeriesBackoffDurationRequest) (*NodeWriteNewSeriesBackoffDurationResult_, error)
	SetWriteNewSeriesLimitPerShardPerSecond(ctx thrift.Context, req *NodeSetWriteNewSeriesLimitPerShardPerSecondRequest) (*NodeWriteNewSeriesLimitPerShardPerSecondResult_, error)
	Truncate(ctx thrift.Context, req *TruncateRequest) (*TruncateResult_, error)
	Write(ctx thrift.Context, req *WriteRequest) error
	WriteBatchRaw(ctx thrift.Context, req *WriteBatchRawRequest) error
	WriteBatchRawV2(ctx thrift.Context, req *WriteBatchRawV2Request) error
	WriteTagged(ctx thrift.Context, req *WriteTaggedRequest) error
	WriteTaggedBatchRaw(ctx thrift.Context, req *WriteTaggedBatchRawRequest) error
	WriteTaggedBatchRawV2(ctx thrift.Context, req *WriteTaggedBatchRawV2Request) error
}

TChanNode is the interface that defines the server handler and client interface.

func NewTChanNodeClient

func NewTChanNodeClient(client thrift.TChanClient) TChanNode

NewTChanNodeClient creates a client that can be used to make remote calls.

type Tag

type Tag struct {
	Name  string `thrift:"name,1,required" db:"name" json:"name"`
	Value string `thrift:"value,2,required" db:"value" json:"value"`
}

Attributes:

  • Name
  • Value

func NewTag

func NewTag() *Tag

func (*Tag) GetName

func (p *Tag) GetName() string

func (*Tag) GetValue

func (p *Tag) GetValue() string

func (*Tag) Read

func (p *Tag) Read(iprot thrift.TProtocol) error

func (*Tag) ReadField1

func (p *Tag) ReadField1(iprot thrift.TProtocol) error

func (*Tag) ReadField2

func (p *Tag) ReadField2(iprot thrift.TProtocol) error

func (*Tag) String

func (p *Tag) String() string

func (*Tag) Write

func (p *Tag) Write(oprot thrift.TProtocol) error

type TermQuery

type TermQuery struct {
	Field string `thrift:"field,1,required" db:"field" json:"field"`
	Term  string `thrift:"term,2,required" db:"term" json:"term"`
}

Attributes:

  • Field
  • Term
var Query_Term_DEFAULT *TermQuery

func NewTermQuery

func NewTermQuery() *TermQuery

func (*TermQuery) GetField

func (p *TermQuery) GetField() string

func (*TermQuery) GetTerm

func (p *TermQuery) GetTerm() string

func (*TermQuery) Read

func (p *TermQuery) Read(iprot thrift.TProtocol) error

func (*TermQuery) ReadField1

func (p *TermQuery) ReadField1(iprot thrift.TProtocol) error

func (*TermQuery) ReadField2

func (p *TermQuery) ReadField2(iprot thrift.TProtocol) error

func (*TermQuery) String

func (p *TermQuery) String() string

func (*TermQuery) Write

func (p *TermQuery) Write(oprot thrift.TProtocol) error

type TimeType

type TimeType int64
const (
	TimeType_UNIX_SECONDS      TimeType = 0
	TimeType_UNIX_MICROSECONDS TimeType = 1
	TimeType_UNIX_MILLISECONDS TimeType = 2
	TimeType_UNIX_NANOSECONDS  TimeType = 3
)
var AggregateQueryRawRequest_RangeType_DEFAULT TimeType = 0
var AggregateQueryRequest_RangeType_DEFAULT TimeType = 0
var AggregateTilesRequest_RangeType_DEFAULT TimeType = 0
var BlockMetadataV2_LastReadTimeType_DEFAULT TimeType = 0
var Datapoint_TimestampTimeType_DEFAULT TimeType = 0
var FetchBatchRawRequest_RangeTimeType_DEFAULT TimeType = 0
var FetchBatchRawV2RequestElement_RangeTimeType_DEFAULT TimeType = 0
var FetchRequest_RangeType_DEFAULT TimeType = 0
var FetchRequest_ResultTimeType_DEFAULT TimeType = 0
var FetchTaggedRequest_RangeTimeType_DEFAULT TimeType = 0
var NodeSetWriteNewSeriesBackoffDurationRequest_DurationType_DEFAULT TimeType = 2
var QueryRequest_RangeType_DEFAULT TimeType = 0
var QueryRequest_ResultTimeType_DEFAULT TimeType = 0

func TimeTypeFromString

func TimeTypeFromString(s string) (TimeType, error)

func TimeTypePtr

func TimeTypePtr(v TimeType) *TimeType

func (TimeType) MarshalText

func (p TimeType) MarshalText() ([]byte, error)

func (*TimeType) Scan

func (p *TimeType) Scan(value interface{}) error

func (TimeType) String

func (p TimeType) String() string

func (*TimeType) UnmarshalText

func (p *TimeType) UnmarshalText(text []byte) error

func (*TimeType) Value

func (p *TimeType) Value() (driver.Value, error)

type TruncateRequest

type TruncateRequest struct {
	NameSpace []byte `thrift:"nameSpace,1,required" db:"nameSpace" json:"nameSpace"`
}

Attributes:

  • NameSpace
var ClusterTruncateArgs_Req_DEFAULT *TruncateRequest
var NodeTruncateArgs_Req_DEFAULT *TruncateRequest

func NewTruncateRequest

func NewTruncateRequest() *TruncateRequest

func (*TruncateRequest) GetNameSpace

func (p *TruncateRequest) GetNameSpace() []byte

func (*TruncateRequest) Read

func (p *TruncateRequest) Read(iprot thrift.TProtocol) error

func (*TruncateRequest) ReadField1

func (p *TruncateRequest) ReadField1(iprot thrift.TProtocol) error

func (*TruncateRequest) String

func (p *TruncateRequest) String() string

func (*TruncateRequest) Write

func (p *TruncateRequest) Write(oprot thrift.TProtocol) error

type TruncateResult_

type TruncateResult_ struct {
	NumSeries int64 `thrift:"numSeries,1,required" db:"numSeries" json:"numSeries"`
}

Attributes:

  • NumSeries
var ClusterTruncateResult_Success_DEFAULT *TruncateResult_
var NodeTruncateResult_Success_DEFAULT *TruncateResult_

func NewTruncateResult_

func NewTruncateResult_() *TruncateResult_

func (*TruncateResult_) GetNumSeries

func (p *TruncateResult_) GetNumSeries() int64

func (*TruncateResult_) Read

func (p *TruncateResult_) Read(iprot thrift.TProtocol) error

func (*TruncateResult_) ReadField1

func (p *TruncateResult_) ReadField1(iprot thrift.TProtocol) error

func (*TruncateResult_) String

func (p *TruncateResult_) String() string

func (*TruncateResult_) Write

func (p *TruncateResult_) Write(oprot thrift.TProtocol) error

type WriteBatchRawError

type WriteBatchRawError struct {
	Index int64  `thrift:"index,1,required" db:"index" json:"index"`
	Err   *Error `thrift:"err,2,required" db:"err" json:"err"`
}

Attributes:

  • Index
  • Err

func NewWriteBatchRawError

func NewWriteBatchRawError() *WriteBatchRawError

func (*WriteBatchRawError) GetErr

func (p *WriteBatchRawError) GetErr() *Error

func (*WriteBatchRawError) GetIndex

func (p *WriteBatchRawError) GetIndex() int64

func (*WriteBatchRawError) IsSetErr

func (p *WriteBatchRawError) IsSetErr() bool

func (*WriteBatchRawError) Read

func (p *WriteBatchRawError) Read(iprot thrift.TProtocol) error

func (*WriteBatchRawError) ReadField1

func (p *WriteBatchRawError) ReadField1(iprot thrift.TProtocol) error

func (*WriteBatchRawError) ReadField2

func (p *WriteBatchRawError) ReadField2(iprot thrift.TProtocol) error

func (*WriteBatchRawError) String

func (p *WriteBatchRawError) String() string

func (*WriteBatchRawError) Write

func (p *WriteBatchRawError) Write(oprot thrift.TProtocol) error

type WriteBatchRawErrors

type WriteBatchRawErrors struct {
	Errors []*WriteBatchRawError `thrift:"errors,1,required" db:"errors" json:"errors"`
}

Attributes:

  • Errors
var NodeWriteBatchRawResult_Err_DEFAULT *WriteBatchRawErrors
var NodeWriteBatchRawV2Result_Err_DEFAULT *WriteBatchRawErrors
var NodeWriteTaggedBatchRawResult_Err_DEFAULT *WriteBatchRawErrors
var NodeWriteTaggedBatchRawV2Result_Err_DEFAULT *WriteBatchRawErrors

func NewWriteBatchRawErrors

func NewWriteBatchRawErrors() *WriteBatchRawErrors

func (*WriteBatchRawErrors) Error

func (p *WriteBatchRawErrors) Error() string

func (*WriteBatchRawErrors) GetErrors

func (p *WriteBatchRawErrors) GetErrors() []*WriteBatchRawError

func (*WriteBatchRawErrors) Read

func (p *WriteBatchRawErrors) Read(iprot thrift.TProtocol) error

func (*WriteBatchRawErrors) ReadField1

func (p *WriteBatchRawErrors) ReadField1(iprot thrift.TProtocol) error

func (*WriteBatchRawErrors) String

func (p *WriteBatchRawErrors) String() string

func (*WriteBatchRawErrors) Write

func (p *WriteBatchRawErrors) Write(oprot thrift.TProtocol) error

type WriteBatchRawRequest

type WriteBatchRawRequest struct {
	NameSpace []byte                         `thrift:"nameSpace,1,required" db:"nameSpace" json:"nameSpace"`
	Elements  []*WriteBatchRawRequestElement `thrift:"elements,2,required" db:"elements" json:"elements"`
}

Attributes:

  • NameSpace
  • Elements
var NodeWriteBatchRawArgs_Req_DEFAULT *WriteBatchRawRequest

func NewWriteBatchRawRequest

func NewWriteBatchRawRequest() *WriteBatchRawRequest

func (*WriteBatchRawRequest) GetElements

func (*WriteBatchRawRequest) GetNameSpace

func (p *WriteBatchRawRequest) GetNameSpace() []byte

func (*WriteBatchRawRequest) Read

func (p *WriteBatchRawRequest) Read(iprot thrift.TProtocol) error

func (*WriteBatchRawRequest) ReadField1

func (p *WriteBatchRawRequest) ReadField1(iprot thrift.TProtocol) error

func (*WriteBatchRawRequest) ReadField2

func (p *WriteBatchRawRequest) ReadField2(iprot thrift.TProtocol) error

func (*WriteBatchRawRequest) String

func (p *WriteBatchRawRequest) String() string

func (*WriteBatchRawRequest) Write

func (p *WriteBatchRawRequest) Write(oprot thrift.TProtocol) error

type WriteBatchRawRequestElement

type WriteBatchRawRequestElement struct {
	ID        []byte     `thrift:"id,1,required" db:"id" json:"id"`
	Datapoint *Datapoint `thrift:"datapoint,2,required" db:"datapoint" json:"datapoint"`
}

Attributes:

  • ID
  • Datapoint

func NewWriteBatchRawRequestElement

func NewWriteBatchRawRequestElement() *WriteBatchRawRequestElement

func (*WriteBatchRawRequestElement) GetDatapoint

func (p *WriteBatchRawRequestElement) GetDatapoint() *Datapoint

func (*WriteBatchRawRequestElement) GetID

func (p *WriteBatchRawRequestElement) GetID() []byte

func (*WriteBatchRawRequestElement) IsSetDatapoint

func (p *WriteBatchRawRequestElement) IsSetDatapoint() bool

func (*WriteBatchRawRequestElement) Read

func (*WriteBatchRawRequestElement) ReadField1

func (p *WriteBatchRawRequestElement) ReadField1(iprot thrift.TProtocol) error

func (*WriteBatchRawRequestElement) ReadField2

func (p *WriteBatchRawRequestElement) ReadField2(iprot thrift.TProtocol) error

func (*WriteBatchRawRequestElement) String

func (p *WriteBatchRawRequestElement) String() string

func (*WriteBatchRawRequestElement) Write

type WriteBatchRawV2Request added in v0.14.0

type WriteBatchRawV2Request struct {
	NameSpaces [][]byte                         `thrift:"nameSpaces,1,required" db:"nameSpaces" json:"nameSpaces"`
	Elements   []*WriteBatchRawV2RequestElement `thrift:"elements,2,required" db:"elements" json:"elements"`
}

Attributes:

  • NameSpaces
  • Elements
var NodeWriteBatchRawV2Args_Req_DEFAULT *WriteBatchRawV2Request

func NewWriteBatchRawV2Request added in v0.14.0

func NewWriteBatchRawV2Request() *WriteBatchRawV2Request

func (*WriteBatchRawV2Request) GetElements added in v0.14.0

func (*WriteBatchRawV2Request) GetNameSpaces added in v0.14.0

func (p *WriteBatchRawV2Request) GetNameSpaces() [][]byte

func (*WriteBatchRawV2Request) Read added in v0.14.0

func (*WriteBatchRawV2Request) ReadField1 added in v0.14.0

func (p *WriteBatchRawV2Request) ReadField1(iprot thrift.TProtocol) error

func (*WriteBatchRawV2Request) ReadField2 added in v0.14.0

func (p *WriteBatchRawV2Request) ReadField2(iprot thrift.TProtocol) error

func (*WriteBatchRawV2Request) String added in v0.14.0

func (p *WriteBatchRawV2Request) String() string

func (*WriteBatchRawV2Request) Write added in v0.14.0

func (p *WriteBatchRawV2Request) Write(oprot thrift.TProtocol) error

type WriteBatchRawV2RequestElement added in v0.14.0

type WriteBatchRawV2RequestElement struct {
	ID        []byte     `thrift:"id,1,required" db:"id" json:"id"`
	Datapoint *Datapoint `thrift:"datapoint,2,required" db:"datapoint" json:"datapoint"`
	NameSpace int64      `thrift:"nameSpace,3,required" db:"nameSpace" json:"nameSpace"`
}

Attributes:

  • ID
  • Datapoint
  • NameSpace

func NewWriteBatchRawV2RequestElement added in v0.14.0

func NewWriteBatchRawV2RequestElement() *WriteBatchRawV2RequestElement

func (*WriteBatchRawV2RequestElement) GetDatapoint added in v0.14.0

func (p *WriteBatchRawV2RequestElement) GetDatapoint() *Datapoint

func (*WriteBatchRawV2RequestElement) GetID added in v0.14.0

func (p *WriteBatchRawV2RequestElement) GetID() []byte

func (*WriteBatchRawV2RequestElement) GetNameSpace added in v0.14.0

func (p *WriteBatchRawV2RequestElement) GetNameSpace() int64

func (*WriteBatchRawV2RequestElement) IsSetDatapoint added in v0.14.0

func (p *WriteBatchRawV2RequestElement) IsSetDatapoint() bool

func (*WriteBatchRawV2RequestElement) Read added in v0.14.0

func (*WriteBatchRawV2RequestElement) ReadField1 added in v0.14.0

func (p *WriteBatchRawV2RequestElement) ReadField1(iprot thrift.TProtocol) error

func (*WriteBatchRawV2RequestElement) ReadField2 added in v0.14.0

func (p *WriteBatchRawV2RequestElement) ReadField2(iprot thrift.TProtocol) error

func (*WriteBatchRawV2RequestElement) ReadField3 added in v0.14.0

func (p *WriteBatchRawV2RequestElement) ReadField3(iprot thrift.TProtocol) error

func (*WriteBatchRawV2RequestElement) String added in v0.14.0

func (*WriteBatchRawV2RequestElement) Write added in v0.14.0

type WriteRequest

type WriteRequest struct {
	NameSpace string     `thrift:"nameSpace,1,required" db:"nameSpace" json:"nameSpace"`
	ID        string     `thrift:"id,2,required" db:"id" json:"id"`
	Datapoint *Datapoint `thrift:"datapoint,3,required" db:"datapoint" json:"datapoint"`
}

Attributes:

  • NameSpace
  • ID
  • Datapoint
var ClusterWriteArgs_Req_DEFAULT *WriteRequest
var NodeWriteArgs_Req_DEFAULT *WriteRequest

func NewWriteRequest

func NewWriteRequest() *WriteRequest

func (*WriteRequest) GetDatapoint

func (p *WriteRequest) GetDatapoint() *Datapoint

func (*WriteRequest) GetID

func (p *WriteRequest) GetID() string

func (*WriteRequest) GetNameSpace

func (p *WriteRequest) GetNameSpace() string

func (*WriteRequest) IsSetDatapoint

func (p *WriteRequest) IsSetDatapoint() bool

func (*WriteRequest) Read

func (p *WriteRequest) Read(iprot thrift.TProtocol) error

func (*WriteRequest) ReadField1

func (p *WriteRequest) ReadField1(iprot thrift.TProtocol) error

func (*WriteRequest) ReadField2

func (p *WriteRequest) ReadField2(iprot thrift.TProtocol) error

func (*WriteRequest) ReadField3

func (p *WriteRequest) ReadField3(iprot thrift.TProtocol) error

func (*WriteRequest) String

func (p *WriteRequest) String() string

func (*WriteRequest) Write

func (p *WriteRequest) Write(oprot thrift.TProtocol) error

type WriteTaggedBatchRawRequest

type WriteTaggedBatchRawRequest struct {
	NameSpace []byte                               `thrift:"nameSpace,1,required" db:"nameSpace" json:"nameSpace"`
	Elements  []*WriteTaggedBatchRawRequestElement `thrift:"elements,2,required" db:"elements" json:"elements"`
}

Attributes:

  • NameSpace
  • Elements
var NodeWriteTaggedBatchRawArgs_Req_DEFAULT *WriteTaggedBatchRawRequest

func NewWriteTaggedBatchRawRequest

func NewWriteTaggedBatchRawRequest() *WriteTaggedBatchRawRequest

func (*WriteTaggedBatchRawRequest) GetElements

func (*WriteTaggedBatchRawRequest) GetNameSpace

func (p *WriteTaggedBatchRawRequest) GetNameSpace() []byte

func (*WriteTaggedBatchRawRequest) Read

func (*WriteTaggedBatchRawRequest) ReadField1

func (p *WriteTaggedBatchRawRequest) ReadField1(iprot thrift.TProtocol) error

func (*WriteTaggedBatchRawRequest) ReadField2

func (p *WriteTaggedBatchRawRequest) ReadField2(iprot thrift.TProtocol) error

func (*WriteTaggedBatchRawRequest) String

func (p *WriteTaggedBatchRawRequest) String() string

func (*WriteTaggedBatchRawRequest) Write

type WriteTaggedBatchRawRequestElement

type WriteTaggedBatchRawRequestElement struct {
	ID          []byte     `thrift:"id,1,required" db:"id" json:"id"`
	EncodedTags []byte     `thrift:"encodedTags,2,required" db:"encodedTags" json:"encodedTags"`
	Datapoint   *Datapoint `thrift:"datapoint,3,required" db:"datapoint" json:"datapoint"`
}

Attributes:

  • ID
  • EncodedTags
  • Datapoint

func NewWriteTaggedBatchRawRequestElement

func NewWriteTaggedBatchRawRequestElement() *WriteTaggedBatchRawRequestElement

func (*WriteTaggedBatchRawRequestElement) GetDatapoint

func (p *WriteTaggedBatchRawRequestElement) GetDatapoint() *Datapoint

func (*WriteTaggedBatchRawRequestElement) GetEncodedTags

func (p *WriteTaggedBatchRawRequestElement) GetEncodedTags() []byte

func (*WriteTaggedBatchRawRequestElement) GetID

func (*WriteTaggedBatchRawRequestElement) IsSetDatapoint

func (p *WriteTaggedBatchRawRequestElement) IsSetDatapoint() bool

func (*WriteTaggedBatchRawRequestElement) Read

func (*WriteTaggedBatchRawRequestElement) ReadField1

func (*WriteTaggedBatchRawRequestElement) ReadField2

func (*WriteTaggedBatchRawRequestElement) ReadField3

func (*WriteTaggedBatchRawRequestElement) String

func (*WriteTaggedBatchRawRequestElement) Write

type WriteTaggedBatchRawV2Request added in v0.14.0

type WriteTaggedBatchRawV2Request struct {
	NameSpaces [][]byte                               `thrift:"nameSpaces,1,required" db:"nameSpaces" json:"nameSpaces"`
	Elements   []*WriteTaggedBatchRawV2RequestElement `thrift:"elements,2,required" db:"elements" json:"elements"`
}

Attributes:

  • NameSpaces
  • Elements
var NodeWriteTaggedBatchRawV2Args_Req_DEFAULT *WriteTaggedBatchRawV2Request

func NewWriteTaggedBatchRawV2Request added in v0.14.0

func NewWriteTaggedBatchRawV2Request() *WriteTaggedBatchRawV2Request

func (*WriteTaggedBatchRawV2Request) GetElements added in v0.14.0

func (*WriteTaggedBatchRawV2Request) GetNameSpaces added in v0.14.0

func (p *WriteTaggedBatchRawV2Request) GetNameSpaces() [][]byte

func (*WriteTaggedBatchRawV2Request) Read added in v0.14.0

func (*WriteTaggedBatchRawV2Request) ReadField1 added in v0.14.0

func (p *WriteTaggedBatchRawV2Request) ReadField1(iprot thrift.TProtocol) error

func (*WriteTaggedBatchRawV2Request) ReadField2 added in v0.14.0

func (p *WriteTaggedBatchRawV2Request) ReadField2(iprot thrift.TProtocol) error

func (*WriteTaggedBatchRawV2Request) String added in v0.14.0

func (*WriteTaggedBatchRawV2Request) Write added in v0.14.0

type WriteTaggedBatchRawV2RequestElement added in v0.14.0

type WriteTaggedBatchRawV2RequestElement struct {
	ID          []byte     `thrift:"id,1,required" db:"id" json:"id"`
	EncodedTags []byte     `thrift:"encodedTags,2,required" db:"encodedTags" json:"encodedTags"`
	Datapoint   *Datapoint `thrift:"datapoint,3,required" db:"datapoint" json:"datapoint"`
	NameSpace   int64      `thrift:"nameSpace,4,required" db:"nameSpace" json:"nameSpace"`
}

Attributes:

  • ID
  • EncodedTags
  • Datapoint
  • NameSpace

func NewWriteTaggedBatchRawV2RequestElement added in v0.14.0

func NewWriteTaggedBatchRawV2RequestElement() *WriteTaggedBatchRawV2RequestElement

func (*WriteTaggedBatchRawV2RequestElement) GetDatapoint added in v0.14.0

func (*WriteTaggedBatchRawV2RequestElement) GetEncodedTags added in v0.14.0

func (p *WriteTaggedBatchRawV2RequestElement) GetEncodedTags() []byte

func (*WriteTaggedBatchRawV2RequestElement) GetID added in v0.14.0

func (*WriteTaggedBatchRawV2RequestElement) GetNameSpace added in v0.14.0

func (p *WriteTaggedBatchRawV2RequestElement) GetNameSpace() int64

func (*WriteTaggedBatchRawV2RequestElement) IsSetDatapoint added in v0.14.0

func (p *WriteTaggedBatchRawV2RequestElement) IsSetDatapoint() bool

func (*WriteTaggedBatchRawV2RequestElement) Read added in v0.14.0

func (*WriteTaggedBatchRawV2RequestElement) ReadField1 added in v0.14.0

func (*WriteTaggedBatchRawV2RequestElement) ReadField2 added in v0.14.0

func (*WriteTaggedBatchRawV2RequestElement) ReadField3 added in v0.14.0

func (*WriteTaggedBatchRawV2RequestElement) ReadField4 added in v0.14.0

func (*WriteTaggedBatchRawV2RequestElement) String added in v0.14.0

func (*WriteTaggedBatchRawV2RequestElement) Write added in v0.14.0

type WriteTaggedRequest

type WriteTaggedRequest struct {
	NameSpace string     `thrift:"nameSpace,1,required" db:"nameSpace" json:"nameSpace"`
	ID        string     `thrift:"id,2,required" db:"id" json:"id"`
	Tags      []*Tag     `thrift:"tags,3,required" db:"tags" json:"tags"`
	Datapoint *Datapoint `thrift:"datapoint,4,required" db:"datapoint" json:"datapoint"`
}

Attributes:

  • NameSpace
  • ID
  • Tags
  • Datapoint
var ClusterWriteTaggedArgs_Req_DEFAULT *WriteTaggedRequest
var NodeWriteTaggedArgs_Req_DEFAULT *WriteTaggedRequest

func NewWriteTaggedRequest

func NewWriteTaggedRequest() *WriteTaggedRequest

func (*WriteTaggedRequest) GetDatapoint

func (p *WriteTaggedRequest) GetDatapoint() *Datapoint

func (*WriteTaggedRequest) GetID

func (p *WriteTaggedRequest) GetID() string

func (*WriteTaggedRequest) GetNameSpace

func (p *WriteTaggedRequest) GetNameSpace() string

func (*WriteTaggedRequest) GetTags

func (p *WriteTaggedRequest) GetTags() []*Tag

func (*WriteTaggedRequest) IsSetDatapoint

func (p *WriteTaggedRequest) IsSetDatapoint() bool

func (*WriteTaggedRequest) Read

func (p *WriteTaggedRequest) Read(iprot thrift.TProtocol) error

func (*WriteTaggedRequest) ReadField1

func (p *WriteTaggedRequest) ReadField1(iprot thrift.TProtocol) error

func (*WriteTaggedRequest) ReadField2

func (p *WriteTaggedRequest) ReadField2(iprot thrift.TProtocol) error

func (*WriteTaggedRequest) ReadField3

func (p *WriteTaggedRequest) ReadField3(iprot thrift.TProtocol) error

func (*WriteTaggedRequest) ReadField4

func (p *WriteTaggedRequest) ReadField4(iprot thrift.TProtocol) error

func (*WriteTaggedRequest) String

func (p *WriteTaggedRequest) String() string

func (*WriteTaggedRequest) Write

func (p *WriteTaggedRequest) Write(oprot thrift.TProtocol) error

Jump to

Keyboard shortcuts

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