msgservice

package
v1.5.3-rc4 Latest Latest
Warning

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

 Go to latest Published: Jan 15, 2026 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	UnknownMessage uint8 = iota

	SeriesKeysRequestMessage
	SeriesKeysResponseMessage

	SeriesExactCardinalityRequestMessage
	SeriesExactCardinalityResponseMessage

	SeriesCardinalityRequestMessage
	SeriesCardinalityResponseMessage

	ShowTagValuesRequestMessage
	ShowTagValuesResponseMessage

	ShowTagValuesCardinalityRequestMessage
	ShowTagValuesCardinalityResponseMessage

	GetShardSplitPointsRequestMessage
	GetShardSplitPointsResponseMessage

	DeleteRequestMessage
	DeleteResponseMessage

	CreateDataBaseRequestMessage
	CreateDatabaseResponseMessage

	ShowQueriesRequestMessage
	ShowQueriesResponseMessage

	KillQueryRequestMessage
	KillQueryResponseMessage

	ShowTagKeysRequestMessage
	ShowTagKeysResponseMessage

	RaftMessagesRequestMessage
	RaftMessagesResponseMessage

	DropSeriesRequestMessage
	DropSeriesResponseMessage

	ShowLastIndexRequestMessage
	ShowLastIndexResponseMessage

	SmarterQueryRequestMessage
	SmarterQueryResponseMessage

	PullRPPTWriteStatusRequestMessage
	PullRPPTWriteStatusResponseMessage

	GetTaskRequestMessage
	GetTaskResponseMessage

	SendTaskResultRequestMessage
	SendTaskResultResponseMessage
)
View Source 
const (
	ShowMeasurementsStatement           = "ShowMeasurementsStatement"
	ShowTagKeysStatement                = "ShowTagKeysStatement"
	ShowTagValuesStatement              = "ShowTagValuesStatement"
	ShowSeriesCardinalityStatement      = "ShowSeriesCardinalityStatement"
	ShowMeasurementCardinalityStatement = "ShowMeasurementCardinalityStatement"
)

Variables

View Source 
var MessageBinaryCodec = make(map[uint8]func() codec.BinaryCodec, 20)
View Source 
var MessageResponseTyp = make(map[uint8]uint8, 20)
View Source 
var RaftMsgRequestPool = pool.NewUnionPool(cpu.GetCpuNum(), 0, 0, func() *RaftMessagesRequest {
	return &RaftMessagesRequest{}
})

Functions

func MarshalError 

func MarshalError(e error) *string

func NormalizeError 

func NormalizeError(errStr *string) error

Types

type BaseMessage 

type BaseMessage struct {
	Typ  uint8
	Data codec.BinaryCodec
}

func (*BaseMessage) Marshal 

func (bm *BaseMessage) Marshal(buf []byte) ([]byte, error)

func (*BaseMessage) Size 

func (bm *BaseMessage) Size() int

type CreateDataBaseRequest 

type CreateDataBaseRequest struct {
	internal2.CreateDataBaseRequest
}

func (*CreateDataBaseRequest) MarshalBinary 

func (r *CreateDataBaseRequest) MarshalBinary() ([]byte, error)

func (*CreateDataBaseRequest) UnmarshalBinary 

func (r *CreateDataBaseRequest) UnmarshalBinary(buf []byte) error

type CreateDataBaseResponse 

type CreateDataBaseResponse struct {
	internal2.CreateDataBaseResponse
}

func (*CreateDataBaseResponse) Error 

func (r *CreateDataBaseResponse) Error() error

func (*CreateDataBaseResponse) MarshalBinary 

func (r *CreateDataBaseResponse) MarshalBinary() ([]byte, error)

func (*CreateDataBaseResponse) UnmarshalBinary 

func (r *CreateDataBaseResponse) UnmarshalBinary(buf []byte) error

type DDLCallback 

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

func (*DDLCallback) GetCodec 

func (c *DDLCallback) GetCodec() transport.Codec

func (*DDLCallback) GetResponse 

func (c *DDLCallback) GetResponse() interface{}

func (*DDLCallback) Handle 

func (c *DDLCallback) Handle(data interface{}) error

type DDLMessage 

type DDLMessage struct {
	BaseMessage
}

func NewDDLMessage 

func NewDDLMessage(typ uint8, data codec.BinaryCodec) *DDLMessage

func (*DDLMessage) Instance 

func (m *DDLMessage) Instance() transport.Codec

func (*DDLMessage) Unmarshal 

func (m *DDLMessage) Unmarshal(buf []byte) error

type DeleteRequest 

type DeleteRequest struct {
	Database    string
	Rp          string
	Measurement string
	ShardIds    []uint64
	Type        DeleteType
	PtId        uint32
}

func (*DeleteRequest) MarshalBinary 

