rpc

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Sep 10, 2021 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_DocsLimit_DEFAULT int64
View Source 
var AggregateQueryRawRequest_RequireExhaustive_DEFAULT bool
View Source 
var AggregateQueryRawRequest_RequireNoWait_DEFAULT bool
View Source 
var AggregateQueryRawRequest_SeriesLimit_DEFAULT int64
View Source 
var AggregateQueryRawRequest_Source_DEFAULT []byte
View Source 
var AggregateQueryRawRequest_TagNameFilter_DEFAULT [][]byte
View Source 
var AggregateQueryRawResultTagNameElement_TagValues_DEFAULT []*AggregateQueryRawResultTagValueElement
View Source 
var AggregateQueryRawResult__WaitedIndex_DEFAULT int64
View Source 
var AggregateQueryRequest_DocsLimit_DEFAULT int64
View Source 
var AggregateQueryRequest_RequireExhaustive_DEFAULT bool
View Source 
var AggregateQueryRequest_RequireNoWait_DEFAULT bool
View Source 
var AggregateQueryRequest_SeriesLimit_DEFAULT int64
View Source 
var AggregateQueryRequest_Source_DEFAULT []byte
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 Error_Flags_DEFAULT int64 = 0
View Source 
var FetchBatchRawRequest_Source_DEFAULT []byte
View Source 
var FetchBatchRawV2Request_Source_DEFAULT []byte
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 FetchBlocksRawRequest_Source_DEFAULT []byte
View Source 
var FetchRequest_Source_DEFAULT []byte
View Source 
var FetchTaggedIDResult__Segments_DEFAULT []*Segments
View Source 
var FetchTaggedRequest_DocsLimit_DEFAULT int64
View Source 
var FetchTaggedRequest_RequireExhaustive_DEFAULT bool = true
View Source 
var FetchTaggedRequest_RequireNoWait_DEFAULT bool = false
View Source 
var FetchTaggedRequest_SeriesLimit_DEFAULT int64
View Source 
var FetchTaggedRequest_Source_DEFAULT []byte
View Source 
var FetchTaggedResult__WaitedIndex_DEFAULT int64
View Source 
var FetchTaggedResult__WaitedSeriesRead_DEFAULT int64
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 QueryRequest_Source_DEFAULT []byte
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"`
	SeriesLimit        *int64             `thrift:"seriesLimit,5" db:"seriesLimit" json:"seriesLimit,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"`
	Source             []byte             `thrift:"source,9" db:"source" json:"source,omitempty"`
	DocsLimit          *int64             `thrift:"docsLimit,10" db:"docsLimit" json:"docsLimit,omitempty"`
	RequireExhaustive  *bool              `thrift:"requireExhaustive,11" db:"requireExhaustive" json:"requireExhaustive,omitempty"`
	RequireNoWait      *bool              `thrift:"requireNoWait,12" db:"requireNoWait" json:"requireNoWait,omitempty"`
}

Attributes:

  • Query
  • RangeStart
  • RangeEnd
  • NameSpace
  • SeriesLimit
  • TagNameFilter
  • AggregateQueryType
  • RangeType
  • Source
  • DocsLimit
  • RequireExhaustive
  • RequireNoWait
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) GetDocsLimit added in v1.0.1 

func (p *AggregateQueryRawRequest) GetDocsLimit() 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) GetRequireExhaustive added in v1.2.0 

func (p *AggregateQueryRawRequest) GetRequireExhaustive() bool

func (*AggregateQueryRawRequest) GetRequireNoWait added in v1.2.0 

func (p *AggregateQueryRawRequest) GetRequireNoWait() bool

func (*AggregateQueryRawRequest) GetSeriesLimit added in v1.0.1 

func (p *AggregateQueryRawRequest) GetSeriesLimit() int64

func (*AggregateQueryRawRequest) GetSource added in v1.0.1 

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

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) IsSetDocsLimit added in v1.0.1 

func (p *AggregateQueryRawRequest) IsSetDocsLimit() bool

func (*AggregateQueryRawRequest) IsSetRangeType added in v0.7.3 

func (p *AggregateQueryRawRequest) IsSetRangeType() bool

func (*AggregateQueryRawRequest) IsSetRequireExhaustive added in v1.2.0 

func (p *AggregateQueryRawRequest) IsSetRequireExhaustive() bool

func (*AggregateQueryRawRequest) IsSetRequireNoWait added in v1.2.0 

func (p *AggregateQueryRawRequest) IsSetRequireNoWait() bool

func (*AggregateQueryRawRequest) IsSetSeriesLimit added in v1.0.1 

func (p *AggregateQueryRawRequest) IsSetSeriesLimit() bool

func (*AggregateQueryRawRequest) IsSetSource added in v1.0.1 

func (p *AggregateQueryRawRequest) IsSetSource() bool

func (*AggregateQueryRawRequest) IsSetTagNameFilter added in v0.7.3 

func (p *AggregateQueryRawRequest) IsSetTagNameFilter() bool

func (*AggregateQueryRawRequest) Read added in v0.7.3 

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

func (*AggregateQueryRawRequest) ReadField1 added in v0.7.3 

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

func (*AggregateQueryRawRequest) ReadField10 added in v1.0.1 

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

func (*AggregateQueryRawRequest) ReadField11 added in v1.2.0 

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

func (*AggregateQueryRawRequest) ReadField12 added in v1.2.0 

func (p *AggregateQueryRawRequest) ReadField12(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) ReadField9 added in v1.0.1 

func (p *AggregateQueryRawRequest) ReadField9(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 

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

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 (p *AggregateQueryRawResultTagNameElement) GetTagValues() []*AggregateQueryRawResultTagValueElement

func (*AggregateQueryRawResultTagNameElement) IsSetTagValues added in v0.7.3 

func (p *AggregateQueryRawResultTagNameElement) IsSetTagValues() bool

func (*AggregateQueryRawResultTagNameElement) Read added in v0.7.3 

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

func (*AggregateQueryRawResultTagNameElement) ReadField1 added in v0.7.3 

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

func (*AggregateQueryRawResultTagNameElement) ReadField2 added in v0.7.3 

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

func (*AggregateQueryRawResultTagNameElement) String added in v0.7.3 

func (p *AggregateQueryRawResultTagNameElement) String() string

func (*AggregateQueryRawResultTagNameElement) Write added in v0.7.3 

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

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 (p *AggregateQueryRawResultTagValueElement) Read(iprot thrift.TProtocol) error

func (*AggregateQueryRawResultTagValueElement) ReadField1 added in v0.7.3 

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

func (*AggregateQueryRawResultTagValueElement) String added in v0.7.3 

func (p *AggregateQueryRawResultTagValueElement) String() string

func (*AggregateQueryRawResultTagValueElement) Write added in v0.7.3 

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

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"`
	WaitedIndex *int64                                   `thrift:"waitedIndex,3" db:"waitedIndex" json:"waitedIndex,omitempty"`
}

Attributes:

  • Results
  • Exhaustive
  • WaitedIndex
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 (p *AggregateQueryRawResult_) GetResults() []*AggregateQueryRawResultTagNameElement

func (*AggregateQueryRawResult_) GetWaitedIndex added in v1.2.0 

func (p *AggregateQueryRawResult_) GetWaitedIndex() int64

func (*AggregateQueryRawResult_) IsSetWaitedIndex added in v1.2.0 

func (p *AggregateQueryRawResult_) IsSetWaitedIndex() bool

func (*AggregateQueryRawResult_) Read added in v0.7.3 

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

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_) ReadField3 added in v1.2.0 

func (p *AggregateQueryRawResult_) ReadField3(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 

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

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"`
	SeriesLimit        *int64             `thrift:"seriesLimit,5" db:"seriesLimit" json:"seriesLimit,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"`
	Source             []byte             `thrift:"source,9" db:"source" json:"source,omitempty"`
	DocsLimit          *int64             `thrift:"docsLimit,10" db:"docsLimit" json:"docsLimit,omitempty"`
	RequireExhaustive  *bool              `thrift:"requireExhaustive,11" db:"requireExhaustive" json:"requireExhaustive,omitempty"`
	RequireNoWait      *bool              `thrift:"requireNoWait,12" db:"requireNoWait" json:"requireNoWait,omitempty"`
}

