rpc

package
v0.4.8 Latest Latest
Warning

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

 Go to latest Published: Nov 19, 2018 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 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 FetchBlocksMetadataRawV2Request_IncludeChecksums_DEFAULT bool
View Source 
var FetchBlocksMetadataRawV2Request_IncludeLastRead_DEFAULT bool
View Source 
var FetchBlocksMetadataRawV2Request_IncludeSizes_DEFAULT bool
View Source 
var FetchBlocksMetadataRawV2Request_PageToken_DEFAULT []byte
View Source 
var FetchBlocksMetadataRawV2Result__NextPageToken_DEFAULT []byte
View Source 
var FetchTaggedIDResult__Segments_DEFAULT []*Segments
View Source 
var FetchTaggedRequest_Limit_DEFAULT int64
View Source 
var GoUnusedProtection__ int
View Source 
var NodeSetPersistRateLimitRequest_LimitCheckEvery_DEFAULT int64
View Source 
var NodeSetPersistRateLimitRequest_LimitEnabled_DEFAULT bool
View Source 
var NodeSetPersistRateLimitRequest_LimitMbps_DEFAULT float64
View Source 
var QueryRequest_Limit_DEFAULT int64
View Source 
var QueryRequest_NoData_DEFAULT bool
View Source 
var Segment_BlockSize_DEFAULT int64
View Source 
var Segment_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 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
	Fetch(req *FetchRequest) (r *FetchResult_, err error)
	// Parameters:
	//  - Req
	FetchTagged(req *FetchTaggedRequest) (r *FetchTaggedResult_, err error)
	// Parameters:
	//  - Req
	Truncate(req *TruncateRequest) (r *TruncateResult_, err 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) Fetch 

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

Parameters:

  • Req

func (*ClusterClient) FetchTagged 