func (ddr *DeleteRequest) MarshalBinary() ([]byte, error)

func (*DeleteRequest) UnmarshalBinary 

func (ddr *DeleteRequest) UnmarshalBinary(data []byte) error

type DeleteResponse 

type DeleteResponse struct {
	Err error
}

func (*DeleteResponse) MarshalBinary 

func (dr *DeleteResponse) MarshalBinary() ([]byte, error)

func (*DeleteResponse) UnmarshalBinary 

func (dr *DeleteResponse) UnmarshalBinary(data []byte) error

type DeleteType 

type DeleteType int
const (
	DatabaseDelete DeleteType = iota
	RetentionPolicyDelete
	MeasurementDelete
)

type DropSeriesRequest 

type DropSeriesRequest struct {
	internal2.DropSeriesRequest
}

func (*DropSeriesRequest) MarshalBinary 

func (r *DropSeriesRequest) MarshalBinary() ([]byte, error)

func (*DropSeriesRequest) UnmarshalBinary 

func (r *DropSeriesRequest) UnmarshalBinary(buf []byte) error

type DropSeriesResponse 

type DropSeriesResponse struct {
	internal2.DropSeriesResponse
}

func (*DropSeriesResponse) Error 

func (r *DropSeriesResponse) Error() error

func (*DropSeriesResponse) MarshalBinary 

func (r *DropSeriesResponse) MarshalBinary() ([]byte, error)

func (*DropSeriesResponse) UnmarshalBinary 

func (r *DropSeriesResponse) UnmarshalBinary(buf []byte) error

type ExactCardinalityResponse 

type ExactCardinalityResponse struct {
	internal2.ExactCardinalityResponse
}

func (*ExactCardinalityResponse) Error 

func (r *ExactCardinalityResponse) Error() error

func (*ExactCardinalityResponse) MarshalBinary 

func (r *ExactCardinalityResponse) MarshalBinary() ([]byte, error)

func (*ExactCardinalityResponse) UnmarshalBinary 

func (r *ExactCardinalityResponse) UnmarshalBinary(buf []byte) error

type ExecuteStatementMessage 

type ExecuteStatementMessage struct {
	StatementType string
	Result        []byte
	Filtered      []byte
}

type GetShardSplitPointsRequest 

type GetShardSplitPointsRequest struct {
	internal2.GetShardSplitPointsRequest
}

func (*GetShardSplitPointsRequest) Error 

func (r *GetShardSplitPointsRequest) Error() error

func (*GetShardSplitPointsRequest) MarshalBinary 

func (r *GetShardSplitPointsRequest) MarshalBinary() ([]byte, error)

func (*GetShardSplitPointsRequest) UnmarshalBinary 

func (r *GetShardSplitPointsRequest) UnmarshalBinary(buf []byte) error

type GetShardSplitPointsResponse 

type GetShardSplitPointsResponse struct {
	internal2.GetShardSplitPointsResponse
}

func (*GetShardSplitPointsResponse) Error 

func (r *GetShardSplitPointsResponse) Error() error

func (*GetShardSplitPointsResponse) MarshalBinary 

func (r *GetShardSplitPointsResponse) MarshalBinary() ([]byte, error)

func (*GetShardSplitPointsResponse) UnmarshalBinary 

func (r *GetShardSplitPointsResponse) UnmarshalBinary(buf []byte) error

type GetTaskCallback 

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

func (*GetTaskCallback) GetCodec 

func (c *GetTaskCallback) GetCodec() transport.Codec

func (*GetTaskCallback) GetResponse 

func (c *GetTaskCallback) GetResponse() interface{}

func (*GetTaskCallback) Handle 

func (c *GetTaskCallback) Handle(data interface{}) error

type GetTaskRequest 

type GetTaskRequest struct {
	Type scheduler.TaskType
}

func (*GetTaskRequest) MarshalBinary 

func (r *GetTaskRequest) MarshalBinary() ([]byte, error)

func (*GetTaskRequest) UnmarshalBinary 

func (r *GetTaskRequest) UnmarshalBinary(buf []byte) error

type GetTaskResponse 

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

func (*GetTaskResponse) Error 

func (r *GetTaskResponse) Error() error

func (*GetTaskResponse) MarshalBinary 

func (r *GetTaskResponse) MarshalBinary() ([]byte, error)

func (*GetTaskResponse) Result 

func (r *GetTaskResponse) Result() scheduler.Task

func (*GetTaskResponse) SetError 

func (r *GetTaskResponse) SetError(err string)

func (*GetTaskResponse) SetTask 

func (r *GetTaskResponse) SetTask(task scheduler.Task)

func (*GetTaskResponse) UnmarshalBinary 

func (r *GetTaskResponse) UnmarshalBinary(buf []byte) error

type KillQueryRequest 

type KillQueryRequest struct {
	internal2.KillQueryRequest
}