Attributes:

  • Query
  • RangeStart
  • RangeEnd
  • NameSpace
  • SeriesLimit
  • TagNameFilter
  • AggregateQueryType
  • RangeType
  • Source
  • DocsLimit
  • RequireExhaustive
  • RequireNoWait
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) GetDocsLimit added in v1.0.1 

func (p *AggregateQueryRequest) GetDocsLimit() 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) GetRequireExhaustive added in v1.2.0 

func (p *AggregateQueryRequest) GetRequireExhaustive() bool

func (*AggregateQueryRequest) GetRequireNoWait added in v1.2.0 

func (p *AggregateQueryRequest) GetRequireNoWait() bool

func (*AggregateQueryRequest) GetSeriesLimit added in v1.0.1 

func (p *AggregateQueryRequest) GetSeriesLimit() int64

func (*AggregateQueryRequest) GetSource added in v1.0.1 

func (p *AggregateQueryRequest) GetSource() []byte

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) IsSetDocsLimit added in v1.0.1 

func (p *AggregateQueryRequest) IsSetDocsLimit() 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) IsSetRequireExhaustive added in v1.2.0 

func (p *AggregateQueryRequest) IsSetRequireExhaustive() bool

func (*AggregateQueryRequest) IsSetRequireNoWait added in v1.2.0 

func (p *AggregateQueryRequest) IsSetRequireNoWait() bool

func (*AggregateQueryRequest) IsSetSeriesLimit added in v1.0.1 

func (p *AggregateQueryRequest) IsSetSeriesLimit() bool

func (*AggregateQueryRequest) IsSetSource added in v1.0.1 

func (p *AggregateQueryRequest) IsSetSource() bool

func (*AggregateQueryRequest) IsSetTagNameFilter added in v0.7.3 

func (p *AggregateQueryRequest) IsSetTagNameFilter() bool

func (*AggregateQueryRequest) Read added in v0.7.3 

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

func (*AggregateQueryRequest) ReadField1 added in v0.7.3 

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

func (*AggregateQueryRequest) ReadField10 added in v1.0.1 

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

func (*AggregateQueryRequest) ReadField11 added in v1.2.0 

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

func (*AggregateQueryRequest) ReadField12 added in v1.2.0 

func (p *AggregateQueryRequest) ReadField12(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) ReadField9 added in v1.0.1 

func (p *AggregateQueryRequest) ReadField9(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 (p *AggregateQueryResultTagNameElement) GetTagName() string

func (*AggregateQueryResultTagNameElement) GetTagValues added in v0.7.3 

func (p *AggregateQueryResultTagNameElement) GetTagValues() []*AggregateQueryResultTagValueElement

func (*AggregateQueryResultTagNameElement) IsSetTagValues added in v0.7.3 

func (p *AggregateQueryResultTagNameElement) IsSetTagValues() bool

func (*AggregateQueryResultTagNameElement) Read added in v0.7.3 

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

func (*AggregateQueryResultTagNameElement) ReadField1 added in v0.7.3 

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

func (*AggregateQueryResultTagNameElement) ReadField2 added in v0.7.3 

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

func (*AggregateQueryResultTagNameElement) String added in v0.7.3 

func (p *AggregateQueryResultTagNameElement) String() string

func (*AggregateQueryResultTagNameElement) Write added in v0.7.3 

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

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 (p *AggregateQueryResultTagValueElement) GetTagValue() string

func (*AggregateQueryResultTagValueElement) Read added in v0.7.3 

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

func (*AggregateQueryResultTagValueElement) ReadField1 added in v0.7.3 

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

func (*AggregateQueryResultTagValueElement) String added in v0.7.3 

func (p *AggregateQueryResultTagValueElement) String() string

func (*AggregateQueryResultTagValueElement) Write added in v0.7.3 

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

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 (p *AggregateQueryResult_) GetResults() []*AggregateQueryResultTagNameElement

func (*AggregateQueryResult_) Read added in v0.7.3 

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

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 (p *AggregateTilesRequest) Read(iprot thrift.TProtocol) error

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 (p *AggregateTilesResult_) Read(iprot thrift.TProtocol) error

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 (p *ClusterAggregateArgs) GetReq() *AggregateQueryRequest

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 (p *ClusterAggregateResult) GetSuccess() *AggregateQueryResult_

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 (p *ClusterAggregateResult) Read(iprot thrift.TProtocol) error

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 NewClusterClientFactory 

func NewClusterClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ClusterClient

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 (p *ClusterTruncateResult) Read(iprot thrift.TProtocol) error

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 (p *ClusterWriteTaggedArgs) GetReq() *WriteTaggedRequest

func (*ClusterWriteTaggedArgs) IsSetReq 

func (p *ClusterWriteTaggedArgs) IsSetReq() bool

func (*ClusterWriteTaggedArgs) Read 

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

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 (p *ClusterWriteTaggedResult) Read(iprot thrift.TProtocol) error

func (*ClusterWriteTaggedResult) ReadField1 

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

func (*ClusterWriteTaggedResult) String 

func (p *ClusterWriteTaggedResult) String() string

func (*ClusterWriteTaggedResult) Write 

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

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 (p *DebugIndexMemorySegmentsRequest) Read(iprot thrift.TProtocol) error

func (*DebugIndexMemorySegmentsRequest) ReadField1 added in v0.15.0 

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

func (*DebugIndexMemorySegmentsRequest) String added in v0.15.0 

func (p *DebugIndexMemorySegmentsRequest) String() string

func (*DebugIndexMemorySegmentsRequest) Write added in v0.15.0 

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

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 (p *DebugIndexMemorySegmentsResult_) Read(iprot thrift.TProtocol) error

func (*DebugIndexMemorySegmentsResult_) String added in v0.15.0 

func (p *DebugIndexMemorySegmentsResult_) String() string

func (*DebugIndexMemorySegmentsResult_) Write added in v0.15.0 

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

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 (p *DebugProfileStartRequest) Read(iprot thrift.TProtocol) error

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 

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

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 (p *DebugProfileStartResult_) Read(iprot thrift.TProtocol) error

func (*DebugProfileStartResult_) String added in v0.15.5 

func (p *DebugProfileStartResult_) String() string

func (*DebugProfileStartResult_) Write added in v0.15.5 

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

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 (p *DebugProfileStopRequest) Read(iprot thrift.TProtocol) error

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 

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

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 (p *DebugProfileStopResult_) Read(iprot thrift.TProtocol) error

func (*DebugProfileStopResult_) String added in v0.15.5 

func (p *DebugProfileStopResult_) String() string

func (*DebugProfileStopResult_) Write added in v0.15.5 

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

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"`
	Flags   int64     `thrift:"flags,3" db:"flags" json:"flags,omitempty"`
}

Attributes:

  • Type
  • Message
  • Flags
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) GetFlags added in v1.0.1 

func (p *Error) GetFlags() int64

func (*Error) GetMessage 

func (p *Error) GetMessage() string

func (*Error) GetType 

func (p *Error) GetType() ErrorType

func (*Error) IsSetFlags added in v1.0.1 

func (p *Error) IsSetFlags() bool

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) ReadField3 added in v1.0.1 

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

func (*Error) String 

func (p *Error) String() string

func (*Error) Write 

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

type ErrorFlags added in v1.0.1 

type ErrorFlags int64
const (
	ErrorFlags_NONE               ErrorFlags = 0
	ErrorFlags_RESOURCE_EXHAUSTED ErrorFlags = 1
	ErrorFlags_SERVER_TIMEOUT     ErrorFlags = 2
)

func ErrorFlagsFromString added in v1.0.1 

func ErrorFlagsFromString(s string) (ErrorFlags, error)

func ErrorFlagsPtr added in v1.0.1 

func ErrorFlagsPtr(v ErrorFlags) *ErrorFlags

func (ErrorFlags) MarshalText added in v1.0.1 

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

func (*ErrorFlags) Scan added in v1.0.1 

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

func (ErrorFlags) String added in v1.0.1 

func (p ErrorFlags) String() string

func (*ErrorFlags) UnmarshalText added in v1.0.1 

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

func (*ErrorFlags) Value added in v1.0.1 