func (p *ClusterClient) FetchTagged(req *FetchTaggedRequest) (r *FetchTaggedResult_, 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 ClusterFetchTaggedArgs 

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

Attributes:

  • Req

func NewClusterFetchTaggedArgs 

func NewClusterFetchTaggedArgs() *ClusterFetchTaggedArgs

func (*ClusterFetchTaggedArgs) GetReq 

func (p *ClusterFetchTaggedArgs) GetReq() *FetchTaggedRequest

func (*ClusterFetchTaggedArgs) IsSetReq 

func (p *ClusterFetchTaggedArgs) IsSetReq() bool

func (*ClusterFetchTaggedArgs) Read 

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

func (*ClusterFetchTaggedArgs) ReadField1 

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

func (*ClusterFetchTaggedArgs) String 

func (p *ClusterFetchTaggedArgs) String() string

func (*ClusterFetchTaggedArgs) Write 

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

type ClusterFetchTaggedResult 

type ClusterFetchTaggedResult 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 NewClusterFetchTaggedResult 

func NewClusterFetchTaggedResult() *ClusterFetchTaggedResult

func (*ClusterFetchTaggedResult) GetErr 

func (p *ClusterFetchTaggedResult) GetErr() *Error

func (*ClusterFetchTaggedResult) GetSuccess 

func (p *ClusterFetchTaggedResult) GetSuccess() *FetchTaggedResult_

func (*ClusterFetchTaggedResult) IsSetErr 

func (p *ClusterFetchTaggedResult) IsSetErr() bool

func (*ClusterFetchTaggedResult) IsSetSuccess 

func (p *ClusterFetchTaggedResult) IsSetSuccess() bool

func (*ClusterFetchTaggedResult) Read 

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

func (*ClusterFetchTaggedResult) ReadField0 

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

func (*ClusterFetchTaggedResult) ReadField1 

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

func (*ClusterFetchTaggedResult) String 

func (p *ClusterFetchTaggedResult) String() string

func (*ClusterFetchTaggedResult) Write 

func (p *ClusterFetchTaggedResult) 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 WriteRequest_Datapoint_DEFAULT *Datapoint
var WriteTaggedBatchRawRequestElement_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 DisjunctionQuery 

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

Attributes:

  • Queries
var Query_Disjunction_DEFAULT *DisjunctionQuery

func NewDisjunctionQuery 

func NewDisjunctionQuery() *DisjunctionQuery

func (*DisjunctionQuery) GetQueries 

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

func (*DisjunctionQuery) Read 

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

func (*DisjunctionQuery) ReadField1 

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

func (*DisjunctionQuery) String 

func (p *DisjunctionQuery) String() string

func (*DisjunctionQuery) Write 

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

type Error 

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

Attributes:

  • Type
  • Message
var BlockMetadataV2_Err_DEFAULT *Error
var Block_Err_DEFAULT *Error
var ClusterFetchResult_Err_DEFAULT *Error
var ClusterFetchTaggedResult_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 NodeBootstrappedResult_Err_DEFAULT *Error
var NodeFetchBatchRawResult_Err_DEFAULT *Error
var NodeFetchBlocksMetadataRawV2Result_Err_DEFAULT *Error
var NodeFetchBlocksRawResult_Err_DEFAULT *Error
var NodeFetchResult_Err_DEFAULT *Error
var NodeFetchTaggedResult_Err_DEFAULT *Error
var NodeGetPersistRateLimitResult_Err_DEFAULT *Error
var NodeGetWriteNewSeriesAsyncResult_Err_DEFAULT *Error
var NodeGetWriteNewSeriesBackoffDurationResult_Err_DEFAULT *Error
var NodeGetWriteNewSeriesLimitPerShardPerSecondResult_Err_DEFAULT *Error
var NodeHealthResult_Err_DEFAULT *Error
var NodeQueryResult_Err_DEFAULT *Error
var NodeRepairResult_Err_DEFAULT *Error
var NodeSetPersistRateLimitResult_Err_DEFAULT *Error
var NodeSetWriteNewSeriesAsyncResult_Err_DEFAULT *Error
var NodeSetWriteNewSeriesBackoffDurationResult_Err_DEFAULT *Error
var NodeSetWriteNewSeriesLimitPerShardPerSecondResult_Err_DEFAULT *Error
var NodeTruncateResult_Err_DEFAULT *Error
var NodeWriteResult_Err_DEFAULT *Error
var NodeWriteTaggedResult_Err_DEFAULT *Error
var WriteBatchRawError_Err_DEFAULT *Error

func NewError 

func NewError() *Error

func (*Error) Error 

func (p *Error) Error() string

func (*Error) GetMessage 

func (p *Error) GetMessage() string

func (*Error) GetType 

func (p *Error) GetType() ErrorType

func (*Error) Read 

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

func (*Error) ReadField1 

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

func (*Error) ReadField2 

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

func (*Error) String 

func (p *Error) String() string

func (*Error) Write 

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

type ErrorType 

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

func ErrorTypeFromString 

func ErrorTypeFromString(s string) (ErrorType, error)

func ErrorTypePtr 

func ErrorTypePtr(v ErrorType) *ErrorType

func (ErrorType) MarshalText 

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

func (*ErrorType) Scan 

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

func (ErrorType) String 

func (p ErrorType) String() string

func (*ErrorType) UnmarshalText 

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

func (*ErrorType) Value 

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

type FetchBatchRawRequest 

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

Attributes:

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

func NewFetchBatchRawRequest 

func NewFetchBatchRawRequest() *FetchBatchRawRequest

func (*FetchBatchRawRequest) GetIds 

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

func (*FetchBatchRawRequest) GetNameSpace 

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

func (*FetchBatchRawRequest) GetRangeEnd 

func (p *FetchBatchRawRequest) GetRangeEnd() int64

func (*FetchBatchRawRequest) GetRangeStart 

func (p *FetchBatchRawRequest) GetRangeStart() int64

func (*FetchBatchRawRequest) GetRangeTimeType 

func (p *FetchBatchRawRequest) GetRangeTimeType() TimeType

func (*FetchBatchRawRequest) IsSetRangeTimeType 

func (p *FetchBatchRawRequest) IsSetRangeTimeType() bool

func (*FetchBatchRawRequest) Read 

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

func (*FetchBatchRawRequest) ReadField1 

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

func (*FetchBatchRawRequest) ReadField2 

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

func (*FetchBatchRawRequest) ReadField3 

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

func (*FetchBatchRawRequest) ReadField4 

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

func (*FetchBatchRawRequest) ReadField5 

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

func (*FetchBatchRawRequest) String 

func (p *FetchBatchRawRequest) String() string

func (*FetchBatchRawRequest) Write 

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

type FetchBatchRawResult_ 

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

Attributes:

  • Elements
var NodeFetchBatchRawResult_Success_DEFAULT *FetchBatchRawResult_

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 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"`
}