func (*KillQueryRequest) MarshalBinary 

func (r *KillQueryRequest) MarshalBinary() ([]byte, error)

func (*KillQueryRequest) UnmarshalBinary 

func (r *KillQueryRequest) UnmarshalBinary(buf []byte) error

type KillQueryResponse 

type KillQueryResponse struct {
	internal2.KillQueryResponse
}

func (*KillQueryResponse) Error 

func (r *KillQueryResponse) Error() error

func (*KillQueryResponse) MarshalBinary 

func (r *KillQueryResponse) MarshalBinary() ([]byte, error)

func (*KillQueryResponse) UnmarshalBinary 

func (r *KillQueryResponse) UnmarshalBinary(buf []byte) error

type MigratePtCallback 

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

func (*MigratePtCallback) CallFn 

func (c *MigratePtCallback) CallFn(err error)

func (*MigratePtCallback) GetCodec 

func (c *MigratePtCallback) GetCodec() transport.Codec

func (*MigratePtCallback) GetResponse 

func (c *MigratePtCallback) GetResponse() interface{}

func (*MigratePtCallback) Handle 

func (c *MigratePtCallback) Handle(data interface{}) error

func (*MigratePtCallback) SetCallbackFn 

func (c *MigratePtCallback) SetCallbackFn(fn func(err error))

type PartialWriteError 

type PartialWriteError struct {
	Reason  error
	Dropped int

	// A sorted slice of series keys that were dropped.
	DroppedKeys [][]byte
}

PartialWriteError indicates a write request could only write a portion of the requested values.

func (PartialWriteError) Error 

func (e PartialWriteError) Error() string

type PingRequest 

type PingRequest struct {
}

func NewPingRequest 

func NewPingRequest() *PingRequest

func (*PingRequest) Instance 

func (r *PingRequest) Instance() transport.Codec

func (*PingRequest) Marshal 

func (r *PingRequest) Marshal(buf []byte) ([]byte, error)

func (*PingRequest) Size 

func (r *PingRequest) Size() int

func (*PingRequest) Unmarshal 

func (r *PingRequest) Unmarshal(buf []byte) error

type PtRequest 

type PtRequest struct {
	netdata.PtRequest
}

func NewPtRequest 

func NewPtRequest() *PtRequest

func (*PtRequest) Instance 

func (r *PtRequest) Instance() transport.Codec

func (*PtRequest) Marshal 

func (r *PtRequest) Marshal(buf []byte) ([]byte, error)

func (*PtRequest) Size 

func (r *PtRequest) Size() int

func (*PtRequest) Unmarshal 

func (r *PtRequest) Unmarshal(buf []byte) error

type PtResponse 

type PtResponse struct {
	netdata.PtResponse
}

func NewPtResponse 

func NewPtResponse() *PtResponse

func (*PtResponse) Error 

func (r *PtResponse) Error() error

func (*PtResponse) Instance 

func (r *PtResponse) Instance() transport.Codec

func (*PtResponse) Marshal 

func (r *PtResponse) Marshal(buf []byte) ([]byte, error)

func (*PtResponse) Size 

func (r *PtResponse) Size() int

func (*PtResponse) Unmarshal 

func (r *PtResponse) Unmarshal(buf []byte) error

type PullRPPTWriteStatusRequest 

type PullRPPTWriteStatusRequest struct {
	internal2.PullRPPTWriteStatusRequest
}

func (*PullRPPTWriteStatusRequest) MarshalBinary 

func (r *PullRPPTWriteStatusRequest) MarshalBinary() ([]byte, error)

func (*PullRPPTWriteStatusRequest) UnmarshalBinary 

func (r *PullRPPTWriteStatusRequest) UnmarshalBinary(buf []byte) error

type PullRPPTWriteStatusResponse 

type PullRPPTWriteStatusResponse struct {
	meta.RPPTWriteStatusResponse
}

type QueryExeInfo 

type QueryExeInfo struct {
	QueryID   uint64
	PtID      uint32
	Stmt      string
	Database  string
	BeginTime int64
	RunState  RunStateType
}

type RaftMessagesRequest 

type RaftMessagesRequest struct {
	Database    string
	PtId        uint32
	RaftMessage raftpb.Message
	Data        []byte
}

func (*RaftMessagesRequest) MarshalBinary 

func (r *RaftMessagesRequest) MarshalBinary() ([]byte, error)

func (*RaftMessagesRequest) Release 

func (r *RaftMessagesRequest) Release()

func (*RaftMessagesRequest) Reset 

func (r *RaftMessagesRequest) Reset()

func (*RaftMessagesRequest) UnmarshalBinary 

func (r *RaftMessagesRequest) UnmarshalBinary(buf []byte) error

type RaftMessagesResponse 

type RaftMessagesResponse struct {
	internal2.RaftMessagesResponse
}

