msgservice

package
v1.5.2 Latest Latest
Warning

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

 Go to latest Published: Jan 9, 2026 License: Apache-2.0 Imports: 18 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
)
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)

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

func (*RaftMessagesRequest) MarshalBinary 

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

func (*RaftMessagesRequest) UnmarshalBinary 

func (r *RaftMessagesRequest) UnmarshalBinary(data []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)

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