Attributes:

  • NameSpace
  • Shard
  • Elements
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) 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) 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"`
}

Attributes:

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

func NewFetchRequest 

func NewFetchRequest() *FetchRequest

func (*FetchRequest) GetID 

func (p *FetchRequest) GetID() string

func (*FetchRequest) GetNameSpace 

func (p *FetchRequest) GetNameSpace() string

func (*FetchRequest) GetRangeEnd 

func (p *FetchRequest) GetRangeEnd() int64

func (*FetchRequest) GetRangeStart 

func (p *FetchRequest) GetRangeStart() int64

func (*FetchRequest) GetRangeType 

func (p *FetchRequest) GetRangeType() TimeType

func (*FetchRequest) GetResultTimeType 

func (p *FetchRequest) GetResultTimeType() TimeType

func (*FetchRequest) IsSetRangeType 

func (p *FetchRequest) IsSetRangeType() bool

func (*FetchRequest) IsSetResultTimeType 

func (p *FetchRequest) IsSetResultTimeType() bool

func (*FetchRequest) Read 

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

func (*FetchRequest) ReadField1 

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

func (*FetchRequest) ReadField2 

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

func (*FetchRequest) ReadField3 

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

func (*FetchRequest) ReadField4 

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

func (*FetchRequest) ReadField5 

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

func (*FetchRequest) ReadField6 

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

func (*FetchRequest) String 

func (p *FetchRequest) String() string

func (*FetchRequest) Write 

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

type FetchResult_ 

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

Attributes:

  • Datapoints
var ClusterFetchResult_Success_DEFAULT *FetchResult_
var NodeFetchResult_Success_DEFAULT *FetchResult_

func NewFetchResult_ 

func NewFetchResult_() *FetchResult_

func (*FetchResult_) GetDatapoints 

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

func (*FetchResult_) Read 

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

func (*FetchResult_) ReadField1 

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

func (*FetchResult_) String 

func (p *FetchResult_) String() string

func (*FetchResult_) Write 

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

type FetchTaggedIDResult_ 

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

Attributes:

  • ID
  • NameSpace
  • EncodedTags
  • Segments
  • Err

func NewFetchTaggedIDResult_ 

func NewFetchTaggedIDResult_() *FetchTaggedIDResult_

func (*FetchTaggedIDResult_) GetEncodedTags 

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

func (*FetchTaggedIDResult_) GetErr 

func (p *FetchTaggedIDResult_) GetErr() *Error

func (*FetchTaggedIDResult_) GetID 

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

func (*FetchTaggedIDResult_) GetNameSpace 

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

func (*FetchTaggedIDResult_) GetSegments 

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

func (*FetchTaggedIDResult_) IsSetErr 

func (p *FetchTaggedIDResult_) IsSetErr() bool

func (*FetchTaggedIDResult_) IsSetSegments 

func (p *FetchTaggedIDResult_) IsSetSegments() bool