func (*RaftMessagesResponse) MarshalBinary 

func (r *RaftMessagesResponse) MarshalBinary() ([]byte, error)

func (*RaftMessagesResponse) UnmarshalBinary 

func (r *RaftMessagesResponse) UnmarshalBinary(buf []byte) error

type RaftMsgCallback 

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

func (*RaftMsgCallback) GetCodec 

func (c *RaftMsgCallback) GetCodec() transport.Codec

func (*RaftMsgCallback) GetResponse 

func (c *RaftMsgCallback) GetResponse() interface{}

func (*RaftMsgCallback) Handle 

func (c *RaftMsgCallback) Handle(data interface{}) error

type RaftMsgMessage 

type RaftMsgMessage struct {
	BaseMessage
}

func NewRaftMsgMessage 

func NewRaftMsgMessage(typ uint8, data codec.BinaryCodec) *RaftMsgMessage

func (*RaftMsgMessage) Instance 

func (m *RaftMsgMessage) Instance() transport.Codec

func (*RaftMsgMessage) Unmarshal 

func (m *RaftMsgMessage) Unmarshal(buf []byte) error

type Requester 

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

func NewRequester 

func NewRequester(msgTyp uint8, data codec.BinaryCodec, mc meta.MetaClient) *Requester

func (*Requester) DDL 

func (r *Requester) DDL() (interface{}, error)

func (*Requester) GetNode 

func (r *Requester) GetNode() *meta2.DataNode

func (*Requester) InitWithNode 

func (r *Requester) InitWithNode(node *meta2.DataNode)

func (*Requester) InitWithNodeID 

func (r *Requester) InitWithNodeID(nodeID uint64) error

func (*Requester) RaftMsg 

func (r *Requester) RaftMsg() (interface{}, error)

func (*Requester) Request 

func (r *Requester) Request(queryTyp uint8, data transport.Codec, cb transport.Callback) error

func (*Requester) SetTimeout 

func (r *Requester) SetTimeout(timeout time.Duration)

func (*Requester) SetToInsert 

func (r *Requester) SetToInsert()

func (*Requester) SysCtrl 

func (r *Requester) SysCtrl(req *SysCtrlRequest) (interface{}, error)

func (*Requester) TaskResponse 

func (r *Requester) TaskResponse() (interface{}, error)

type RunStateType 

type RunStateType int32
const (
	Unknown RunStateType = iota
	Running
	Killed
)

type SegregateNodeRequest 

type SegregateNodeRequest struct {
	netdata.SegregateNodeRequest
}

func NewSegregateNodeRequest 

func NewSegregateNodeRequest() *SegregateNodeRequest

func (*SegregateNodeRequest) Instance 

func (r *SegregateNodeRequest) Instance() transport.Codec

func (*SegregateNodeRequest) Marshal 

func (r *SegregateNodeRequest) Marshal(buf []byte) ([]byte, error)

func (*SegregateNodeRequest) Size 

func (r *SegregateNodeRequest) Size() int

func (*SegregateNodeRequest) Unmarshal 

func (r *SegregateNodeRequest) Unmarshal(buf []byte) error

type SegregateNodeResponse 

type SegregateNodeResponse struct {
	netdata.SegregateNodeResponse
}

func NewSegregateNodeResponse 

func NewSegregateNodeResponse() *SegregateNodeResponse

func (*SegregateNodeResponse) Error 

func (r *SegregateNodeResponse) Error() error

func (*SegregateNodeResponse) Instance 

func (r *SegregateNodeResponse) Instance() transport.Codec

func (*SegregateNodeResponse) Marshal 

func (r *SegregateNodeResponse) Marshal(buf []byte) ([]byte, error)

func (*SegregateNodeResponse) Size 

func (r *SegregateNodeResponse) Size() int

func (*SegregateNodeResponse) Unmarshal 

func (r *SegregateNodeResponse) Unmarshal(buf []byte) error

type SendClearEventsRequest 

type SendClearEventsRequest struct {
	netdata.ClearEventsRequest
}

func NewSendClearEventsRequest 

func NewSendClearEventsRequest() *SendClearEventsRequest

func (*SendClearEventsRequest) Instance 

func (r *SendClearEventsRequest) Instance() transport.Codec

func (*SendClearEventsRequest) Marshal 

func (r *SendClearEventsRequest) Marshal(buf []byte) ([]byte, error)

func (*SendClearEventsRequest) Size 

func (r *SendClearEventsRequest) Size() int

func (*SendClearEventsRequest) Unmarshal 

func (r *SendClearEventsRequest) Unmarshal(buf []byte) error

type SendClearEventsResponse 

type SendClearEventsResponse struct {
	netdata.ClearEventsResponse
}

func NewSendClearEventsResponse 

func NewSendClearEventsResponse() *SendClearEventsResponse