func (p *ErrorFlags) Value() (driver.Value, 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"`
	Source        []byte   `thrift:"source,6" db:"source" json:"source,omitempty"`
}

Attributes:

  • RangeStart
  • RangeEnd
  • NameSpace
  • Ids
  • RangeTimeType
  • Source
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) GetSource added in v1.0.1 

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

func (*FetchBatchRawRequest) IsSetRangeTimeType 

func (p *FetchBatchRawRequest) IsSetRangeTimeType() bool

func (*FetchBatchRawRequest) IsSetSource added in v1.0.1 

func (p *FetchBatchRawRequest) IsSetSource() 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) ReadField6 added in v1.0.1 

func (p *FetchBatchRawRequest) ReadField6(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"`
	Source     []byte                           `thrift:"source,3" db:"source" json:"source,omitempty"`
}

Attributes:

  • NameSpaces
  • Elements
  • Source
var NodeFetchBatchRawV2Args_Req_DEFAULT *FetchBatchRawV2Request

func NewFetchBatchRawV2Request added in v0.14.0 

func NewFetchBatchRawV2Request() *FetchBatchRawV2Request

func (*FetchBatchRawV2Request) GetElements added in v0.14.0 

func (p *FetchBatchRawV2Request) GetElements() []*FetchBatchRawV2RequestElement

func (*FetchBatchRawV2Request) GetNameSpaces added in v0.14.0 

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

func (*FetchBatchRawV2Request) GetSource added in v1.0.1 

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

func (*FetchBatchRawV2Request) IsSetSource added in v1.0.1 

func (p *FetchBatchRawV2Request) IsSetSource() bool

func (*FetchBatchRawV2Request) Read added in v0.14.0 

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

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) ReadField3 added in v1.0.1 

func (p *FetchBatchRawV2Request) ReadField3(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 (p *FetchBatchRawV2RequestElement) Read(iprot thrift.TProtocol) error

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 (p *FetchBatchRawV2RequestElement) String() string

func (*FetchBatchRawV2RequestElement) Write added in v0.14.0 

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

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 (p *FetchBlocksMetadataRawV2Request) Read(iprot thrift.TProtocol) error

func (*FetchBlocksMetadataRawV2Request) ReadField1 

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

func (*FetchBlocksMetadataRawV2Request) ReadField2 

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

func (*FetchBlocksMetadataRawV2Request) ReadField3 

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

func (*FetchBlocksMetadataRawV2Request) ReadField4 

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

func (*FetchBlocksMetadataRawV2Request) ReadField5 

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

func (*FetchBlocksMetadataRawV2Request) ReadField6 

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

func (*FetchBlocksMetadataRawV2Request) ReadField7 

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

func (*FetchBlocksMetadataRawV2Request) ReadField8 

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

func (*FetchBlocksMetadataRawV2Request) ReadField9 

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

func (*FetchBlocksMetadataRawV2Request) String 

func (p *FetchBlocksMetadataRawV2Request) String() string

func (*FetchBlocksMetadataRawV2Request) Write 

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

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 (p *FetchBlocksMetadataRawV2Result_) GetElements() []*BlockMetadataV2

func (*FetchBlocksMetadataRawV2Result_) GetNextPageToken 

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

func (*FetchBlocksMetadataRawV2Result_) IsSetNextPageToken 

func (p *FetchBlocksMetadataRawV2Result_) IsSetNextPageToken() bool

func (*FetchBlocksMetadataRawV2Result_) Read 

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

func (*FetchBlocksMetadataRawV2Result_) ReadField1 

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

func (*FetchBlocksMetadataRawV2Result_) ReadField2 

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

func (*FetchBlocksMetadataRawV2Result_) String 

func (p *FetchBlocksMetadataRawV2Result_) String() string

func (*FetchBlocksMetadataRawV2Result_) Write 

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

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"`
	Source    []byte                          `thrift:"source,4" db:"source" json:"source,omitempty"`
}

Attributes:

  • NameSpace
  • Shard
  • Elements
  • Source
var NodeFetchBlocksRawArgs_Req_DEFAULT *FetchBlocksRawRequest

func NewFetchBlocksRawRequest 

func NewFetchBlocksRawRequest() *FetchBlocksRawRequest

func (*FetchBlocksRawRequest) GetElements 

func (p *FetchBlocksRawRequest) GetElements() []*FetchBlocksRawRequestElement

func (*FetchBlocksRawRequest) GetNameSpace 

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

func (*FetchBlocksRawRequest) GetShard 

func (p *FetchBlocksRawRequest) GetShard() int32

func (*FetchBlocksRawRequest) GetSource added in v1.0.1 

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

func (*FetchBlocksRawRequest) IsSetSource added in v1.0.1 

func (p *FetchBlocksRawRequest) IsSetSource() bool

func (*FetchBlocksRawRequest) Read 

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

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) ReadField4 added in v1.0.1 

func (p *FetchBlocksRawRequest) ReadField4(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 (p *FetchBlocksRawRequestElement) Read(iprot thrift.TProtocol) error

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 (p *FetchBlocksRawRequestElement) String() string

func (*FetchBlocksRawRequestElement) Write 

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

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 (p *FetchBlocksRawResult_) Read(iprot thrift.TProtocol) error

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"`
	Source         []byte   `thrift:"source,7" db:"source" json:"source,omitempty"`
}

Attributes:

  • RangeStart
  • RangeEnd
  • NameSpace
  • ID
  • RangeType
  • ResultTimeType
  • Source
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) GetSource added in v1.0.1 

func (p *FetchRequest) GetSource() []byte

func (*FetchRequest) IsSetRangeType 

func (p *FetchRequest) IsSetRangeType() bool

func (*FetchRequest) IsSetResultTimeType 

func (p *FetchRequest) IsSetResultTimeType() bool

func (*FetchRequest) IsSetSource added in v1.0.1 

func (p *FetchRequest) IsSetSource() 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) ReadField7 added in v1.0.1 

func (p *FetchRequest) ReadField7(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"`
	SeriesLimit       *int64   `thrift:"seriesLimit,6" db:"seriesLimit" json:"seriesLimit,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"`
	Source            []byte   `thrift:"source,10" db:"source" json:"source,omitempty"`
	RequireNoWait     bool     `thrift:"requireNoWait,11" db:"requireNoWait" json:"requireNoWait,omitempty"`
}

Attributes:

  • NameSpace
  • Query
  • RangeStart
  • RangeEnd
  • FetchData
  • SeriesLimit
  • RangeTimeType
  • RequireExhaustive
  • DocsLimit
  • Source
  • RequireNoWait
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) 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) GetRequireNoWait added in v1.2.0 

func (p *FetchTaggedRequest) GetRequireNoWait() bool

func (*FetchTaggedRequest) GetSeriesLimit added in v1.0.1 

func (p *FetchTaggedRequest) GetSeriesLimit() int64

func (*FetchTaggedRequest) GetSource added in v1.0.1 

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

func (*FetchTaggedRequest) IsSetDocsLimit added in v0.15.3 

func (p *FetchTaggedRequest) IsSetDocsLimit() bool

func (*FetchTaggedRequest) IsSetRangeTimeType 

func (p *FetchTaggedRequest) IsSetRangeTimeType() bool

func (*FetchTaggedRequest) IsSetRequireExhaustive added in v0.15.1 

func (p *FetchTaggedRequest) IsSetRequireExhaustive() bool

func (*FetchTaggedRequest) IsSetRequireNoWait added in v1.2.0 

func (p *FetchTaggedRequest) IsSetRequireNoWait() bool

func (*FetchTaggedRequest) IsSetSeriesLimit added in v1.0.1 

func (p *FetchTaggedRequest) IsSetSeriesLimit() bool

func (*FetchTaggedRequest) IsSetSource added in v1.0.1 

func (p *FetchTaggedRequest) IsSetSource() 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) ReadField10 added in v1.0.1 

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

func (*FetchTaggedRequest) ReadField11 added in v1.2.0 

func (p *FetchTaggedRequest) ReadField11(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"`
	WaitedIndex      *int64                  `thrift:"waitedIndex,3" db:"waitedIndex" json:"waitedIndex,omitempty"`
	WaitedSeriesRead *int64                  `thrift:"waitedSeriesRead,4" db:"waitedSeriesRead" json:"waitedSeriesRead,omitempty"`
}