func (*FetchTaggedIDResult_) Read 

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

func (*FetchTaggedIDResult_) ReadField1 

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

func (*FetchTaggedIDResult_) ReadField2 

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

func (*FetchTaggedIDResult_) ReadField3 

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

func (*FetchTaggedIDResult_) ReadField4 

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

func (*FetchTaggedIDResult_) ReadField5 

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

func (*FetchTaggedIDResult_) String 

func (p *FetchTaggedIDResult_) String() string

func (*FetchTaggedIDResult_) Write 

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

type FetchTaggedRequest 

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

Attributes:

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

func NewFetchTaggedRequest 

func NewFetchTaggedRequest() *FetchTaggedRequest

func (*FetchTaggedRequest) GetFetchData 

func (p *FetchTaggedRequest) GetFetchData() bool

func (*FetchTaggedRequest) GetLimit 

func (p *FetchTaggedRequest) GetLimit() int64

func (*FetchTaggedRequest) GetNameSpace 

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

func (*FetchTaggedRequest) GetQuery 

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

func (*FetchTaggedRequest) GetRangeEnd 

func (p *FetchTaggedRequest) GetRangeEnd() int64

func (*FetchTaggedRequest) GetRangeStart 

func (p *FetchTaggedRequest) GetRangeStart() int64

func (*FetchTaggedRequest) GetRangeTimeType 

func (p *FetchTaggedRequest) GetRangeTimeType() TimeType

func (*FetchTaggedRequest) IsSetLimit 

func (p *FetchTaggedRequest) IsSetLimit() bool

func (*FetchTaggedRequest) IsSetRangeTimeType 

func (p *FetchTaggedRequest) IsSetRangeTimeType() bool

func (*FetchTaggedRequest) Read 

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

func (*FetchTaggedRequest) ReadField1 

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

func (*FetchTaggedRequest) ReadField2 

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

func (*FetchTaggedRequest) ReadField3 

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

func (*FetchTaggedRequest) ReadField4 

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

func (*FetchTaggedRequest) ReadField5 

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

func (*FetchTaggedRequest) ReadField6 

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

func (*FetchTaggedRequest) ReadField7 

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

func (*FetchTaggedRequest) String 

func (p *FetchTaggedRequest) String() string

func (*FetchTaggedRequest) Write 

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

type FetchTaggedResult_ 

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

Attributes:

  • Elements
  • Exhaustive
var ClusterFetchTaggedResult_Success_DEFAULT *FetchTaggedResult_
var NodeFetchTaggedResult_Success_DEFAULT *FetchTaggedResult_

func NewFetchTaggedResult_ 

func NewFetchTaggedResult_() *FetchTaggedResult_

func (*FetchTaggedResult_) GetElements 

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

func (*FetchTaggedResult_) GetExhaustive 

func (p *FetchTaggedResult_) GetExhaustive() bool

func (*FetchTaggedResult_) Read 

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

func (*FetchTaggedResult_) ReadField1 

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

func (*FetchTaggedResult_) ReadField2 

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

func (*FetchTaggedResult_) String 

func (p *FetchTaggedResult_) String() string

func (*FetchTaggedResult_) Write 

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

type 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) 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) FetchTagged 

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

FetchTagged 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) Fetch 

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

Fetch indicates an expected call of Fetch

func (*MockTChanClusterMockRecorder) FetchTagged 

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

FetchTagged indicates an expected call of FetchTagged

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) Bootstrapped added in v0.4.6 

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

Bootstrapped 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) 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) 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

type MockTChanNodeMockRecorder 

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