func (*SendClearEventsResponse) Error 

func (r *SendClearEventsResponse) Error() error

func (*SendClearEventsResponse) Instance 

func (r *SendClearEventsResponse) Instance() transport.Codec

func (*SendClearEventsResponse) Marshal 

func (r *SendClearEventsResponse) Marshal(buf []byte) ([]byte, error)

func (*SendClearEventsResponse) Size 

func (r *SendClearEventsResponse) Size() int

func (*SendClearEventsResponse) Unmarshal 

func (r *SendClearEventsResponse) Unmarshal(buf []byte) error

type SendTaskResultRequest 

type SendTaskResultRequest struct {
	Uuid uint64
	Type scheduler.TaskType
	Info interface{}
}

func (*SendTaskResultRequest) MarshalBinary 

func (r *SendTaskResultRequest) MarshalBinary() ([]byte, error)

func (*SendTaskResultRequest) UnmarshalBinary 

func (r *SendTaskResultRequest) UnmarshalBinary(buf []byte) error

type SendTaskResultResponse 

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

func (*SendTaskResultResponse) Error 

func (r *SendTaskResultResponse) Error() string

func (*SendTaskResultResponse) MarshalBinary 

func (r *SendTaskResultResponse) MarshalBinary() ([]byte, error)

func (*SendTaskResultResponse) SetError 

func (r *SendTaskResultResponse) SetError(err string)

func (*SendTaskResultResponse) UnmarshalBinary 

func (r *SendTaskResultResponse) UnmarshalBinary(buf []byte) error

type SeriesCardinalityRequest 

type SeriesCardinalityRequest struct {
	SeriesKeysRequest
}

type SeriesCardinalityResponse 

type SeriesCardinalityResponse struct {
	meta.CardinalityResponse
}

type SeriesExactCardinalityRequest 

type SeriesExactCardinalityRequest struct {
	SeriesKeysRequest
}

type SeriesExactCardinalityResponse 

type SeriesExactCardinalityResponse struct {
	ExactCardinalityResponse
}

type SeriesKeysRequest 

type SeriesKeysRequest struct {
	internal2.SeriesKeysRequest
}

func (*SeriesKeysRequest) MarshalBinary 

func (r *SeriesKeysRequest) MarshalBinary() ([]byte, error)

func (*SeriesKeysRequest) UnmarshalBinary 

func (r *SeriesKeysRequest) UnmarshalBinary(buf []byte) error

type SeriesKeysResponse 

type SeriesKeysResponse struct {
	internal2.SeriesKeysResponse
}

func (*SeriesKeysResponse) Error 

func (r *SeriesKeysResponse) Error() error

func (*SeriesKeysResponse) MarshalBinary 

func (r *SeriesKeysResponse) MarshalBinary() ([]byte, error)

func (*SeriesKeysResponse) UnmarshalBinary 

func (r *SeriesKeysResponse) UnmarshalBinary(buf []byte) error

type ShowLastIndexRequest 

type ShowLastIndexRequest struct {
	internal2.ShowLastIndexRequest
}

func (*ShowLastIndexRequest) MarshalBinary 

func (r *ShowLastIndexRequest) MarshalBinary() ([]byte, error)

func (*ShowLastIndexRequest) UnmarshalBinary 

func (r *ShowLastIndexRequest) UnmarshalBinary(buf []byte) error

type ShowLastIndexResponse 

type ShowLastIndexResponse struct {
	meta.ShowLastInfoResponse
}

type ShowQueriesRequest 

type ShowQueriesRequest struct {
}

func (*ShowQueriesRequest) MarshalBinary 

func (r *ShowQueriesRequest) MarshalBinary() ([]byte, error)

func (*ShowQueriesRequest) UnmarshalBinary 

func (r *ShowQueriesRequest) UnmarshalBinary(buf []byte) error

type ShowQueriesResponse 

type ShowQueriesResponse struct {
	QueryExeInfos []*QueryExeInfo
}

func (*ShowQueriesResponse) MarshalBinary 

func (r *ShowQueriesResponse) MarshalBinary() ([]byte, error)

func (*ShowQueriesResponse) UnmarshalBinary 

func (r *ShowQueriesResponse) UnmarshalBinary(buf []byte) error

type ShowTagKeysRequest 

type ShowTagKeysRequest struct {
	internal2.ShowTagKeysRequest
}

func (*ShowTagKeysRequest) MarshalBinary 

func (r *ShowTagKeysRequest) MarshalBinary() ([]byte, error)

func (*ShowTagKeysRequest) UnmarshalBinary 

func (r *ShowTagKeysRequest) UnmarshalBinary(buf []byte) error

type ShowTagKeysResponse 

type ShowTagKeysResponse struct {
	internal2.ShowTagKeysResponse
}

func (*ShowTagKeysResponse) Error 

