message

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Feb 29, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	UnknownMessage uint8 = iota + 1

	PingRequestMessage
	PingResponseMessage

	PeersRequestMessage
	PeersResponseMessage

	CreateNodeRequestMessage
	CreateNodeResponseMessage

	SnapshotRequestMessage
	SnapshotResponseMessage

	ExecuteRequestMessage
	ExecuteResponseMessage

	UpdateRequestMessage
	UpdateResponseMessage

	ReportRequestMessage
	ReportResponseMessage

	GetShardInfoRequestMessage
	GetShardInfoResponseMessage

	GetDownSampleInfoRequestMessage
	GetDownSampleInfoResponseMessage

	GetRpMstInfosRequestMessage
	GetRpMstInfosResponseMessage

	GetUserInfoRequestMessage
	GetUserInfoResponseMessage

	GetStreamInfoRequestMessage
	GetStreamInfoResponseMessage

	GetMeasurementInfoRequestMessage
	GetMeasurementInfoResponseMessage

	GetMeasurementsInfoRequestMessage
	GetMeasurementsInfoResponseMessage

	GetDBBriefInfoRequestMessage
	GetDBBriefInfoResponseMessage

	RegisterQueryIDOffsetRequestMessage
	RegisterQueryIDOffsetResponseMessage

	Sql2MetaHeartbeatRequestMessage
	Sql2MetaHeartbeatResponseMessage

	GetContinuousQueryLeaseRequestMessage
	GetContinuousQueryLeaseResponseMessage

	VerifyDataNodeStatusRequestMessage
	VerifyDataNodeStatusResponseMessage

	SendSysCtrlToMetaRequestMessage
	SendSysCtrlToMetaResponseMessage
)

Variables

View Source 
var MetaMessageBinaryCodec = make(map[uint8]func() transport.Codec, 20)
View Source 
var MetaMessageResponseTyp = make(map[uint8]uint8, 20)

Functions

This section is empty.

Types

type CreateNodeRequest 

type CreateNodeRequest struct {
	WriteHost string
	QueryHost string
	Role      string
}

func (*CreateNodeRequest) Instance 

func (o *CreateNodeRequest) Instance() transport.Codec

func (*CreateNodeRequest) Marshal 

func (o *CreateNodeRequest) Marshal(buf []byte) ([]byte, error)

func (*CreateNodeRequest) Size 

func (o *CreateNodeRequest) Size() int

func (*CreateNodeRequest) Unmarshal 

func (o *CreateNodeRequest) Unmarshal(buf []byte) error

type CreateNodeResponse 

type CreateNodeResponse struct {
	//Header     map[string][]string
	Data []byte

	Err string
}

func (*CreateNodeResponse) Instance 

func (o *CreateNodeResponse) Instance() transport.Codec

func (*CreateNodeResponse) Marshal 

func (o *CreateNodeResponse) Marshal(buf []byte) ([]byte, error)

func (*CreateNodeResponse) Size 

func (o *CreateNodeResponse) Size() int

func (*CreateNodeResponse) Unmarshal 

func (o *CreateNodeResponse) Unmarshal(buf []byte) error

type ExecuteRequest 

type ExecuteRequest struct {
	Body []byte
}

func (*ExecuteRequest) Instance 

func (o *ExecuteRequest) Instance() transport.Codec

func (*ExecuteRequest) Marshal 

func (o *ExecuteRequest) Marshal(buf []byte) ([]byte, error)

func (*ExecuteRequest) Size 

func (o *ExecuteRequest) Size() int

func (*ExecuteRequest) Unmarshal 

func (o *ExecuteRequest) Unmarshal(buf []byte) error

type ExecuteResponse 

type ExecuteResponse struct {
	Index      uint64
	Err        string // can retry error
	ErrCommand string // do not to retry error
}

func (*ExecuteResponse) Instance 

func (o *ExecuteResponse) Instance() transport.Codec

func (*ExecuteResponse) Marshal 

func (o *ExecuteResponse) Marshal(buf []byte) ([]byte, error)

func (*ExecuteResponse) Size 