Attributes:

  • Elements
  • Exhaustive
  • WaitedIndex
  • WaitedSeriesRead
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_) GetWaitedIndex added in v1.2.0 

func (p *FetchTaggedResult_) GetWaitedIndex() int64

func (*FetchTaggedResult_) GetWaitedSeriesRead added in v1.2.0 

func (p *FetchTaggedResult_) GetWaitedSeriesRead() int64

func (*FetchTaggedResult_) IsSetWaitedIndex added in v1.2.0 

func (p *FetchTaggedResult_) IsSetWaitedIndex() bool

func (*FetchTaggedResult_) IsSetWaitedSeriesRead added in v1.2.0 

func (p *FetchTaggedResult_) IsSetWaitedSeriesRead() 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_) ReadField3 added in v1.2.0 

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

func (*FetchTaggedResult_) ReadField4 added in v1.2.0 

func (p *FetchTaggedResult_) ReadField4(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 

func (m *MockTChanCluster) Aggregate(ctx thrift.Context, req *AggregateQueryRequest) (*AggregateQueryResult_, error)

Aggregate mocks base method.

func (*MockTChanCluster) EXPECT 

func (m *MockTChanCluster) EXPECT() *MockTChanClusterMockRecorder

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

func (*MockTChanCluster) Fetch 

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

Fetch mocks base method.

func (*MockTChanCluster) Health 

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

Health mocks base method.

func (*MockTChanCluster) Query 

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

Query mocks base method.

func (*MockTChanCluster) Truncate 

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

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 

func (m *MockTChanNode) Aggregate(ctx thrift.Context, req *AggregateQueryRequest) (*AggregateQueryResult_, error)

Aggregate mocks base method.

func (*MockTChanNode) AggregateRaw added in v0.7.3 

func (m *MockTChanNode) AggregateRaw(ctx thrift.Context, req *AggregateQueryRawRequest) (*AggregateQueryRawResult_, error)

AggregateRaw mocks base method.

func (*MockTChanNode) AggregateTiles added in v0.15.14 

func (m *MockTChanNode) AggregateTiles(ctx thrift.Context, req *AggregateTilesRequest) (*AggregateTilesResult_, error)

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 

func (m *MockTChanNode) DebugIndexMemorySegments(ctx thrift.Context, req *DebugIndexMemorySegmentsRequest) (*DebugIndexMemorySegmentsResult_, error)

DebugIndexMemorySegments mocks base method.

func (*MockTChanNode) DebugProfileStart added in v0.15.5 

func (m *MockTChanNode) DebugProfileStart(ctx thrift.Context, req *DebugProfileStartRequest) (*DebugProfileStartResult_, error)

DebugProfileStart mocks base method.

func (*MockTChanNode) DebugProfileStop added in v0.15.5 

func (m *MockTChanNode) DebugProfileStop(ctx thrift.Context, req *DebugProfileStopRequest) (*DebugProfileStopResult_, error)

DebugProfileStop mocks base method.

func (*MockTChanNode) EXPECT 

func (m *MockTChanNode) EXPECT() *MockTChanNodeMockRecorder

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 

func (m *MockTChanNode) FetchBatchRaw(ctx thrift.Context, req *FetchBatchRawRequest) (*FetchBatchRawResult_, error)

FetchBatchRaw mocks base method.

func (*MockTChanNode) FetchBatchRawV2 added in v0.14.0 

func (m *MockTChanNode) FetchBatchRawV2(ctx thrift.Context, req *FetchBatchRawV2Request) (*FetchBatchRawResult_, error)

FetchBatchRawV2 mocks base method.

func (*MockTChanNode) FetchBlocksMetadataRawV2 

func (m *MockTChanNode) FetchBlocksMetadataRawV2(ctx thrift.Context, req *FetchBlocksMetadataRawV2Request) (*FetchBlocksMetadataRawV2Result_, error)

FetchBlocksMetadataRawV2 mocks base method.

func (*MockTChanNode) FetchBlocksRaw 

func (m *MockTChanNode) FetchBlocksRaw(ctx thrift.Context, req *FetchBlocksRawRequest) (*FetchBlocksRawResult_, error)

FetchBlocksRaw mocks base method.

func (*MockTChanNode) FetchTagged 

func (m *MockTChanNode) FetchTagged(ctx thrift.Context, req *FetchTaggedRequest) (*FetchTaggedResult_, error)

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 

func (m *MockTChanNode) SetPersistRateLimit(ctx thrift.Context, req *NodeSetPersistRateLimitRequest) (*NodePersistRateLimitResult_, error)

SetPersistRateLimit mocks base method.

func (*MockTChanNode) SetWriteNewSeriesAsync 

func (m *MockTChanNode) SetWriteNewSeriesAsync(ctx thrift.Context, req *NodeSetWriteNewSeriesAsyncRequest) (*NodeWriteNewSeriesAsyncResult_, error)

SetWriteNewSeriesAsync mocks base method.

func (*MockTChanNode) SetWriteNewSeriesBackoffDuration 

func (m *MockTChanNode) SetWriteNewSeriesBackoffDuration(ctx thrift.Context, req *NodeSetWriteNewSeriesBackoffDurationRequest) (*NodeWriteNewSeriesBackoffDurationResult_, error)

SetWriteNewSeriesBackoffDuration mocks base method.

func (*MockTChanNode) SetWriteNewSeriesLimitPerShardPerSecond 

func (m *MockTChanNode) SetWriteNewSeriesLimitPerShardPerSecond(ctx thrift.Context, req *NodeSetWriteNewSeriesLimitPerShardPerSecondRequest) (*NodeWriteNewSeriesLimitPerShardPerSecondResult_, error)

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 (p *NodeAggregateArgs) GetReq() *AggregateQueryRequest

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 (p *NodeAggregateRawArgs) GetReq() *AggregateQueryRawRequest

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 (p *NodeAggregateRawResult) GetSuccess() *AggregateQueryRawResult_

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 (p *NodeAggregateRawResult) Read(iprot thrift.TProtocol) error

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 (p *NodeAggregateTilesArgs) GetReq() *AggregateTilesRequest

func (*NodeAggregateTilesArgs) IsSetReq added in v0.15.14 

func (p *NodeAggregateTilesArgs) IsSetReq() bool

func (*NodeAggregateTilesArgs) Read added in v0.15.14 

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

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 (p *NodeAggregateTilesResult) GetSuccess() *AggregateTilesResult_

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 (p *NodeAggregateTilesResult) Read(iprot thrift.TProtocol) error

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 

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

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 (p *NodeBootstrappedInPlacementOrNoPlacementArgs) Read(iprot thrift.TProtocol) error

func (*NodeBootstrappedInPlacementOrNoPlacementArgs) String added in v0.9.0 

func (p *NodeBootstrappedInPlacementOrNoPlacementArgs) String() string

func (*NodeBootstrappedInPlacementOrNoPlacementArgs) Write added in v0.9.0 

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

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 (p *NodeBootstrappedInPlacementOrNoPlacementResult) GetErr() *Error

func (*NodeBootstrappedInPlacementOrNoPlacementResult) GetSuccess added in v0.9.0 

func (p *NodeBootstrappedInPlacementOrNoPlacementResult) GetSuccess() *NodeBootstrappedInPlacementOrNoPlacementResult_

func (*NodeBootstrappedInPlacementOrNoPlacementResult) IsSetErr added in v0.9.0 

func (p *NodeBootstrappedInPlacementOrNoPlacementResult) IsSetErr() bool

func (*NodeBootstrappedInPlacementOrNoPlacementResult) IsSetSuccess added in v0.9.0 

func (p *NodeBootstrappedInPlacementOrNoPlacementResult) IsSetSuccess() bool

func (*NodeBootstrappedInPlacementOrNoPlacementResult) Read added in v0.9.0 

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

func (*NodeBootstrappedInPlacementOrNoPlacementResult) ReadField0 added in v0.9.0 

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

func (*NodeBootstrappedInPlacementOrNoPlacementResult) ReadField1 added in v0.9.0 

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

func (*NodeBootstrappedInPlacementOrNoPlacementResult) String added in v0.9.0 

func (p *NodeBootstrappedInPlacementOrNoPlacementResult) String() string

func (*NodeBootstrappedInPlacementOrNoPlacementResult) Write added in v0.9.0 

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

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 (p *NodeBootstrappedInPlacementOrNoPlacementResult_) Read(iprot thrift.TProtocol) error

func (*NodeBootstrappedInPlacementOrNoPlacementResult_) String added in v0.9.0 

func (p *NodeBootstrappedInPlacementOrNoPlacementResult_) String() string

func (*NodeBootstrappedInPlacementOrNoPlacementResult_) Write added in v0.9.0 

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

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 (p *NodeBootstrappedResult) GetSuccess() *NodeBootstrappedResult_

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 (p *NodeBootstrappedResult) Read(iprot thrift.TProtocol) error

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 (p *NodeBootstrappedResult_) Read(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 NodeClient 

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

func NewNodeClientFactory 

func NewNodeClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *NodeClient

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 

func (p *NodeClient) SetWriteNewSeriesBackoffDuration(req *NodeSetWriteNewSeriesBackoffDurationRequest) (r *NodeWriteNewSeriesBackoffDurationResult_, err error)

Parameters:

  • Req

func (*NodeClient) SetWriteNewSeriesLimitPerShardPerSecond 

func (p *NodeClient) SetWriteNewSeriesLimitPerShardPerSecond(req *NodeSetWriteNewSeriesLimitPerShardPerSecondRequest) (r *NodeWriteNewSeriesLimitPerShardPerSecondResult_, err error)

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 (p *NodeDebugIndexMemorySegmentsArgs) GetReq() *DebugIndexMemorySegmentsRequest

func (*NodeDebugIndexMemorySegmentsArgs) IsSetReq added in v0.15.0 

func (p *NodeDebugIndexMemorySegmentsArgs) IsSetReq() bool

func (*NodeDebugIndexMemorySegmentsArgs) Read added in v0.15.0 

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

func (*NodeDebugIndexMemorySegmentsArgs) ReadField1 added in v0.15.0 

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

func (*NodeDebugIndexMemorySegmentsArgs) String added in v0.15.0 

func (p *NodeDebugIndexMemorySegmentsArgs) String() string

func (*NodeDebugIndexMemorySegmentsArgs) Write added in v0.15.0 

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

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 (p *NodeDebugIndexMemorySegmentsResult) GetErr() *Error

func (*NodeDebugIndexMemorySegmentsResult) GetSuccess added in v0.15.0 

func (p *NodeDebugIndexMemorySegmentsResult) GetSuccess() *DebugIndexMemorySegmentsResult_

func (*NodeDebugIndexMemorySegmentsResult) IsSetErr added in v0.15.0 

func (p *NodeDebugIndexMemorySegmentsResult) IsSetErr() bool

func (*NodeDebugIndexMemorySegmentsResult) IsSetSuccess added in v0.15.0 

func (p *NodeDebugIndexMemorySegmentsResult) IsSetSuccess() bool

func (*NodeDebugIndexMemorySegmentsResult) Read added in v0.15.0 

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

func (*NodeDebugIndexMemorySegmentsResult) ReadField0 added in v0.15.0 

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

func (*NodeDebugIndexMemorySegmentsResult) ReadField1 added in v0.15.0 

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

func (*NodeDebugIndexMemorySegmentsResult) String added in v0.15.0 

func (p *NodeDebugIndexMemorySegmentsResult) String() string

func (*NodeDebugIndexMemorySegmentsResult) Write added in v0.15.0 

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

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 (p *NodeDebugProfileStartArgs) GetReq() *DebugProfileStartRequest

func (*NodeDebugProfileStartArgs) IsSetReq added in v0.15.5 

func (p *NodeDebugProfileStartArgs) IsSetReq() bool

func (*NodeDebugProfileStartArgs) Read added in v0.15.5 

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

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 

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

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 (p *NodeDebugProfileStartResult) GetSuccess() *DebugProfileStartResult_

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 (p *NodeDebugProfileStartResult) Read(iprot thrift.TProtocol) error

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 

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

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 (p *NodeDebugProfileStopArgs) GetReq() *DebugProfileStopRequest

func (*NodeDebugProfileStopArgs) IsSetReq added in v0.15.5 

func (p *NodeDebugProfileStopArgs) IsSetReq() bool

func (*NodeDebugProfileStopArgs) Read added in v0.15.5 

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

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 

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

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 (p *NodeDebugProfileStopResult) GetSuccess() *DebugProfileStopResult_

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 (p *NodeDebugProfileStopResult) Read(iprot thrift.TProtocol) error

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 

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

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 (p *NodeFetchBatchRawArgs) GetReq() *FetchBatchRawRequest

func (*NodeFetchBatchRawArgs) IsSetReq 

func (p *NodeFetchBatchRawArgs) IsSetReq() bool

func (*NodeFetchBatchRawArgs) Read 

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

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 (p *NodeFetchBatchRawResult) GetSuccess() *FetchBatchRawResult_

func (*NodeFetchBatchRawResult) IsSetErr 

func (p *NodeFetchBatchRawResult) IsSetErr() bool

func (*NodeFetchBatchRawResult) IsSetSuccess 

func (p *NodeFetchBatchRawResult) IsSetSuccess() bool

func (*NodeFetchBatchRawResult) Read 

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

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 

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

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 (p *NodeFetchBatchRawV2Args) GetReq() *FetchBatchRawV2Request

func (*NodeFetchBatchRawV2Args) IsSetReq added in v0.14.0 

func (p *NodeFetchBatchRawV2Args) IsSetReq() bool

func (*NodeFetchBatchRawV2Args) Read added in v0.14.0 

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

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 

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

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 (p *NodeFetchBatchRawV2Result) GetSuccess() *FetchBatchRawResult_

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 (p *NodeFetchBatchRawV2Result) Read(iprot thrift.TProtocol) error

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 

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

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 (p *NodeFetchBlocksMetadataRawV2Args) GetReq() *FetchBlocksMetadataRawV2Request

func (*NodeFetchBlocksMetadataRawV2Args) IsSetReq 

func (p *NodeFetchBlocksMetadataRawV2Args) IsSetReq() bool

func (*NodeFetchBlocksMetadataRawV2Args) Read 

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

func (*NodeFetchBlocksMetadataRawV2Args) ReadField1 

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

func (*NodeFetchBlocksMetadataRawV2Args) String 

func (p *NodeFetchBlocksMetadataRawV2Args) String() string

func (*NodeFetchBlocksMetadataRawV2Args) Write 

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

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 (p *NodeFetchBlocksMetadataRawV2Result) GetErr() *Error

func (*NodeFetchBlocksMetadataRawV2Result) GetSuccess 

func (p *NodeFetchBlocksMetadataRawV2Result) GetSuccess() *FetchBlocksMetadataRawV2Result_

func (*NodeFetchBlocksMetadataRawV2Result) IsSetErr 

func (p *NodeFetchBlocksMetadataRawV2Result) IsSetErr() bool

func (*NodeFetchBlocksMetadataRawV2Result) IsSetSuccess 

func (p *NodeFetchBlocksMetadataRawV2Result) IsSetSuccess() bool

func (*NodeFetchBlocksMetadataRawV2Result) Read 

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

func (*NodeFetchBlocksMetadataRawV2Result) ReadField0 

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

func (*NodeFetchBlocksMetadataRawV2Result) ReadField1 

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

func (*NodeFetchBlocksMetadataRawV2Result) String 

func (p *NodeFetchBlocksMetadataRawV2Result) String() string

func (*NodeFetchBlocksMetadataRawV2Result) Write 

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

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 (p *NodeFetchBlocksRawArgs) GetReq() *FetchBlocksRawRequest

func (*NodeFetchBlocksRawArgs) IsSetReq 

func (p *NodeFetchBlocksRawArgs) IsSetReq() bool

func (*NodeFetchBlocksRawArgs) Read 

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

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 (p *NodeFetchBlocksRawResult) GetSuccess() *FetchBlocksRawResult_

func (*NodeFetchBlocksRawResult) IsSetErr 

func (p *NodeFetchBlocksRawResult) IsSetErr() bool

func (*NodeFetchBlocksRawResult) IsSetSuccess 

func (p *NodeFetchBlocksRawResult) IsSetSuccess() bool

func (*NodeFetchBlocksRawResult) Read 

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

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 

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

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 (p *NodeFetchTaggedArgs) GetReq() *FetchTaggedRequest

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 (p *NodeFetchTaggedResult) Read(iprot thrift.TProtocol) error

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 (p *NodeGetPersistRateLimitArgs) Read(iprot thrift.TProtocol) error

func (*NodeGetPersistRateLimitArgs) String 

func (p *NodeGetPersistRateLimitArgs) String() string

func (*NodeGetPersistRateLimitArgs) Write 

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

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 (p *NodeGetPersistRateLimitResult) GetSuccess() *NodePersistRateLimitResult_

func (*NodeGetPersistRateLimitResult) IsSetErr 

func (p *NodeGetPersistRateLimitResult) IsSetErr() bool

func (*NodeGetPersistRateLimitResult) IsSetSuccess 

func (p *NodeGetPersistRateLimitResult) IsSetSuccess() bool

func (*NodeGetPersistRateLimitResult) Read 

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

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 (p *NodeGetPersistRateLimitResult) String() string

func (*NodeGetPersistRateLimitResult) Write 

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

type NodeGetWriteNewSeriesAsyncArgs 

type NodeGetWriteNewSeriesAsyncArgs struct {
}

func NewNodeGetWriteNewSeriesAsyncArgs 

func NewNodeGetWriteNewSeriesAsyncArgs() *NodeGetWriteNewSeriesAsyncArgs

func (*NodeGetWriteNewSeriesAsyncArgs) Read 

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

func (*NodeGetWriteNewSeriesAsyncArgs) String 

func (p *NodeGetWriteNewSeriesAsyncArgs) String() string

func (*NodeGetWriteNewSeriesAsyncArgs) Write 

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

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 (p *NodeGetWriteNewSeriesAsyncResult) GetErr() *Error

func (*NodeGetWriteNewSeriesAsyncResult) GetSuccess 

func (p *NodeGetWriteNewSeriesAsyncResult) GetSuccess() *NodeWriteNewSeriesAsyncResult_

func (*NodeGetWriteNewSeriesAsyncResult) IsSetErr 

func (p *NodeGetWriteNewSeriesAsyncResult) IsSetErr() bool

func (*NodeGetWriteNewSeriesAsyncResult) IsSetSuccess 

func (p *NodeGetWriteNewSeriesAsyncResult) IsSetSuccess() bool

func (*NodeGetWriteNewSeriesAsyncResult) Read 

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

func (*NodeGetWriteNewSeriesAsyncResult) ReadField0 

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

func (*NodeGetWriteNewSeriesAsyncResult) ReadField1 

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

func (*NodeGetWriteNewSeriesAsyncResult) String 

func (p *NodeGetWriteNewSeriesAsyncResult) String() string

func (*NodeGetWriteNewSeriesAsyncResult) Write 

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

type NodeGetWriteNewSeriesBackoffDurationArgs 

type NodeGetWriteNewSeriesBackoffDurationArgs struct {
}

func NewNodeGetWriteNewSeriesBackoffDurationArgs 

func NewNodeGetWriteNewSeriesBackoffDurationArgs() *NodeGetWriteNewSeriesBackoffDurationArgs

func (*NodeGetWriteNewSeriesBackoffDurationArgs) Read 

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

func (*NodeGetWriteNewSeriesBackoffDurationArgs) String 

func (p *NodeGetWriteNewSeriesBackoffDurationArgs) String() string

func (*NodeGetWriteNewSeriesBackoffDurationArgs) Write 

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

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 (p *NodeGetWriteNewSeriesBackoffDurationResult) GetErr() *Error

func (*NodeGetWriteNewSeriesBackoffDurationResult) GetSuccess 

func (p *NodeGetWriteNewSeriesBackoffDurationResult) GetSuccess() *NodeWriteNewSeriesBackoffDurationResult_

func (*NodeGetWriteNewSeriesBackoffDurationResult) IsSetErr 

func (p *NodeGetWriteNewSeriesBackoffDurationResult) IsSetErr() bool

func (*NodeGetWriteNewSeriesBackoffDurationResult) IsSetSuccess 

func (p *NodeGetWriteNewSeriesBackoffDurationResult) IsSetSuccess() bool

func (*NodeGetWriteNewSeriesBackoffDurationResult) Read 

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

func (*NodeGetWriteNewSeriesBackoffDurationResult) ReadField0 

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

func (*NodeGetWriteNewSeriesBackoffDurationResult) ReadField1 

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

func (*NodeGetWriteNewSeriesBackoffDurationResult) String 

func (p *NodeGetWriteNewSeriesBackoffDurationResult) String() string

func (*NodeGetWriteNewSeriesBackoffDurationResult) Write 

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

type NodeGetWriteNewSeriesLimitPerShardPerSecondArgs 

type NodeGetWriteNewSeriesLimitPerShardPerSecondArgs struct {
}

func NewNodeGetWriteNewSeriesLimitPerShardPerSecondArgs 

func NewNodeGetWriteNewSeriesLimitPerShardPerSecondArgs() *NodeGetWriteNewSeriesLimitPerShardPerSecondArgs

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondArgs) Read 

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

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondArgs) String 

