node

package
v0.0.0-...-6cbfa36 Latest Latest
Warning

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

 Go to latest Published: May 18, 2018 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int

Functions

func NewTChanMemTSDBInheritedClient 

func NewTChanMemTSDBInheritedClient(thriftService string, client thrift.TChanClient) *tchanMemTSDBClient

func NewTChanMemTSDBServer 

func NewTChanMemTSDBServer(handler TChanMemTSDB) thrift.TChanServer

NewTChanMemTSDBServer wraps a handler for TChanMemTSDB so it can be registered with a thrift.Server.

Types

type FetchBatchRequest 

type FetchBatchRequest struct {
	StartUnixMs int64    `thrift:"startUnixMs,1,required" json:"startUnixMs"`
	EndUnixMs   int64    `thrift:"endUnixMs,2,required" json:"endUnixMs"`
	Ids         []string `thrift:"ids,3,required" json:"ids"`
}

Attributes:

  • StartUnixMs
  • EndUnixMs
  • Ids
var MemTSDBFetchBatchArgs_Req_DEFAULT FetchBatchRequest

func NewFetchBatchRequest 

func NewFetchBatchRequest() *FetchBatchRequest

func (*FetchBatchRequest) GetEndUnixMs 

func (p *FetchBatchRequest) GetEndUnixMs() int64

func (*FetchBatchRequest) GetIds 

func (p *FetchBatchRequest) GetIds() []string

func (*FetchBatchRequest) GetStartUnixMs 

func (p *FetchBatchRequest) GetStartUnixMs() int64

func (*FetchBatchRequest) Read 

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

func (*FetchBatchRequest) String 

func (p *FetchBatchRequest) String() string

func (*FetchBatchRequest) Write 

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

type FetchBatchResult_ 

type FetchBatchResult_ struct {
	Results []*FetchResult_ `thrift:"results,1,required" json:"results"`
}

Attributes:

  • Results
var MemTSDBFetchBatchResult_Success_DEFAULT *FetchBatchResult_ = nil

func NewFetchBatchResult_ 

func NewFetchBatchResult_() *FetchBatchResult_

func (*FetchBatchResult_) GetResults 

func (p *FetchBatchResult_) GetResults() []*FetchResult_

func (*FetchBatchResult_) Read 

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

func (*FetchBatchResult_) String 

func (p *FetchBatchResult_) String() string

func (*FetchBatchResult_) Write 

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

type FetchRequest 

type FetchRequest struct {
	StartUnixMs int64  `thrift:"startUnixMs,1,required" json:"startUnixMs"`
	EndUnixMs   int64  `thrift:"endUnixMs,2,required" json:"endUnixMs"`
	ID          string `thrift:"id,3,required" json:"id"`
}

Attributes:

  • StartUnixMs
  • EndUnixMs
  • ID
var MemTSDBFetchArgs_Req_DEFAULT FetchRequest

func NewFetchRequest 

func NewFetchRequest() *FetchRequest

func (*FetchRequest) GetEndUnixMs 

func (p *FetchRequest) GetEndUnixMs() int64

func (*FetchRequest) GetID 

func (p *FetchRequest) GetID() string

func (*FetchRequest) GetStartUnixMs 

func (p *FetchRequest) GetStartUnixMs() int64

func (*FetchRequest) Read 