func (o *ExecuteResponse) Size() int

func (*ExecuteResponse) Unmarshal 

func (o *ExecuteResponse) Unmarshal(buf []byte) error

type GetContinuousQueryLeaseRequest added in v1.1.0 

type GetContinuousQueryLeaseRequest struct {
	Host string
}

func (*GetContinuousQueryLeaseRequest) Instance added in v1.1.0 

func (o *GetContinuousQueryLeaseRequest) Instance() transport.Codec

func (*GetContinuousQueryLeaseRequest) Marshal added in v1.1.0 

func (o *GetContinuousQueryLeaseRequest) Marshal(buf []byte) ([]byte, error)

func (*GetContinuousQueryLeaseRequest) Size added in v1.1.0 

func (o *GetContinuousQueryLeaseRequest) Size() int

func (*GetContinuousQueryLeaseRequest) Unmarshal added in v1.1.0 

func (o *GetContinuousQueryLeaseRequest) Unmarshal(buf []byte) error

type GetContinuousQueryLeaseResponse added in v1.1.0 

type GetContinuousQueryLeaseResponse struct {
	CQNames []string
	Err     string
}

func (*GetContinuousQueryLeaseResponse) Instance added in v1.1.0 

func (o *GetContinuousQueryLeaseResponse) Instance() transport.Codec

func (*GetContinuousQueryLeaseResponse) Marshal added in v1.1.0 

func (o *GetContinuousQueryLeaseResponse) Marshal(buf []byte) ([]byte, error)

func (*GetContinuousQueryLeaseResponse) Size added in v1.1.0 

func (o *GetContinuousQueryLeaseResponse) Size() int

func (*GetContinuousQueryLeaseResponse) Unmarshal added in v1.1.0 

func (o *GetContinuousQueryLeaseResponse) Unmarshal(buf []byte) error

type GetDownSampleInfoRequest added in v1.0.0 

type GetDownSampleInfoRequest struct{}

func (*GetDownSampleInfoRequest) Instance added in v1.0.0 

func (o *GetDownSampleInfoRequest) Instance() transport.Codec

func (*GetDownSampleInfoRequest) Marshal added in v1.0.0 

func (o *GetDownSampleInfoRequest) Marshal(buf []byte) ([]byte, error)

func (*GetDownSampleInfoRequest) Size added in v1.0.0 

func (o *GetDownSampleInfoRequest) Size() int

func (*GetDownSampleInfoRequest) Unmarshal added in v1.0.0 

func (o *GetDownSampleInfoRequest) Unmarshal(buf []byte) error

type GetDownSampleInfoResponse added in v1.0.0 

type GetDownSampleInfoResponse struct {
	Data []byte
	Err  string
}

func (*GetDownSampleInfoResponse) Instance added in v1.0.0 

func (o *GetDownSampleInfoResponse) Instance() transport.Codec

func (*GetDownSampleInfoResponse) Marshal added in v1.0.0 

func (o *GetDownSampleInfoResponse) Marshal(buf []byte) ([]byte, error)

func (*GetDownSampleInfoResponse) Size added in v1.0.0 

func (o *GetDownSampleInfoResponse) Size() int

func (*GetDownSampleInfoResponse) Unmarshal added in v1.0.0 

func (o *GetDownSampleInfoResponse) Unmarshal(buf []byte) error

type GetMeasurementInfoRequest added in v1.0.0 

type GetMeasurementInfoRequest struct {
	DbName  string
	RpName  string
	MstName string
}

func (*GetMeasurementInfoRequest) Instance added in v1.0.0 

func (o *GetMeasurementInfoRequest) Instance() transport.Codec

func (*GetMeasurementInfoRequest) Marshal added in v1.0.0 

func (o *GetMeasurementInfoRequest) Marshal(buf []byte) ([]byte, error)

func (*GetMeasurementInfoRequest) Size added in v1.0.0 

func (o *GetMeasurementInfoRequest) Size() int

func (*GetMeasurementInfoRequest) Unmarshal added in v1.0.0 

func (o *GetMeasurementInfoRequest) Unmarshal(buf []byte) error