func (p *NodeGetWriteNewSeriesLimitPerShardPerSecondArgs) String() string

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondArgs) Write 

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

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 (p *NodeGetWriteNewSeriesLimitPerShardPerSecondResult) GetErr() *Error

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondResult) GetSuccess 

func (p *NodeGetWriteNewSeriesLimitPerShardPerSecondResult) GetSuccess() *NodeWriteNewSeriesLimitPerShardPerSecondResult_

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondResult) IsSetErr 

func (p *NodeGetWriteNewSeriesLimitPerShardPerSecondResult) IsSetErr() bool

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondResult) IsSetSuccess 

func (p *NodeGetWriteNewSeriesLimitPerShardPerSecondResult) IsSetSuccess() bool

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondResult) Read 

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

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondResult) ReadField0 

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

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondResult) ReadField1 

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

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondResult) String 

func (p *NodeGetWriteNewSeriesLimitPerShardPerSecondResult) String() string

func (*NodeGetWriteNewSeriesLimitPerShardPerSecondResult) Write 

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

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 (p *NodePersistRateLimitResult_) Read(iprot thrift.TProtocol) error

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 

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

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 (p *NodeSetPersistRateLimitArgs) GetReq() *NodeSetPersistRateLimitRequest

func (*NodeSetPersistRateLimitArgs) IsSetReq 