MockTChanNodeMockRecorder is the mock recorder for MockTChanNode

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) 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) 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) 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

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
	Fetch(req *FetchRequest) (r *FetchResult_, err error)
	// Parameters:
	//  - Req
	FetchTagged(req *FetchTaggedRequest) (r *FetchTaggedResult_, err error)
	// Parameters:
	//  - Req
	Write(req *WriteRequest) (err error)
	// Parameters:
	//  - Req
	WriteTagged(req *WriteTaggedRequest) (err error)
	// Parameters:
	//  - Req
	FetchBatchRaw(req *FetchBatchRawRequest) (r *FetchBatchRawResult_, err error)
	// Parameters:
	//  - Req
	FetchBlocksRaw(req *FetchBlocksRawRequest) (r *FetchBlocksRawResult_, err error)
	// Parameters:
	//  - Req
	FetchBlocksMetadataRawV2(req *FetchBlocksMetadataRawV2Request) (r *FetchBlocksMetadataRawV2Result_, err error)
	// Parameters:
	//  - Req
	WriteBatchRaw(req *WriteBatchRawRequest) (err error)
	// Parameters:
	//  - Req
	WriteTaggedBatchRaw(req *WriteTaggedBatchRawRequest) (err error)
	Repair() (err error)
	// Parameters:
	//  - Req
	Truncate(req *TruncateRequest) (r *TruncateResult_, err error)
	Health() (r *NodeHealthResult_, err error)
	Bootstrapped() (r *NodeBootstrappedResult_, 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)
}

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 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) Bootstrapped added in v0.4.6 

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

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) 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) WriteTagged 

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

Parameters:

  • Req

func (*NodeClient) WriteTaggedBatchRaw 

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

Parameters:

  • Req

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 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"`
}

Attributes:

  • Ok
  • Status
  • Bootstrapped
var NodeHealthResult_Success_DEFAULT *NodeHealthResult_

func NewNodeHealthResult_ 

func NewNodeHealthResult_() *NodeHealthResult_

func (*NodeHealthResult_) GetBootstrapped 

func (p *NodeHealthResult_) GetBootstrapped() bool

func (*NodeHealthResult_) GetOk 

func (p *NodeHealthResult_) GetOk() bool

func (*NodeHealthResult_) GetStatus 

func (p *NodeHealthResult_) GetStatus() string

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_) 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 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 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"`
}

Attributes:

  • Term
  • Regexp
  • Negation
  • Conjunction
  • Disjunction
var NegationQuery_Query_DEFAULT *Query
var QueryRequest_Query_DEFAULT *Query

func NewQuery 

func NewQuery() *Query

func (*Query) GetConjunction 

func (p *Query) GetConjunction() *ConjunctionQuery

func (*Query) GetDisjunction 

func (p *Query) GetDisjunction() *DisjunctionQuery

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) IsSetConjunction 

func (p *Query) IsSetConjunction() bool

func (*Query) IsSetDisjunction 

func (p *Query) IsSetDisjunction() 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) String 

func (p *Query) String() string

func (*Query) Write 

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

type QueryRequest 

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

Attributes:

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

func NewQueryRequest 

func NewQueryRequest() *QueryRequest

func (*QueryRequest) GetLimit 

func (p *QueryRequest) GetLimit() int64

func (*QueryRequest) GetNameSpace 

func (p *QueryRequest) GetNameSpace() string

func (*QueryRequest) GetNoData 

func (p *QueryRequest) GetNoData() bool

func (*QueryRequest) GetQuery 

func (p *QueryRequest) GetQuery() *Query

func (*QueryRequest) GetRangeEnd 

func (p *QueryRequest) GetRangeEnd() int64

func (*QueryRequest) GetRangeStart 

func (p *QueryRequest) GetRangeStart() int64

func (*QueryRequest) GetRangeType 

func (p *QueryRequest) GetRangeType() TimeType

func (*QueryRequest) GetResultTimeType 

func (p *QueryRequest) GetResultTimeType() TimeType

func (*QueryRequest) IsSetLimit 

func (p *QueryRequest) IsSetLimit() bool

func (*QueryRequest) IsSetNoData 

func (p *QueryRequest) IsSetNoData() bool