type GetMeasurementInfoResponse added in v1.0.0 

type GetMeasurementInfoResponse struct {
	Data []byte
	Err  string
}

func (*GetMeasurementInfoResponse) Instance added in v1.0.0 

func (o *GetMeasurementInfoResponse) Instance() transport.Codec

func (*GetMeasurementInfoResponse) Marshal added in v1.0.0 

func (o *GetMeasurementInfoResponse) Marshal(buf []byte) ([]byte, error)

func (*GetMeasurementInfoResponse) Size added in v1.0.0 

func (o *GetMeasurementInfoResponse) Size() int

func (*GetMeasurementInfoResponse) Unmarshal added in v1.0.0 

func (o *GetMeasurementInfoResponse) Unmarshal(buf []byte) error

type GetMeasurementsInfoRequest added in v1.1.0 

type GetMeasurementsInfoRequest struct {
	DbName string
	RpName string
}

func (*GetMeasurementsInfoRequest) Instance added in v1.1.0 

func (o *GetMeasurementsInfoRequest) Instance() transport.Codec

func (*GetMeasurementsInfoRequest) Marshal added in v1.1.0 

func (o *GetMeasurementsInfoRequest) Marshal(buf []byte) ([]byte, error)

func (*GetMeasurementsInfoRequest) Size added in v1.1.0 

func (o *GetMeasurementsInfoRequest) Size() int

func (*GetMeasurementsInfoRequest) Unmarshal added in v1.1.0 

func (o *GetMeasurementsInfoRequest) Unmarshal(buf []byte) error

type GetMeasurementsInfoResponse added in v1.1.0 

type GetMeasurementsInfoResponse struct {
	Data []byte
	Err  string
}

func (*GetMeasurementsInfoResponse) Instance added in v1.1.0 

func (o *GetMeasurementsInfoResponse) Instance() transport.Codec

func (*GetMeasurementsInfoResponse) Marshal added in v1.1.0 

func (o *GetMeasurementsInfoResponse) Marshal(buf []byte) ([]byte, error)

func (*GetMeasurementsInfoResponse) Size added in v1.1.0 

func (o *GetMeasurementsInfoResponse) Size() int

func (*GetMeasurementsInfoResponse) Unmarshal added in v1.1.0 

func (o *GetMeasurementsInfoResponse) Unmarshal(buf []byte) error

type GetRpMstInfosRequest added in v1.0.0 

type GetRpMstInfosRequest struct {
	DbName    string
	RpName    string
	DataTypes []int64
}

func (*GetRpMstInfosRequest) Instance added in v1.0.0 

func (o *GetRpMstInfosRequest) Instance() transport.Codec

func (*GetRpMstInfosRequest) Marshal added in v1.0.0 

func (o *GetRpMstInfosRequest) Marshal(buf []byte) ([]byte, error)

func (*GetRpMstInfosRequest) Size added in v1.0.0 

func (o *GetRpMstInfosRequest) Size() int

func (*GetRpMstInfosRequest) Unmarshal added in v1.0.0 

func (o *GetRpMstInfosRequest) Unmarshal(buf []byte) error

type GetRpMstInfosResponse added in v1.0.0 

type GetRpMstInfosResponse struct {
	Data []byte
	Err  string
}

func (*GetRpMstInfosResponse) Instance added in v1.0.0 

func (o *GetRpMstInfosResponse) Instance() transport.Codec

func (*GetRpMstInfosResponse) Marshal added in v1.0.0 

func (o *GetRpMstInfosResponse) Marshal(buf []byte) ([]byte, error)

func (*GetRpMstInfosResponse) Size added in v1.0.0 

func (o *GetRpMstInfosResponse) Size() int

func (*GetRpMstInfosResponse) Unmarshal added in v1.0.0 

func (o *GetRpMstInfosResponse) Unmarshal(buf []byte) error

type GetShardInfoRequest 

type GetShardInfoRequest struct {
	Body []byte
}

func (*GetShardInfoRequest) Instance 

func (o *GetShardInfoRequest) Instance() transport.Codec