func (p *FetchRequest) Read(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 {
	Segments []*Segment `thrift:"segments,1,required" json:"segments"`
}

Attributes:

  • Segments
var MemTSDBFetchResult_Success_DEFAULT *FetchResult_ = nil

func NewFetchResult_ 

func NewFetchResult_() *FetchResult_

func (*FetchResult_) GetSegments 

func (p *FetchResult_) GetSegments() []*Segment

func (*FetchResult_) Read 

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

func (*FetchResult_) String 

func (p *FetchResult_) String() string

func (*FetchResult_) Write 

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

type MemTSDB 

type MemTSDB interface {
	// Parameters:
	//  - Req
	Fetch(req *FetchRequest) (r *FetchResult_, err error)
	// Parameters:
	//  - Req
	FetchBatch(req *FetchBatchRequest) (r *FetchBatchResult_, err error)
}

type MemTSDBClient 

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

func NewMemTSDBClientFactory 

func NewMemTSDBClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *MemTSDBClient

func NewMemTSDBClientProtocol 

func NewMemTSDBClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *MemTSDBClient

func (*MemTSDBClient) Fetch 

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

Parameters:

  • Req

func (*MemTSDBClient) FetchBatch 

func (p *MemTSDBClient) FetchBatch(req *FetchBatchRequest) (r *FetchBatchResult_, err error)

Parameters:

  • Req

type MemTSDBFetchArgs 

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

Attributes:

  • Req

func NewMemTSDBFetchArgs 

func NewMemTSDBFetchArgs() *MemTSDBFetchArgs

func (*MemTSDBFetchArgs) GetReq 

func (p *MemTSDBFetchArgs) GetReq() FetchRequest

func (*MemTSDBFetchArgs) IsSetReq 

func (p *MemTSDBFetchArgs) IsSetReq() bool

func (*MemTSDBFetchArgs) Read 

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

func (*MemTSDBFetchArgs) String 

func (p *MemTSDBFetchArgs) String() string

func (*MemTSDBFetchArgs) Write 

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

type MemTSDBFetchBatchArgs 

type MemTSDBFetchBatchArgs struct {
	Req *FetchBatchRequest `thrift:"req,1" json:"req"`
}

Attributes:

  • Req

func NewMemTSDBFetchBatchArgs 

func NewMemTSDBFetchBatchArgs() *MemTSDBFetchBatchArgs

func (*MemTSDBFetchBatchArgs) GetReq 

func (p *MemTSDBFetchBatchArgs) GetReq() FetchBatchRequest

func (*MemTSDBFetchBatchArgs) IsSetReq 

func (p *MemTSDBFetchBatchArgs) IsSetReq() bool

func (*MemTSDBFetchBatchArgs) Read 

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

func (*MemTSDBFetchBatchArgs) String 

func (p *MemTSDBFetchBatchArgs) String() string

func (*MemTSDBFetchBatchArgs) Write 

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

type MemTSDBFetchBatchResult 

type MemTSDBFetchBatchResult struct {
	Success *FetchBatchResult_ `thrift:"success,0" json:"success,omitempty"`
}

Attributes:

  • Success

func NewMemTSDBFetchBatchResult 

func NewMemTSDBFetchBatchResult() *MemTSDBFetchBatchResult

func (*MemTSDBFetchBatchResult) GetSuccess 

func (p *MemTSDBFetchBatchResult) GetSuccess() *FetchBatchResult_

func (*MemTSDBFetchBatchResult) IsSetSuccess 

func (p *MemTSDBFetchBatchResult) IsSetSuccess() bool

func (*MemTSDBFetchBatchResult) Read 

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

func (*MemTSDBFetchBatchResult) String 

func (p *MemTSDBFetchBatchResult) String() string

func (*MemTSDBFetchBatchResult) Write 

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

type MemTSDBFetchResult 

type MemTSDBFetchResult struct {
	Success *FetchResult_ `thrift:"success,0" json:"success,omitempty"`
}

Attributes:

  • Success

func NewMemTSDBFetchResult 

func NewMemTSDBFetchResult() *MemTSDBFetchResult

func (*MemTSDBFetchResult) GetSuccess 

func (p *MemTSDBFetchResult) GetSuccess() *FetchResult_

func (*MemTSDBFetchResult) IsSetSuccess 

func (p *MemTSDBFetchResult) IsSetSuccess() bool

func (*MemTSDBFetchResult) Read 

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

func (*MemTSDBFetchResult) String 

func (p *MemTSDBFetchResult) String() string

func (*MemTSDBFetchResult) Write 

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

type MemTSDBProcessor 

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

func NewMemTSDBProcessor 

func NewMemTSDBProcessor(handler MemTSDB) *MemTSDBProcessor

func (*MemTSDBProcessor) AddToProcessorMap 

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

func (*MemTSDBProcessor) GetProcessorFunction 

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

func (*MemTSDBProcessor) Process 

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

func (*MemTSDBProcessor) ProcessorMap 

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

type Segment 

type Segment struct {
	Value []byte `thrift:"value,1,required" json:"value"`
}

Attributes:

  • Value

func NewSegment 

func NewSegment() *Segment

func (*Segment) GetValue 

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

func (*Segment) Read 

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

func (*Segment) String 

func (p *Segment) String() string

func (*Segment) Write 

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

type TChanMemTSDB 

type TChanMemTSDB interface {
	Fetch(ctx thrift.Context, req *FetchRequest) (*FetchResult_, error)
	FetchBatch(ctx thrift.Context, req *FetchBatchRequest) (*FetchBatchResult_, error)
}

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

func NewTChanMemTSDBClient 

func NewTChanMemTSDBClient(client thrift.TChanClient) TChanMemTSDB

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

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.