func (r *ShowTagKeysResponse) Error() error

func (*ShowTagKeysResponse) MarshalBinary 

func (r *ShowTagKeysResponse) MarshalBinary() ([]byte, error)

func (*ShowTagKeysResponse) UnmarshalBinary 

func (r *ShowTagKeysResponse) UnmarshalBinary(buf []byte) error

type ShowTagValuesCardinalityRequest 

type ShowTagValuesCardinalityRequest struct {
	ShowTagValuesRequest
}

type ShowTagValuesCardinalityResponse 

type ShowTagValuesCardinalityResponse struct {
	ExactCardinalityResponse
}

type ShowTagValuesRequest 

type ShowTagValuesRequest struct {
	internal2.ShowTagValuesRequest
}

func (*ShowTagValuesRequest) GetTagKeysBytes 

func (r *ShowTagValuesRequest) GetTagKeysBytes() map[string][][]byte

func (*ShowTagValuesRequest) MarshalBinary 

func (r *ShowTagValuesRequest) MarshalBinary() ([]byte, error)

func (*ShowTagValuesRequest) SetTagKeys 

func (r *ShowTagValuesRequest) SetTagKeys(tagKeys map[string]map[string]struct{})

func (*ShowTagValuesRequest) UnmarshalBinary 

func (r *ShowTagValuesRequest) UnmarshalBinary(buf []byte) error

type ShowTagValuesResponse 

type ShowTagValuesResponse struct {
	internal2.ShowTagValuesResponse
}

func (*ShowTagValuesResponse) Error 

func (r *ShowTagValuesResponse) Error() error

func (*ShowTagValuesResponse) GetTagValuesSlice 

func (r *ShowTagValuesResponse) GetTagValuesSlice() influxql.TablesTagSets

func (*ShowTagValuesResponse) MarshalBinary 

func (r *ShowTagValuesResponse) MarshalBinary() ([]byte, error)

func (*ShowTagValuesResponse) SetTagValuesSlice 

func (r *ShowTagValuesResponse) SetTagValuesSlice(s influxql.TablesTagSets)

func (*ShowTagValuesResponse) UnmarshalBinary 

func (r *ShowTagValuesResponse) UnmarshalBinary(buf []byte) error

type SmarterQueryRequest 

type SmarterQueryRequest struct {
	internal2.SmarterQueryRequest
}

func (*SmarterQueryRequest) MarshalBinary 

func (r *SmarterQueryRequest) MarshalBinary() ([]byte, error)

func (*SmarterQueryRequest) UnmarshalBinary 

func (r *SmarterQueryRequest) UnmarshalBinary(buf []byte) error

type SmarterQueryResponse 

type SmarterQueryResponse struct {
	Err  *string
	Data []byte
	// contains filtered or unexported fields
}

func (*SmarterQueryResponse) Error 

func (r *SmarterQueryResponse) Error() error

func (*SmarterQueryResponse) GetResult 

func (r *SmarterQueryResponse) GetResult() *record.SmartQueryResult

func (*SmarterQueryResponse) MarshalBinary 

func (r *SmarterQueryResponse) MarshalBinary() ([]byte, error)

func (*SmarterQueryResponse) Release 

func (r *SmarterQueryResponse) Release()

func (*SmarterQueryResponse) SetResult 

func (r *SmarterQueryResponse) SetResult(res *record.SmartQueryResult)

func (*SmarterQueryResponse) UnmarshalBinary 

func (r *SmarterQueryResponse) UnmarshalBinary(buf []byte) error

type StreamVar 

type StreamVar struct {
	Only bool
	Id   []uint64
}

func (*StreamVar) Instance 

func (s *StreamVar) Instance() transport.Codec

func (*StreamVar) Marshal 

func (s *StreamVar) Marshal(buf []byte) ([]byte, error)

func (*StreamVar) Size 

func (s *StreamVar) Size() int

func (*StreamVar) Unmarshal 

func (s *StreamVar) Unmarshal(buf []byte) error

type SysCtrlCallback 

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

func (*SysCtrlCallback) GetCodec 

func (c *SysCtrlCallback) GetCodec() transport.Codec

func (*SysCtrlCallback) GetResponse 

func (c *SysCtrlCallback) GetResponse() interface{}

func (*SysCtrlCallback) Handle 

func (c *SysCtrlCallback) Handle(data interface{}) error

type SysCtrlRequest 

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

func (*SysCtrlRequest) Get 

func (s *SysCtrlRequest) Get(key string) (v string, ok bool)

func (*SysCtrlRequest) Instance 

func (s *SysCtrlRequest) Instance() transport.Codec

func (*SysCtrlRequest) LocalBindAddress 

func (s *SysCtrlRequest) LocalBindAddress() string

func (*SysCtrlRequest) LocalDomain 