func (*GetShardInfoRequest) Marshal 

func (o *GetShardInfoRequest) Marshal(buf []byte) ([]byte, error)

func (*GetShardInfoRequest) Size 

func (o *GetShardInfoRequest) Size() int

func (*GetShardInfoRequest) Unmarshal 

func (o *GetShardInfoRequest) Unmarshal(buf []byte) error

type GetShardInfoResponse 

type GetShardInfoResponse struct {
	Data    []byte
	ErrCode errno.Errno
	Err     string
}

func (*GetShardInfoResponse) Instance 

func (o *GetShardInfoResponse) Instance() transport.Codec

func (*GetShardInfoResponse) Marshal 

func (o *GetShardInfoResponse) Marshal(buf []byte) ([]byte, error)

func (*GetShardInfoResponse) Size 

func (o *GetShardInfoResponse) Size() int

func (*GetShardInfoResponse) Unmarshal 

func (o *GetShardInfoResponse) Unmarshal(buf []byte) error

type GetStreamInfoRequest added in v1.0.0 

type GetStreamInfoRequest struct {
	Body []byte
}

func (*GetStreamInfoRequest) Instance added in v1.0.0 

func (o *GetStreamInfoRequest) Instance() transport.Codec

func (*GetStreamInfoRequest) Marshal added in v1.0.0 

func (o *GetStreamInfoRequest) Marshal(buf []byte) ([]byte, error)

func (*GetStreamInfoRequest) Size added in v1.0.0 

func (o *GetStreamInfoRequest) Size() int

func (*GetStreamInfoRequest) Unmarshal added in v1.0.0 

func (o *GetStreamInfoRequest) Unmarshal(buf []byte) error

type GetStreamInfoResponse added in v1.0.0 

type GetStreamInfoResponse struct {
	Data []byte
	Err  string
}

func (*GetStreamInfoResponse) Instance added in v1.0.0 

func (o *GetStreamInfoResponse) Instance() transport.Codec

func (*GetStreamInfoResponse) Marshal added in v1.0.0 

func (o *GetStreamInfoResponse) Marshal(buf []byte) ([]byte, error)

func (*GetStreamInfoResponse) Size added in v1.0.0 

func (o *GetStreamInfoResponse) Size() int

func (*GetStreamInfoResponse) Unmarshal added in v1.0.0 

func (o *GetStreamInfoResponse) Unmarshal(buf []byte) error

type MetaMessage 

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

func NewMetaMessage 

func NewMetaMessage(typ uint8, data transport.Codec) *MetaMessage

func (*MetaMessage) Data 

func (m *MetaMessage) Data() transport.Codec

func (*MetaMessage) Instance 

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

func (*MetaMessage) Marshal 

func (m *MetaMessage) Marshal(buf []byte) ([]byte, error)

func (*MetaMessage) Size 

func (m *MetaMessage) Size() int

func (*MetaMessage) Type 

func (m *MetaMessage) Type() uint8

func (*MetaMessage) Unmarshal 

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

type PeerInfo added in v1.1.0 

type PeerInfo struct {
	PtId   uint32
	NodeId uint64

	// map key is the master shard ID
	// map value is the slave shard ID
	ShardMapper map[uint64]uint64
}

func NewPeerInfo added in v1.1.0 

func NewPeerInfo(pt *meta.PtInfo) *PeerInfo

func (*PeerInfo) AddShardMapper added in v1.1.0 

func (p *PeerInfo) AddShardMapper(master, slave uint64)

func (*PeerInfo) GetSlaveShardID added in v1.1.0 

func (p *PeerInfo) GetSlaveShardID(masterShardID uint64) uint64

type PeersRequest 

type PeersRequest struct {
	codec.EmptyCodec
}

func (*PeersRequest) Instance 

func (o *PeersRequest) Instance() transport.Codec

type PeersResponse 

type PeersResponse struct {
	Peers      []string
	Err        string
	StatusCode int
}

func (*PeersResponse) Instance 

func (o *PeersResponse) Instance() transport.Codec

func (*PeersResponse) Marshal 