func (*QueryRequest) IsSetQuery 

func (p *QueryRequest) IsSetQuery() bool

func (*QueryRequest) IsSetRangeType 

func (p *QueryRequest) IsSetRangeType() bool

func (*QueryRequest) IsSetResultTimeType 

func (p *QueryRequest) IsSetResultTimeType() bool

func (*QueryRequest) Read 

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

func (*QueryRequest) ReadField1 

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

func (*QueryRequest) ReadField2 

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

func (*QueryRequest) ReadField3 

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

func (*QueryRequest) ReadField4 

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

func (*QueryRequest) ReadField5 

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

func (*QueryRequest) ReadField6 

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

func (*QueryRequest) ReadField7 

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

func (*QueryRequest) ReadField8 

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

func (*QueryRequest) String 

func (p *QueryRequest) String() string

func (*QueryRequest) Write 

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

type QueryResultElement 

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

Attributes:

  • ID
  • Tags
  • Datapoints

func NewQueryResultElement 

func NewQueryResultElement() *QueryResultElement

func (*QueryResultElement) GetDatapoints 

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

func (*QueryResultElement) GetID 

func (p *QueryResultElement) GetID() string

func (*QueryResultElement) GetTags 

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

func (*QueryResultElement) Read 

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

func (*QueryResultElement) ReadField1 

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

func (*QueryResultElement) ReadField2 

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

func (*QueryResultElement) ReadField3 

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

func (*QueryResultElement) String 

func (p *QueryResultElement) String() string

func (*QueryResultElement) Write 

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

type QueryResult_ 

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

Attributes:

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

func NewQueryResult_ 

func NewQueryResult_() *QueryResult_

func (*QueryResult_) GetExhaustive 

func (p *QueryResult_) GetExhaustive() bool

func (*QueryResult_) GetResults 

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

func (*QueryResult_) Read 

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

func (*QueryResult_) ReadField1 

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

func (*QueryResult_) ReadField2 

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

func (*QueryResult_) String 

func (p *QueryResult_) String() string

func (*QueryResult_) Write 

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

type RegexpQuery 

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

Attributes:

  • Field
  • Regexp
var Query_Regexp_DEFAULT *RegexpQuery

func NewRegexpQuery 

func NewRegexpQuery() *RegexpQuery

func (*RegexpQuery) GetField 

func (p *RegexpQuery) GetField() string

func (*RegexpQuery) GetRegexp 

func (p *RegexpQuery) GetRegexp() string

func (*RegexpQuery) Read 

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

func (*RegexpQuery) ReadField1 

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

func (*RegexpQuery) ReadField2 

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

func (*RegexpQuery) String 

func (p *RegexpQuery) String() string

func (*RegexpQuery) Write 

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

type Segment 

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

Attributes:

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

func NewSegment 

func NewSegment() *Segment

func (*Segment) GetBlockSize 

func (p *Segment) GetBlockSize() 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) 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) 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 {
	Fetch(ctx thrift.Context, req *FetchRequest) (*FetchResult_, error)
	FetchTagged(ctx thrift.Context, req *FetchTaggedRequest) (*FetchTaggedResult_, 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 {
	Bootstrapped(ctx thrift.Context) (*NodeBootstrappedResult_, error)
	Fetch(ctx thrift.Context, req *FetchRequest) (*FetchResult_, error)
	FetchBatchRaw(ctx thrift.Context, req *FetchBatchRawRequest) (*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
	WriteTagged(ctx thrift.Context, req *WriteTaggedRequest) error
	WriteTaggedBatchRaw(ctx thrift.Context, req *WriteTaggedBatchRawRequest) 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 BlockMetadataV2_LastReadTimeType_DEFAULT TimeType = 0
var Datapoint_TimestampTimeType_DEFAULT TimeType = 0
var FetchBatchRawRequest_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 NodeWriteTaggedBatchRawResult_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 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 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.