func (s *SysCtrlRequest) LocalDomain() string

func (*SysCtrlRequest) Marshal 

func (s *SysCtrlRequest) Marshal(buf []byte) ([]byte, error)

func (*SysCtrlRequest) Mod 

func (s *SysCtrlRequest) Mod() string

func (*SysCtrlRequest) Param 

func (s *SysCtrlRequest) Param() map[string]string

func (*SysCtrlRequest) SetLocalBindAddress 

func (s *SysCtrlRequest) SetLocalBindAddress(addr string)

func (*SysCtrlRequest) SetLocalDomain 

func (s *SysCtrlRequest) SetLocalDomain(domain string)

func (*SysCtrlRequest) SetMod 

func (s *SysCtrlRequest) SetMod(m string)

func (*SysCtrlRequest) SetParam 

func (s *SysCtrlRequest) SetParam(m map[string]string)

func (*SysCtrlRequest) Size 

func (s *SysCtrlRequest) Size() int

func (*SysCtrlRequest) Unmarshal 

func (s *SysCtrlRequest) Unmarshal(buf []byte) error

type SysCtrlResponse 

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

func (*SysCtrlResponse) Error 

func (s *SysCtrlResponse) Error() error

func (*SysCtrlResponse) Instance 

func (s *SysCtrlResponse) Instance() transport.Codec

func (*SysCtrlResponse) Marshal 

func (s *SysCtrlResponse) Marshal(buf []byte) ([]byte, error)

func (*SysCtrlResponse) Result 

func (s *SysCtrlResponse) Result() map[string]string

func (*SysCtrlResponse) SetErr 

func (s *SysCtrlResponse) SetErr(err string)

func (*SysCtrlResponse) SetResult 

func (s *SysCtrlResponse) SetResult(ret map[string]string)

func (*SysCtrlResponse) Size 

func (s *SysCtrlResponse) Size() int

func (*SysCtrlResponse) Unmarshal 

func (s *SysCtrlResponse) Unmarshal(buf []byte) error

type TaskMessage 

type TaskMessage struct {
	BaseMessage
}

func NewTaskMessage 

func NewTaskMessage(typ uint8, data codec.BinaryCodec) *TaskMessage

func (*TaskMessage) Instance 

func (m *TaskMessage) Instance() transport.Codec

func (*TaskMessage) Unmarshal 

func (m *TaskMessage) Unmarshal(buf []byte) error

type TransferLeadershipRequest 

type TransferLeadershipRequest struct {
	netdata.TransferLeadershipRequest
}

func NewTransferLeadershipRequest 

func NewTransferLeadershipRequest() *TransferLeadershipRequest

func (*TransferLeadershipRequest) Instance 

func (r *TransferLeadershipRequest) Instance() transport.Codec

func (*TransferLeadershipRequest) Marshal 

func (r *TransferLeadershipRequest) Marshal(buf []byte) ([]byte, error)

func (*TransferLeadershipRequest) Size 

func (r *TransferLeadershipRequest) Size() int

func (*TransferLeadershipRequest) Unmarshal 

func (r *TransferLeadershipRequest) Unmarshal(buf []byte) error

type TransferLeadershipResponse 

type TransferLeadershipResponse struct {
	netdata.TransferLeadershipResponse
}

func NewTransferLeadershipResponse 

func NewTransferLeadershipResponse() *TransferLeadershipResponse

func (*TransferLeadershipResponse) Error 

func (r *TransferLeadershipResponse) Error() error

func (*TransferLeadershipResponse) Instance 

func (r *TransferLeadershipResponse) Instance() transport.Codec

func (*TransferLeadershipResponse) Marshal 

func (r *TransferLeadershipResponse) Marshal(buf []byte) ([]byte, error)

func (*TransferLeadershipResponse) Size 

func (r *TransferLeadershipResponse) Size() int

func (*TransferLeadershipResponse) Unmarshal 

func (r *TransferLeadershipResponse) Unmarshal(buf []byte) error

type WriteBlobsCallback 

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

func (*WriteBlobsCallback) GetCodec 

func (c *WriteBlobsCallback) GetCodec() transport.Codec

func (*WriteBlobsCallback) Handle 

func (c *WriteBlobsCallback) Handle(data interface{}) error

type WriteBlobsRequest 

type WriteBlobsRequest struct {
	Db    string
	Rp    string
	Pt    uint32
	Shard uint64
	Bg    *shelf.BlobGroup
}

func NewWriteBlobsRequest 

func NewWriteBlobsRequest(db string, rp string, pt uint32, shard uint64, bg *shelf.BlobGroup) *WriteBlobsRequest

func (*WriteBlobsRequest) Instance 

func (r *WriteBlobsRequest) Instance() transport.Codec

func (*WriteBlobsRequest) Marshal 

func (r *WriteBlobsRequest) Marshal(buf []byte) ([]byte, error)