func (o *PeersResponse) Marshal(buf []byte) ([]byte, error)

func (*PeersResponse) Size 

func (o *PeersResponse) Size() int

func (*PeersResponse) Unmarshal 

func (o *PeersResponse) Unmarshal(buf []byte) error

type PingRequest 

type PingRequest struct {
	All int
}

func (*PingRequest) Instance 

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

func (*PingRequest) Marshal 

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

func (*PingRequest) Size 

func (o *PingRequest) Size() int

func (*PingRequest) Unmarshal 

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

type PingResponse 

type PingResponse struct {
	Leader []byte
	Err    string
}

func (*PingResponse) Instance 

func (o *PingResponse) Instance() transport.Codec

func (*PingResponse) Marshal 

func (o *PingResponse) Marshal(buf []byte) ([]byte, error)

func (*PingResponse) Size 

func (o *PingResponse) Size() int

func (*PingResponse) Unmarshal 

func (o *PingResponse) Unmarshal(buf []byte) error

type RegisterQueryIDOffsetRequest added in v1.1.0 

type RegisterQueryIDOffsetRequest struct {
	Host string
}

func (*RegisterQueryIDOffsetRequest) Instance added in v1.1.0 

func (o *RegisterQueryIDOffsetRequest) Instance() transport.Codec

func (*RegisterQueryIDOffsetRequest) Marshal added in v1.1.0 

func (o *RegisterQueryIDOffsetRequest) Marshal(buf []byte) ([]byte, error)

func (*RegisterQueryIDOffsetRequest) Size added in v1.1.0 

func (o *RegisterQueryIDOffsetRequest) Size() int

func (*RegisterQueryIDOffsetRequest) Unmarshal added in v1.1.0 

func (o *RegisterQueryIDOffsetRequest) Unmarshal(buf []byte) error

type RegisterQueryIDOffsetResponse added in v1.1.0 

type RegisterQueryIDOffsetResponse struct {
	Offset uint64
	Err    string
}

func (*RegisterQueryIDOffsetResponse) Instance added in v1.1.0 

func (o *RegisterQueryIDOffsetResponse) Instance() transport.Codec

func (*RegisterQueryIDOffsetResponse) Marshal added in v1.1.0 

func (o *RegisterQueryIDOffsetResponse) Marshal(buf []byte) ([]byte, error)

func (*RegisterQueryIDOffsetResponse) Size added in v1.1.0 

func (o *RegisterQueryIDOffsetResponse) Size() int

func (*RegisterQueryIDOffsetResponse) Unmarshal added in v1.1.0 

func (o *RegisterQueryIDOffsetResponse) Unmarshal(buf []byte) error

type ReplicaInfo added in v1.1.0 

type ReplicaInfo struct {
	ReplicaRole   meta.Role
	Master        *PeerInfo
	Peers         []*PeerInfo
	ReplicaStatus meta.RGStatus
	Term          uint64
}

func (*ReplicaInfo) AddPeer added in v1.1.0 

func (r *ReplicaInfo) AddPeer(p *PeerInfo)

type ReportRequest 

type ReportRequest struct {
	Body []byte
}

func (*ReportRequest) Instance 

func (o *ReportRequest) Instance() transport.Codec

func (*ReportRequest) Marshal 

func (o *ReportRequest) Marshal(buf []byte) ([]byte, error)

func (*ReportRequest) Size 

func (o *ReportRequest) Size() int

func (*ReportRequest) Unmarshal 

func (o *ReportRequest) Unmarshal(buf []byte) error

type ReportResponse 

type ReportResponse struct {
	Index      uint64
	Err        string // can retry error
	ErrCommand string // do not to retry error
}

func (*ReportResponse) Instance 

func (o *ReportResponse) Instance() transport.Codec

func (*ReportResponse) Marshal 

func (o *ReportResponse) Marshal(buf []byte) ([]byte, error)

func (*ReportResponse) Size 

func (o *ReportResponse) Size() int

func (*ReportResponse) Unmarshal 

func (o *ReportResponse) Unmarshal(buf []byte) error