func (p *NodeSetPersistRateLimitArgs) IsSetReq() bool

func (*NodeSetPersistRateLimitArgs) Read 

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

func (*NodeSetPersistRateLimitArgs) ReadField1 

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

func (*NodeSetPersistRateLimitArgs) String 

func (p *NodeSetPersistRateLimitArgs) String() string

func (*NodeSetPersistRateLimitArgs) Write 

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

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 (p *NodeSetPersistRateLimitRequest) Read(iprot thrift.TProtocol) error

func (*NodeSetPersistRateLimitRequest) ReadField1 

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

func (*NodeSetPersistRateLimitRequest) ReadField2 

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

func (*NodeSetPersistRateLimitRequest) ReadField3 

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

func (*NodeSetPersistRateLimitRequest) String 

func (p *NodeSetPersistRateLimitRequest) String() string

func (*NodeSetPersistRateLimitRequest) Write 

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

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 (p *NodeSetPersistRateLimitResult) GetSuccess() *NodePersistRateLimitResult_

func (*NodeSetPersistRateLimitResult) IsSetErr 

func (p *NodeSetPersistRateLimitResult) IsSetErr() bool

func (*NodeSetPersistRateLimitResult) IsSetSuccess 

func (p *NodeSetPersistRateLimitResult) IsSetSuccess() bool

func (*NodeSetPersistRateLimitResult) Read 

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

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 (p *NodeSetPersistRateLimitResult) String() string

func (*NodeSetPersistRateLimitResult) Write 

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

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 (p *NodeSetWriteNewSeriesAsyncArgs) GetReq() *NodeSetWriteNewSeriesAsyncRequest

func (*NodeSetWriteNewSeriesAsyncArgs) IsSetReq 