func (*WriteBlobsRequest) Size 

func (r *WriteBlobsRequest) Size() int

func (*WriteBlobsRequest) Unmarshal 

func (r *WriteBlobsRequest) Unmarshal(buf []byte) error

type WriteBlobsResponse 

type WriteBlobsResponse struct {
	Code    uint8
	ErrCode errno.Errno
	Message string
}

func NewWriteBlobsResponse 

func NewWriteBlobsResponse(code uint8, errCode errno.Errno, message string) *WriteBlobsResponse

func (*WriteBlobsResponse) Instance 

func (r *WriteBlobsResponse) Instance() transport.Codec

func (*WriteBlobsResponse) Marshal 

func (r *WriteBlobsResponse) Marshal(buf []byte) ([]byte, error)

func (*WriteBlobsResponse) Size 

func (r *WriteBlobsResponse) Size() int

func (*WriteBlobsResponse) Unmarshal 

func (r *WriteBlobsResponse) Unmarshal(buf []byte) error

type WritePointsCallback 

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

func (*WritePointsCallback) GetCodec 

func (c *WritePointsCallback) GetCodec() transport.Codec

func (*WritePointsCallback) Handle 

func (c *WritePointsCallback) Handle(data interface{}) error

type WritePointsRequest 

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

func NewWritePointsRequest 

func NewWritePointsRequest(points []byte) *WritePointsRequest

func (*WritePointsRequest) Instance 

func (r *WritePointsRequest) Instance() transport.Codec

func (*WritePointsRequest) Marshal 

func (r *WritePointsRequest) Marshal(buf []byte) ([]byte, error)

func (*WritePointsRequest) Points 

func (r *WritePointsRequest) Points() []byte

func (*WritePointsRequest) Size 

func (r *WritePointsRequest) Size() int

func (*WritePointsRequest) Unmarshal 

func (r *WritePointsRequest) Unmarshal(buf []byte) error

type WritePointsResponse 

type WritePointsResponse struct {
	Code    uint8
	ErrCode errno.Errno
	Message string
}

func NewWritePointsResponse 

func NewWritePointsResponse(code uint8, errCode errno.Errno, message string) *WritePointsResponse

func (*WritePointsResponse) Instance 

func (r *WritePointsResponse) Instance() transport.Codec

func (*WritePointsResponse) Marshal 

func (r *WritePointsResponse) Marshal(buf []byte) ([]byte, error)

func (*WritePointsResponse) Size 

func (r *WritePointsResponse) Size() int

func (*WritePointsResponse) Unmarshal 

func (r *WritePointsResponse) Unmarshal(buf []byte) error

type WriteStreamPointsCallback 

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

func (*WriteStreamPointsCallback) GetCodec 

func (c *WriteStreamPointsCallback) GetCodec() transport.Codec

func (*WriteStreamPointsCallback) Handle 

func (c *WriteStreamPointsCallback) Handle(data interface{}) error

type WriteStreamPointsRequest 

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

func NewWriteStreamPointsRequest 

func NewWriteStreamPointsRequest(points []byte, streamVar []*StreamVar) *WriteStreamPointsRequest

func (*WriteStreamPointsRequest) Instance 

func (w *WriteStreamPointsRequest) Instance() transport.Codec

func (*WriteStreamPointsRequest) Marshal 

func (w *WriteStreamPointsRequest) Marshal(buf []byte) ([]byte, error)

func (*WriteStreamPointsRequest) Points 

func (w *WriteStreamPointsRequest) Points() []byte

func (*WriteStreamPointsRequest) Size 

func (w *WriteStreamPointsRequest) Size() int

func (*WriteStreamPointsRequest) StreamVars 

func (w *WriteStreamPointsRequest) StreamVars() []*StreamVar

func (*WriteStreamPointsRequest) Unmarshal 

func (w *WriteStreamPointsRequest) Unmarshal(buf []byte) error

type WriteStreamPointsResponse 

type WriteStreamPointsResponse struct {
	Code    uint8
	ErrCode errno.Errno
	Message string
}

func NewWriteStreamPointsResponse 

func NewWriteStreamPointsResponse(code uint8, errCode errno.Errno, message string) *WriteStreamPointsResponse

func (*WriteStreamPointsResponse) Instance 

func (r *WriteStreamPointsResponse) Instance() transport.Codec

func (*WriteStreamPointsResponse) Marshal 

func (r *WriteStreamPointsResponse) Marshal(buf []byte) ([]byte, error)

func (*WriteStreamPointsResponse) Size 

func (r *WriteStreamPointsResponse) Size() int

func (*WriteStreamPointsResponse) Unmarshal 

func (r *WriteStreamPointsResponse) Unmarshal(buf []byte) error

Source Files

View all Source files

Directories

Path Synopsis

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.