type SendSysCtrlToMetaRequest added in v1.2.0 

type SendSysCtrlToMetaRequest struct {
	Mod   string
	Param map[string]string
}

func (*SendSysCtrlToMetaRequest) Instance added in v1.2.0 

func (req *SendSysCtrlToMetaRequest) Instance() transport.Codec

func (*SendSysCtrlToMetaRequest) Marshal added in v1.2.0 

func (req *SendSysCtrlToMetaRequest) Marshal(buf []byte) ([]byte, error)

func (*SendSysCtrlToMetaRequest) Size added in v1.2.0 

func (req *SendSysCtrlToMetaRequest) Size() int

func (*SendSysCtrlToMetaRequest) Unmarshal added in v1.2.0 

func (req *SendSysCtrlToMetaRequest) Unmarshal(buf []byte) error

type SendSysCtrlToMetaResponse added in v1.2.0 

type SendSysCtrlToMetaResponse struct {
	Err string
}

func (*SendSysCtrlToMetaResponse) Instance added in v1.2.0 

func (resp *SendSysCtrlToMetaResponse) Instance() transport.Codec

func (*SendSysCtrlToMetaResponse) Marshal added in v1.2.0 

func (resp *SendSysCtrlToMetaResponse) Marshal(buf []byte) ([]byte, error)

func (*SendSysCtrlToMetaResponse) Size added in v1.2.0 

func (resp *SendSysCtrlToMetaResponse) Size() int

func (*SendSysCtrlToMetaResponse) Unmarshal added in v1.2.0 

func (resp *SendSysCtrlToMetaResponse) Unmarshal(buf []byte) error

type SnapshotRequest 

type SnapshotRequest struct {
	Role  int
	Index uint64
}

func (*SnapshotRequest) Instance 

func (o *SnapshotRequest) Instance() transport.Codec

func (*SnapshotRequest) Marshal 

func (o *SnapshotRequest) Marshal(buf []byte) ([]byte, error)

func (*SnapshotRequest) Size 

func (o *SnapshotRequest) Size() int

func (*SnapshotRequest) Unmarshal 

func (o *SnapshotRequest) Unmarshal(buf []byte) error

type SnapshotResponse 

type SnapshotResponse struct {
	Data []byte
	Err  string
}

func (*SnapshotResponse) Instance 

func (o *SnapshotResponse) Instance() transport.Codec

func (*SnapshotResponse) Marshal 

func (o *SnapshotResponse) Marshal(buf []byte) ([]byte, error)

func (*SnapshotResponse) Size 

func (o *SnapshotResponse) Size() int

func (*SnapshotResponse) Unmarshal 

func (o *SnapshotResponse) Unmarshal(buf []byte) error

type Sql2MetaHeartbeatRequest added in v1.1.0 

type Sql2MetaHeartbeatRequest struct {
	Host string
}

func (*Sql2MetaHeartbeatRequest) Instance added in v1.1.0 

func (o *Sql2MetaHeartbeatRequest) Instance() transport.Codec

func (*Sql2MetaHeartbeatRequest) Marshal added in v1.1.0 

func (o *Sql2MetaHeartbeatRequest) Marshal(buf []byte) ([]byte, error)

func (*Sql2MetaHeartbeatRequest) Size added in v1.1.0 

func (o *Sql2MetaHeartbeatRequest) Size() int

func (*Sql2MetaHeartbeatRequest) Unmarshal added in v1.1.0 

func (o *Sql2MetaHeartbeatRequest) Unmarshal(buf []byte) error

type Sql2MetaHeartbeatResponse added in v1.1.0 

type Sql2MetaHeartbeatResponse struct {
	Err string
}

func (*Sql2MetaHeartbeatResponse) Instance added in v1.1.0 

func (o *Sql2MetaHeartbeatResponse) Instance() transport.Codec

func (*Sql2MetaHeartbeatResponse) Marshal added in v1.1.0 

func (o *Sql2MetaHeartbeatResponse) Marshal(buf []byte) ([]byte, error)

func (*Sql2MetaHeartbeatResponse) Size added in v1.1.0 