func (p *NodeSetWriteNewSeriesAsyncArgs) IsSetReq() bool

func (*NodeSetWriteNewSeriesAsyncArgs) Read 

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

func (*NodeSetWriteNewSeriesAsyncArgs) ReadField1 

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

func (*NodeSetWriteNewSeriesAsyncArgs) String 

func (p *NodeSetWriteNewSeriesAsyncArgs) String() string

func (*NodeSetWriteNewSeriesAsyncArgs) Write 

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

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 (p *NodeSetWriteNewSeriesAsyncRequest) Read(iprot thrift.TProtocol) error

func (*NodeSetWriteNewSeriesAsyncRequest) ReadField1 

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

func (*NodeSetWriteNewSeriesAsyncRequest) String 

func (p *NodeSetWriteNewSeriesAsyncRequest) String() string

func (*NodeSetWriteNewSeriesAsyncRequest) Write 

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

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 (p *NodeSetWriteNewSeriesAsyncResult) GetErr() *Error

func (*NodeSetWriteNewSeriesAsyncResult) GetSuccess 

func (p *NodeSetWriteNewSeriesAsyncResult) GetSuccess() *NodeWriteNewSeriesAsyncResult_

func (*NodeSetWriteNewSeriesAsyncResult) IsSetErr 

func (p *NodeSetWriteNewSeriesAsyncResult) IsSetErr() bool

func (*NodeSetWriteNewSeriesAsyncResult) IsSetSuccess 

func (p *NodeSetWriteNewSeriesAsyncResult) IsSetSuccess() bool

func (*NodeSetWriteNewSeriesAsyncResult) Read 

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

func (*NodeSetWriteNewSeriesAsyncResult) ReadField0 

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

func (*NodeSetWriteNewSeriesAsyncResult) ReadField1 

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

func (*NodeSetWriteNewSeriesAsyncResult) String 

func (p *NodeSetWriteNewSeriesAsyncResult) String() string

func (*NodeSetWriteNewSeriesAsyncResult) Write 

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

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 (p *NodeSetWriteNewSeriesBackoffDurationArgs) GetReq() *NodeSetWriteNewSeriesBackoffDurationRequest

func (*NodeSetWriteNewSeriesBackoffDurationArgs) IsSetReq 

func (p *NodeSetWriteNewSeriesBackoffDurationArgs) IsSetReq() bool

func (*NodeSetWriteNewSeriesBackoffDurationArgs) Read 

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

func (*NodeSetWriteNewSeriesBackoffDurationArgs) ReadField1 

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

func (*NodeSetWriteNewSeriesBackoffDurationArgs) String 

func (p *NodeSetWriteNewSeriesBackoffDurationArgs) String() string

func (*NodeSetWriteNewSeriesBackoffDurationArgs) Write 

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

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 (p *NodeSetWriteNewSeriesBackoffDurationRequest) GetDurationType() TimeType

func (*NodeSetWriteNewSeriesBackoffDurationRequest) GetWriteNewSeriesBackoffDuration 

func (p *NodeSetWriteNewSeriesBackoffDurationRequest) GetWriteNewSeriesBackoffDuration() int64

func (*NodeSetWriteNewSeriesBackoffDurationRequest) IsSetDurationType 

func (p *NodeSetWriteNewSeriesBackoffDurationRequest) IsSetDurationType() bool

func (*NodeSetWriteNewSeriesBackoffDurationRequest) Read 

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

func (*NodeSetWriteNewSeriesBackoffDurationRequest) ReadField1 

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

func (*NodeSetWriteNewSeriesBackoffDurationRequest) ReadField2 

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

func (*NodeSetWriteNewSeriesBackoffDurationRequest) String 

func (p *NodeSetWriteNewSeriesBackoffDurationRequest) String() string

func (*NodeSetWriteNewSeriesBackoffDurationRequest) Write 

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

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 (p *NodeSetWriteNewSeriesBackoffDurationResult) GetErr() *Error

func (*NodeSetWriteNewSeriesBackoffDurationResult) GetSuccess 

func (p *NodeSetWriteNewSeriesBackoffDurationResult) GetSuccess() *NodeWriteNewSeriesBackoffDurationResult_

func (*NodeSetWriteNewSeriesBackoffDurationResult) IsSetErr 

func (p *NodeSetWriteNewSeriesBackoffDurationResult) IsSetErr() bool

func (*NodeSetWriteNewSeriesBackoffDurationResult) IsSetSuccess 

func (p *NodeSetWriteNewSeriesBackoffDurationResult) IsSetSuccess() bool

func (*NodeSetWriteNewSeriesBackoffDurationResult) Read 

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

func (*NodeSetWriteNewSeriesBackoffDurationResult) ReadField0 

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

func (*NodeSetWriteNewSeriesBackoffDurationResult) ReadField1 

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

func (*NodeSetWriteNewSeriesBackoffDurationResult) String 

func (p *NodeSetWriteNewSeriesBackoffDurationResult) String() string

func (*NodeSetWriteNewSeriesBackoffDurationResult) Write 

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

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 (p *NodeSetWriteNewSeriesLimitPerShardPerSecondArgs) GetReq() *NodeSetWriteNewSeriesLimitPerShardPerSecondRequest

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondArgs) IsSetReq 

func (p *NodeSetWriteNewSeriesLimitPerShardPerSecondArgs) IsSetReq() bool

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondArgs) Read 

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

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondArgs) ReadField1 

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

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondArgs) String 

func (p *NodeSetWriteNewSeriesLimitPerShardPerSecondArgs) String() string

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondArgs) Write 

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

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 (p *NodeSetWriteNewSeriesLimitPerShardPerSecondRequest) Read(iprot thrift.TProtocol) error

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondRequest) ReadField1 

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

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondRequest) String 

func (p *NodeSetWriteNewSeriesLimitPerShardPerSecondRequest) String() string

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondRequest) Write 

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

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 (p *NodeSetWriteNewSeriesLimitPerShardPerSecondResult) GetErr() *Error

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondResult) GetSuccess 

func (p *NodeSetWriteNewSeriesLimitPerShardPerSecondResult) GetSuccess() *NodeWriteNewSeriesLimitPerShardPerSecondResult_

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondResult) IsSetErr 

func (p *NodeSetWriteNewSeriesLimitPerShardPerSecondResult) IsSetErr() bool

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondResult) IsSetSuccess 

func (p *NodeSetWriteNewSeriesLimitPerShardPerSecondResult) IsSetSuccess() bool

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondResult) Read 

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

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondResult) ReadField0 

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

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondResult) ReadField1 

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

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondResult) String 

func (p *NodeSetWriteNewSeriesLimitPerShardPerSecondResult) String() string

func (*NodeSetWriteNewSeriesLimitPerShardPerSecondResult) Write 

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

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 (p *NodeWriteBatchRawArgs) GetReq() *WriteBatchRawRequest

func (*NodeWriteBatchRawArgs) IsSetReq 

func (p *NodeWriteBatchRawArgs) IsSetReq() bool

func (*NodeWriteBatchRawArgs) Read 

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

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 (p *NodeWriteBatchRawResult) GetErr() *WriteBatchRawErrors

func (*NodeWriteBatchRawResult) IsSetErr 

func (p *NodeWriteBatchRawResult) IsSetErr() bool

func (*NodeWriteBatchRawResult) Read 

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

func (*NodeWriteBatchRawResult) ReadField1 

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

func (*NodeWriteBatchRawResult) String 

func (p *NodeWriteBatchRawResult) String() string

func (*NodeWriteBatchRawResult) Write 

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

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 (p *NodeWriteBatchRawV2Args) GetReq() *WriteBatchRawV2Request

func (*NodeWriteBatchRawV2Args) IsSetReq added in v0.14.0 

func (p *NodeWriteBatchRawV2Args) IsSetReq() bool

func (*NodeWriteBatchRawV2Args) Read added in v0.14.0 

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

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 

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

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 (p *NodeWriteBatchRawV2Result) GetErr() *WriteBatchRawErrors

func (*NodeWriteBatchRawV2Result) IsSetErr added in v0.14.0 

func (p *NodeWriteBatchRawV2Result) IsSetErr() bool