func (o *Sql2MetaHeartbeatResponse) Size() int

func (*Sql2MetaHeartbeatResponse) Unmarshal added in v1.1.0 

func (o *Sql2MetaHeartbeatResponse) Unmarshal(buf []byte) error

type UpdateRequest 

type UpdateRequest struct {
	Body []byte
}

func (*UpdateRequest) Instance 

func (o *UpdateRequest) Instance() transport.Codec

func (*UpdateRequest) Marshal 

func (o *UpdateRequest) Marshal(buf []byte) ([]byte, error)

func (*UpdateRequest) Size 

func (o *UpdateRequest) Size() int

func (*UpdateRequest) Unmarshal 

func (o *UpdateRequest) Unmarshal(buf []byte) error

type UpdateResponse 

type UpdateResponse struct {
	Data       []byte
	Location   string
	Err        string
	StatusCode int
}

func (*UpdateResponse) Instance 

func (o *UpdateResponse) Instance() transport.Codec

func (*UpdateResponse) Marshal 

func (o *UpdateResponse) Marshal(buf []byte) ([]byte, error)

func (*UpdateResponse) Size 

func (o *UpdateResponse) Size() int

func (*UpdateResponse) Unmarshal 

func (o *UpdateResponse) Unmarshal(buf []byte) error

type UserSnapshotRequest 

type UserSnapshotRequest struct {
	Index uint64
}

func (*UserSnapshotRequest) Instance 

func (o *UserSnapshotRequest) Instance() transport.Codec

func (*UserSnapshotRequest) Marshal 

func (o *UserSnapshotRequest) Marshal(buf []byte) ([]byte, error)

func (*UserSnapshotRequest) Size 

func (o *UserSnapshotRequest) Size() int

func (*UserSnapshotRequest) Unmarshal 

func (o *UserSnapshotRequest) Unmarshal(buf []byte) error

type UserSnapshotResponse 

type UserSnapshotResponse struct {
	Err string
}

func (*UserSnapshotResponse) Instance 

func (o *UserSnapshotResponse) Instance() transport.Codec

func (*UserSnapshotResponse) Marshal 

func (o *UserSnapshotResponse) Marshal(buf []byte) ([]byte, error)

func (*UserSnapshotResponse) Size 

func (o *UserSnapshotResponse) Size() int

func (*UserSnapshotResponse) Unmarshal 

func (o *UserSnapshotResponse) Unmarshal(buf []byte) error

type VerifyDataNodeStatusRequest added in v1.1.1 

type VerifyDataNodeStatusRequest struct {
	NodeID uint64 // datanode node id
}

func (*VerifyDataNodeStatusRequest) Instance added in v1.1.1 

func (req *VerifyDataNodeStatusRequest) Instance() transport.Codec

func (*VerifyDataNodeStatusRequest) Marshal added in v1.1.1 

func (req *VerifyDataNodeStatusRequest) Marshal(buf []byte) ([]byte, error)

func (*VerifyDataNodeStatusRequest) Size added in v1.1.1 

func (req *VerifyDataNodeStatusRequest) Size() int

func (*VerifyDataNodeStatusRequest) Unmarshal added in v1.1.1 

func (req *VerifyDataNodeStatusRequest) Unmarshal(buf []byte) error

type VerifyDataNodeStatusResponse added in v1.1.1 

type VerifyDataNodeStatusResponse struct {
	Err string
}

func (*VerifyDataNodeStatusResponse) Instance added in v1.1.1 

func (resp *VerifyDataNodeStatusResponse) Instance() transport.Codec

func (*VerifyDataNodeStatusResponse) Marshal added in v1.1.1 

func (resp *VerifyDataNodeStatusResponse) Marshal(buf []byte) ([]byte, error)

func (*VerifyDataNodeStatusResponse) Size added in v1.1.1 

func (resp *VerifyDataNodeStatusResponse) Size() int

func (*VerifyDataNodeStatusResponse) Unmarshal added in v1.1.1 

func (resp *VerifyDataNodeStatusResponse) Unmarshal(buf []byte) 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.