func (*NodeWriteBatchRawV2Result) Read added in v0.14.0 

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

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 

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

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 (p *NodeWriteNewSeriesAsyncResult_) Read(iprot thrift.TProtocol) error

func (*NodeWriteNewSeriesAsyncResult_) ReadField1 

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

func (*NodeWriteNewSeriesAsyncResult_) String 

func (p *NodeWriteNewSeriesAsyncResult_) String() string

func (*NodeWriteNewSeriesAsyncResult_) Write 

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

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 (p *NodeWriteNewSeriesBackoffDurationResult_) GetDurationType() TimeType

func (*NodeWriteNewSeriesBackoffDurationResult_) GetWriteNewSeriesBackoffDuration 

func (p *NodeWriteNewSeriesBackoffDurationResult_) GetWriteNewSeriesBackoffDuration() int64

func (*NodeWriteNewSeriesBackoffDurationResult_) Read 

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

func (*NodeWriteNewSeriesBackoffDurationResult_) ReadField1 

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

func (*NodeWriteNewSeriesBackoffDurationResult_) ReadField2 

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

func (*NodeWriteNewSeriesBackoffDurationResult_) String 

func (p *NodeWriteNewSeriesBackoffDurationResult_) String() string

func (*NodeWriteNewSeriesBackoffDurationResult_) Write 

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

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 (p *NodeWriteNewSeriesLimitPerShardPerSecondResult_) Read(iprot thrift.TProtocol) error

func (*NodeWriteNewSeriesLimitPerShardPerSecondResult_) ReadField1 

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

func (*NodeWriteNewSeriesLimitPerShardPerSecondResult_) String 

func (p *NodeWriteNewSeriesLimitPerShardPerSecondResult_) String() string

func (*NodeWriteNewSeriesLimitPerShardPerSecondResult_) Write 

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

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 (p *NodeWriteTaggedArgs) GetReq() *WriteTaggedRequest

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 (p *NodeWriteTaggedBatchRawArgs) GetReq() *WriteTaggedBatchRawRequest

func (*NodeWriteTaggedBatchRawArgs) IsSetReq 

func (p *NodeWriteTaggedBatchRawArgs) IsSetReq() bool

func (*NodeWriteTaggedBatchRawArgs) Read 

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

func (*NodeWriteTaggedBatchRawArgs) ReadField1 

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

func (*NodeWriteTaggedBatchRawArgs) String 

func (p *NodeWriteTaggedBatchRawArgs) String() string

func (*NodeWriteTaggedBatchRawArgs) Write 

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

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 (p *NodeWriteTaggedBatchRawResult) GetErr() *WriteBatchRawErrors

func (*NodeWriteTaggedBatchRawResult) IsSetErr 

func (p *NodeWriteTaggedBatchRawResult) IsSetErr() bool

func (*NodeWriteTaggedBatchRawResult) Read 

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

func (*NodeWriteTaggedBatchRawResult) ReadField1 

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

func (*NodeWriteTaggedBatchRawResult) String 

func (p *NodeWriteTaggedBatchRawResult) String() string

func (*NodeWriteTaggedBatchRawResult) Write 

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

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 (p *NodeWriteTaggedBatchRawV2Args) GetReq() *WriteTaggedBatchRawV2Request

func (*NodeWriteTaggedBatchRawV2Args) IsSetReq added in v0.14.0 

func (p *NodeWriteTaggedBatchRawV2Args) IsSetReq() bool

func (*NodeWriteTaggedBatchRawV2Args) Read added in v0.14.0 

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

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 (p *NodeWriteTaggedBatchRawV2Args) String() string

func (*NodeWriteTaggedBatchRawV2Args) Write added in v0.14.0 

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

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 (p *NodeWriteTaggedBatchRawV2Result) GetErr() *WriteBatchRawErrors

func (*NodeWriteTaggedBatchRawV2Result) IsSetErr added in v0.14.0 

func (p *NodeWriteTaggedBatchRawV2Result) IsSetErr() bool

func (*NodeWriteTaggedBatchRawV2Result) Read added in v0.14.0 

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

func (*NodeWriteTaggedBatchRawV2Result) ReadField1 added in v0.14.0 

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

func (*NodeWriteTaggedBatchRawV2Result) String added in v0.14.0 

func (p *NodeWriteTaggedBatchRawV2Result) String() string

func (*NodeWriteTaggedBatchRawV2Result) Write added in v0.14.0 

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

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 (p *NodeWriteTaggedResult) Read(iprot thrift.TProtocol) error

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"`
	Source         []byte   `thrift:"source,9" db:"source" json:"source,omitempty"`
}

Attributes:

  • Query
  • RangeStart
  • RangeEnd
  • NameSpace
  • Limit
  • NoData
  • RangeType
  • ResultTimeType
  • Source
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) GetSource added in v1.0.1 

func (p *QueryRequest) GetSource() []byte

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) IsSetSource added in v1.0.1 

func (p *QueryRequest) IsSetSource() 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) ReadField9 added in v1.0.1 

func (p *QueryRequest) ReadField9(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 (p *WriteBatchRawRequest) GetElements() []*WriteBatchRawRequestElement

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 (p *WriteBatchRawRequestElement) Read(iprot thrift.TProtocol) error

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 

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

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 (p *WriteBatchRawV2Request) GetElements() []*WriteBatchRawV2RequestElement

func (*WriteBatchRawV2Request) GetNameSpaces added in v0.14.0 

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

func (*WriteBatchRawV2Request) Read added in v0.14.0 

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

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 (p *WriteBatchRawV2RequestElement) Read(iprot thrift.TProtocol) error

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 (p *WriteBatchRawV2RequestElement) String() string

func (*WriteBatchRawV2RequestElement) Write added in v0.14.0 

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

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 (p *WriteTaggedBatchRawRequest) GetElements() []*WriteTaggedBatchRawRequestElement

func (*WriteTaggedBatchRawRequest) GetNameSpace 

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

func (*WriteTaggedBatchRawRequest) Read 

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

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 

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

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 (p *WriteTaggedBatchRawRequestElement) GetID() []byte

func (*WriteTaggedBatchRawRequestElement) IsSetDatapoint 

func (p *WriteTaggedBatchRawRequestElement) IsSetDatapoint() bool

func (*WriteTaggedBatchRawRequestElement) Read 

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

func (*WriteTaggedBatchRawRequestElement) ReadField1 

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

func (*WriteTaggedBatchRawRequestElement) ReadField2 

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

func (*WriteTaggedBatchRawRequestElement) ReadField3 

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

func (*WriteTaggedBatchRawRequestElement) String 

func (p *WriteTaggedBatchRawRequestElement) String() string

func (*WriteTaggedBatchRawRequestElement) Write 

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

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 (p *WriteTaggedBatchRawV2Request) GetElements() []*WriteTaggedBatchRawV2RequestElement

func (*WriteTaggedBatchRawV2Request) GetNameSpaces added in v0.14.0 

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

func (*WriteTaggedBatchRawV2Request) Read added in v0.14.0 

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

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 (p *WriteTaggedBatchRawV2Request) String() string

func (*WriteTaggedBatchRawV2Request) Write added in v0.14.0 

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

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 (p *WriteTaggedBatchRawV2RequestElement) GetDatapoint() *Datapoint

func (*WriteTaggedBatchRawV2RequestElement) GetEncodedTags added in v0.14.0 

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

func (*WriteTaggedBatchRawV2RequestElement) GetID added in v0.14.0 

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

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 (p *WriteTaggedBatchRawV2RequestElement) Read(iprot thrift.TProtocol) error

func (*WriteTaggedBatchRawV2RequestElement) ReadField1 added in v0.14.0 

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

func (*WriteTaggedBatchRawV2RequestElement) ReadField2 added in v0.14.0 

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

func (*WriteTaggedBatchRawV2RequestElement) ReadField3 added in v0.14.0 

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

func (*WriteTaggedBatchRawV2RequestElement) ReadField4 added in v0.14.0 

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

func (*WriteTaggedBatchRawV2RequestElement) String added in v0.14.0 

func (p *WriteTaggedBatchRawV2RequestElement) String() string

func (*WriteTaggedBatchRawV2RequestElement) Write added in v0.14.0 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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