ctl

package
v1.0.0-rc2 Latest Latest
Warning

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

 Go to latest Published: Oct 24, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCtl        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCtl          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCtl = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var CmdMethod_name = map[int32]string{
	0:  "Ping",
	1:  "Flush",
	2:  "Task",
	3:  "Checkpoint",
	4:  "UseSnapshot",
	5:  "GetSnapshot",
	6:  "ForceGC",
	7:  "Inspect",
	8:  "Label",
	9:  "SyncCommit",
	10: "GetCommit",
	11: "AddFaultPoint",
	12: "Backup",
	13: "TraceSpan",
}
View Source 
var CmdMethod_value = map[string]int32{
	"Ping":          0,
	"Flush":         1,
	"Task":          2,
	"Checkpoint":    3,
	"UseSnapshot":   4,
	"GetSnapshot":   5,
	"ForceGC":       6,
	"Inspect":       7,
	"Label":         8,
	"SyncCommit":    9,
	"GetCommit":     10,
	"AddFaultPoint": 11,
	"Backup":        12,
	"TraceSpan":     13,
}

Functions

This section is empty.

Types

type CmdMethod 

type CmdMethod int32

CmdMethod debug command method 

const (
	// Ping ping the service.
	CmdMethod_Ping CmdMethod = 0
	// Flush is to force flush the table data.
	// parameter should be "DbName.TableName"
	CmdMethod_Flush CmdMethod = 1
	// Task disable or enable task framework
	CmdMethod_Task CmdMethod = 2
	// Checkpoint is to force incremental checkpoint.
	CmdMethod_Checkpoint CmdMethod = 3
	// UseSnapshot use a spec snapshot timestamp, and all txn will use this ts as snapshot timestamp
	CmdMethod_UseSnapshot CmdMethod = 4
	// GetSnapshot get current snapshot timestamp
	CmdMethod_GetSnapshot CmdMethod = 5
	// ForceGC forcing a GC to free memory
	CmdMethod_ForceGC CmdMethod = 6
	// Inspect TN info
	CmdMethod_Inspect CmdMethod = 7
	// Label sets the CN label.
	CmdMethod_Label CmdMethod = 8
	// SyncCommit when we turn on Push, some BVT tests use multiple Sessions in multi-CN scenarios. To
	// ensure data visibility, we need to synchronize CommitTS between multiple CNs so that the whole
	// cluster can see the latest writes from other CNs.
	CmdMethod_SyncCommit CmdMethod = 9
	// GetCommit get latest commit timestamp of cn.
	CmdMethod_GetCommit CmdMethod = 10
	// AddFaultPoint add a fault point
	CmdMethod_AddFaultPoint CmdMethod = 11
	// Backup backup data
	CmdMethod_Backup CmdMethod = 12
	// Enable or disable specified span
	CmdMethod_TraceSpan CmdMethod = 13
)

func (CmdMethod) EnumDescriptor 

func (CmdMethod) EnumDescriptor() ([]byte, []int)

func (CmdMethod) String 

func (x CmdMethod) String() string

type CtlResult 

type CtlResult struct {
	Method string      `json:"method"`
	Data   interface{} `json:"result"`
}

CtlResult ctl result

type GetCommitRequest added in v0.8.0 

type GetCommitRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetCommitRequest get commit timestamp request

func (*GetCommitRequest) Descriptor added in v0.8.0 

func (*GetCommitRequest) Descriptor() ([]byte, []int)

func (*GetCommitRequest) Marshal added in v0.8.0 

func (m *GetCommitRequest) Marshal() (dAtA []byte, err error)

func (*GetCommitRequest) MarshalTo added in v0.8.0 

func (m *GetCommitRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetCommitRequest) MarshalToSizedBuffer added in v0.8.0 

func (m *GetCommitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetCommitRequest) ProtoMessage added in v0.8.0 

func (*GetCommitRequest) ProtoMessage()

func (*GetCommitRequest) Reset added in v0.8.0 

func (m *GetCommitRequest) Reset()

func (*GetCommitRequest) Size added in v0.8.0 

func (m *GetCommitRequest) Size() (n int)

func (*GetCommitRequest) String added in v0.8.0 

func (m *GetCommitRequest) String() string

func (*GetCommitRequest) Unmarshal added in v0.8.0 

func (m *GetCommitRequest) Unmarshal(dAtA []byte) error

func (*GetCommitRequest) XXX_DiscardUnknown added in v0.8.0 

func (m *GetCommitRequest) XXX_DiscardUnknown()

func (*GetCommitRequest) XXX_Marshal added in v0.8.0 

func (m *GetCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCommitRequest) XXX_Merge added in v0.8.0 

func (m *GetCommitRequest) XXX_Merge(src proto.Message)

func (*GetCommitRequest) XXX_Size added in v0.8.0 

func (m *GetCommitRequest) XXX_Size() int

func (*GetCommitRequest) XXX_Unmarshal added in v0.8.0 

func (m *GetCommitRequest) XXX_Unmarshal(b []byte) error

type GetCommitResponse added in v0.8.0 

type GetCommitResponse struct {
	// CurrentCommitTS current commit timestamp after sync
	CurrentCommitTS      timestamp.Timestamp `protobuf:"bytes,1,opt,name=CurrentCommitTS,proto3" json:"CurrentCommitTS"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

GetCommitResponse get commit timestamp response

func (*GetCommitResponse) Descriptor added in v0.8.0 

func (*GetCommitResponse) Descriptor() ([]byte, []int)

func (*GetCommitResponse) GetCurrentCommitTS added in v0.8.0 

func (m *GetCommitResponse) GetCurrentCommitTS() timestamp.Timestamp

func (*GetCommitResponse) Marshal added in v0.8.0 

func (m *GetCommitResponse) Marshal() (dAtA []byte, err error)

func (*GetCommitResponse) MarshalTo added in v0.8.0 

func (m *GetCommitResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetCommitResponse) MarshalToSizedBuffer added in v0.8.0 

func (m *GetCommitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetCommitResponse) ProtoMessage added in v0.8.0 

func (*GetCommitResponse) ProtoMessage()

func (*GetCommitResponse) Reset added in v0.8.0 

func (m *GetCommitResponse) Reset()

func (*GetCommitResponse) Size added in v0.8.0 

func (m *GetCommitResponse) Size() (n int)

func (*GetCommitResponse) String added in v0.8.0 

func (m *GetCommitResponse) String() string

func (*GetCommitResponse) Unmarshal added in v0.8.0 

func (m *GetCommitResponse) Unmarshal(dAtA []byte) error

func (*GetCommitResponse) XXX_DiscardUnknown added in v0.8.0 

func (m *GetCommitResponse) XXX_DiscardUnknown()

func (*GetCommitResponse) XXX_Marshal added in v0.8.0 

func (m *GetCommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCommitResponse) XXX_Merge added in v0.8.0 

func (m *GetCommitResponse) XXX_Merge(src proto.Message)

func (*GetCommitResponse) XXX_Size added in v0.8.0 

func (m *GetCommitResponse) XXX_Size() int

func (*GetCommitResponse) XXX_Unmarshal added in v0.8.0 

func (m *GetCommitResponse) XXX_Unmarshal(b []byte) error

type Request added in v0.8.0 

type Request struct {
	// RequestID request id
	RequestID            uint64            `protobuf:"varint,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	CMDMethod            CmdMethod         `protobuf:"varint,2,opt,name=CMDMethod,proto3,enum=ctl.CmdMethod" json:"CMDMethod,omitempty"`
	SycnCommit           SyncCommitRequest `protobuf:"bytes,3,opt,name=SycnCommit,proto3" json:"SycnCommit"`
	GetCommit            SyncCommitRequest `protobuf:"bytes,4,opt,name=GetCommit,proto3" json:"GetCommit"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Request is used to send a request for a ctl service related operation to another ctl service.

func (*Request) DebugString added in v0.8.0 

func (m *Request) DebugString() string

DebugString returns the debug string

func (*Request) Descriptor added in v0.8.0 

func (*Request) Descriptor() ([]byte, []int)

func (*Request) GetCMDMethod added in v0.8.0 

func (m *Request) GetCMDMethod() CmdMethod

func (*Request) GetGetCommit added in v0.8.0 

func (m *Request) GetGetCommit() SyncCommitRequest

func (*Request) GetID added in v0.8.0 

func (m *Request) GetID() uint64

GetID implement morpc Messgae

func (*Request) GetRequestID added in v0.8.0 

func (m *Request) GetRequestID() uint64

func (*Request) GetSycnCommit added in v0.8.0 

func (m *Request) GetSycnCommit() SyncCommitRequest

func (*Request) Marshal added in v0.8.0 

func (m *Request) Marshal() (dAtA []byte, err error)

func (*Request) MarshalTo added in v0.8.0 

func (m *Request) MarshalTo(dAtA []byte) (int, error)

func (*Request) MarshalToSizedBuffer added in v0.8.0 

func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Request) Method added in v0.8.0 

func (m *Request) Method() uint32

func (*Request) ProtoMessage added in v0.8.0 

func (*Request) ProtoMessage()

func (*Request) Reset added in v0.8.0 

func (m *Request) Reset()

func (*Request) SetID added in v0.8.0 

func (m *Request) SetID(id uint64)

SetID implement morpc Messgae

func (*Request) SetMethod added in v0.8.0 

func (m *Request) SetMethod(v uint32)

func (*Request) Size added in v0.8.0 

func (m *Request) Size() (n int)

func (*Request) String added in v0.8.0 

func (m *Request) String() string

func (*Request) Unmarshal added in v0.8.0 

func (m *Request) Unmarshal(dAtA []byte) error

func (*Request) UnwrapError added in v0.8.0 

func (m *Request) UnwrapError() error

func (*Request) WrapError added in v0.8.0 

func (m *Request) WrapError(err error)

func (*Request) XXX_DiscardUnknown added in v0.8.0 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal added in v0.8.0 

func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Request) XXX_Merge added in v0.8.0 

func (m *Request) XXX_Merge(src proto.Message)

func (*Request) XXX_Size added in v0.8.0 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal added in v0.8.0 

func (m *Request) XXX_Unmarshal(b []byte) error

type Response added in v0.8.0 

type Response struct {
	// RequestID corresponding request id
	RequestID uint64    `protobuf:"varint,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	CMDMethod CmdMethod `protobuf:"varint,2,opt,name=CMDMethod,proto3,enum=ctl.CmdMethod" json:"CMDMethod,omitempty"`
	// Error we use this field to send moerr from service to another service. Set
	// with moerr.MarshalBinary, and use moerr.UnmarshalBinary to restore moerr.
	Error                []byte             `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	SycnCommit           SyncCommitResponse `protobuf:"bytes,4,opt,name=SycnCommit,proto3" json:"SycnCommit"`
	GetCommit            GetCommitResponse  `protobuf:"bytes,5,opt,name=GetCommit,proto3" json:"GetCommit"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Response ctl response

func (*Response) DebugString added in v0.8.0 

func (m *Response) DebugString() string

DebugString returns the debug string

func (*Response) Descriptor added in v0.8.0 

func (*Response) Descriptor() ([]byte, []int)

func (*Response) GetCMDMethod added in v0.8.0 

func (m *Response) GetCMDMethod() CmdMethod

func (*Response) GetError added in v0.8.0 

func (m *Response) GetError() []byte

func (*Response) GetGetCommit added in v0.8.0 

func (m *Response) GetGetCommit() GetCommitResponse

func (*Response) GetID added in v0.8.0 

func (m *Response) GetID() uint64

GetID implement morpc Messgae

func (*Response) GetRequestID added in v0.8.0 

func (m *Response) GetRequestID() uint64

func (*Response) GetSycnCommit added in v0.8.0 

func (m *Response) GetSycnCommit() SyncCommitResponse

func (*Response) Marshal added in v0.8.0 

func (m *Response) Marshal() (dAtA []byte, err error)

func (*Response) MarshalTo added in v0.8.0 

func (m *Response) MarshalTo(dAtA []byte) (int, error)

func (*Response) MarshalToSizedBuffer added in v0.8.0 

func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response) Method added in v0.8.0 

func (m *Response) Method() uint32

func (*Response) ProtoMessage added in v0.8.0 

func (*Response) ProtoMessage()

func (*Response) Reset added in v0.8.0 

func (m *Response) Reset()

func (*Response) SetID added in v0.8.0 

func (m *Response) SetID(id uint64)

SetID implement morpc Messgae

func (*Response) SetMethod added in v0.8.0 

func (m *Response) SetMethod(v uint32)

func (*Response) Size added in v0.8.0 

func (m *Response) Size() (n int)

func (*Response) String added in v0.8.0 

func (m *Response) String() string

func (*Response) Unmarshal added in v0.8.0 

func (m *Response) Unmarshal(dAtA []byte) error

func (*Response) UnwrapError added in v0.8.0 

func (m *Response) UnwrapError() error

UnwrapError unwrap the moerr from the error bytes

func (*Response) WrapError added in v0.8.0 

func (m *Response) WrapError(err error)

func (*Response) XXX_DiscardUnknown added in v0.8.0 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal added in v0.8.0 

func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Response) XXX_Merge added in v0.8.0 

func (m *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size added in v0.8.0 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal added in v0.8.0 

func (m *Response) XXX_Unmarshal(b []byte) error

type SyncCommitRequest added in v0.8.0 

type SyncCommitRequest struct {
	// LatestCommitTS update latest commit ts.
	LatestCommitTS       timestamp.Timestamp `protobuf:"bytes,1,opt,name=LatestCommitTS,proto3" json:"LatestCommitTS"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

SyncCommitRequest sync commit timestamp request

func (*SyncCommitRequest) Descriptor added in v0.8.0 

func (*SyncCommitRequest) Descriptor() ([]byte, []int)

func (*SyncCommitRequest) GetLatestCommitTS added in v0.8.0 

func (m *SyncCommitRequest) GetLatestCommitTS() timestamp.Timestamp

func (*SyncCommitRequest) Marshal added in v0.8.0 

func (m *SyncCommitRequest) Marshal() (dAtA []byte, err error)

func (*SyncCommitRequest) MarshalTo added in v0.8.0 

func (m *SyncCommitRequest) MarshalTo(dAtA []byte) (int, error)

func (*SyncCommitRequest) MarshalToSizedBuffer added in v0.8.0 

func (m *SyncCommitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncCommitRequest) ProtoMessage added in v0.8.0 

func (*SyncCommitRequest) ProtoMessage()

func (*SyncCommitRequest) Reset added in v0.8.0 

func (m *SyncCommitRequest) Reset()

func (*SyncCommitRequest) Size added in v0.8.0 

func (m *SyncCommitRequest) Size() (n int)

func (*SyncCommitRequest) String added in v0.8.0 

func (m *SyncCommitRequest) String() string

func (*SyncCommitRequest) Unmarshal added in v0.8.0 

func (m *SyncCommitRequest) Unmarshal(dAtA []byte) error

func (*SyncCommitRequest) XXX_DiscardUnknown added in v0.8.0 

func (m *SyncCommitRequest) XXX_DiscardUnknown()

func (*SyncCommitRequest) XXX_Marshal added in v0.8.0 

func (m *SyncCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncCommitRequest) XXX_Merge added in v0.8.0 

func (m *SyncCommitRequest) XXX_Merge(src proto.Message)

func (*SyncCommitRequest) XXX_Size added in v0.8.0 

func (m *SyncCommitRequest) XXX_Size() int

func (*SyncCommitRequest) XXX_Unmarshal added in v0.8.0 

func (m *SyncCommitRequest) XXX_Unmarshal(b []byte) error

type SyncCommitResponse added in v0.8.0 

type SyncCommitResponse struct {
	// CurrentCommitTS current commit timestamp after sync
	CurrentCommitTS      timestamp.Timestamp `protobuf:"bytes,1,opt,name=CurrentCommitTS,proto3" json:"CurrentCommitTS"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

SyncCommitResponse sync commit timestamp response

func (*SyncCommitResponse) Descriptor added in v0.8.0 

func (*SyncCommitResponse) Descriptor() ([]byte, []int)

func (*SyncCommitResponse) GetCurrentCommitTS added in v0.8.0 

func (m *SyncCommitResponse) GetCurrentCommitTS() timestamp.Timestamp

func (*SyncCommitResponse) Marshal added in v0.8.0 

func (m *SyncCommitResponse) Marshal() (dAtA []byte, err error)

func (*SyncCommitResponse) MarshalTo added in v0.8.0 

func (m *SyncCommitResponse) MarshalTo(dAtA []byte) (int, error)

func (*SyncCommitResponse) MarshalToSizedBuffer added in v0.8.0 

func (m *SyncCommitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncCommitResponse) ProtoMessage added in v0.8.0 

func (*SyncCommitResponse) ProtoMessage()

func (*SyncCommitResponse) Reset added in v0.8.0 

func (m *SyncCommitResponse) Reset()

func (*SyncCommitResponse) Size added in v0.8.0 

func (m *SyncCommitResponse) Size() (n int)

func (*SyncCommitResponse) String added in v0.8.0 

func (m *SyncCommitResponse) String() string

func (*SyncCommitResponse) Unmarshal added in v0.8.0 

func (m *SyncCommitResponse) Unmarshal(dAtA []byte) error

func (*SyncCommitResponse) XXX_DiscardUnknown added in v0.8.0 

func (m *SyncCommitResponse) XXX_DiscardUnknown()

func (*SyncCommitResponse) XXX_Marshal added in v0.8.0 

func (m *SyncCommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncCommitResponse) XXX_Merge added in v0.8.0 

func (m *SyncCommitResponse) XXX_Merge(src proto.Message)

func (*SyncCommitResponse) XXX_Size added in v0.8.0 

func (m *SyncCommitResponse) XXX_Size() int

func (*SyncCommitResponse) XXX_Unmarshal added in v0.8.0 

func (m *SyncCommitResponse) XXX_Unmarshal(b []byte) error

type TNPingRequest added in v1.0.0 

type TNPingRequest struct {
	Parameter            string   `protobuf:"bytes,1,opt,name=parameter,proto3" json:"parameter,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TNPingRequest ping request

func (*TNPingRequest) Descriptor added in v1.0.0 

func (*TNPingRequest) Descriptor() ([]byte, []int)

func (*TNPingRequest) GetParameter added in v1.0.0 

func (m *TNPingRequest) GetParameter() string

func (*TNPingRequest) Marshal added in v1.0.0 

func (m *TNPingRequest) Marshal() (dAtA []byte, err error)

func (*TNPingRequest) MarshalTo added in v1.0.0 

func (m *TNPingRequest) MarshalTo(dAtA []byte) (int, error)

func (*TNPingRequest) MarshalToSizedBuffer added in v1.0.0 

func (m *TNPingRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TNPingRequest) ProtoMessage added in v1.0.0 

func (*TNPingRequest) ProtoMessage()

func (*TNPingRequest) Reset added in v1.0.0 

func (m *TNPingRequest) Reset()

func (*TNPingRequest) Size added in v1.0.0 

func (m *TNPingRequest) Size() (n int)

func (*TNPingRequest) String added in v1.0.0 

func (m *TNPingRequest) String() string

func (*TNPingRequest) Unmarshal added in v1.0.0 

func (m *TNPingRequest) Unmarshal(dAtA []byte) error

func (*TNPingRequest) XXX_DiscardUnknown added in v1.0.0 

func (m *TNPingRequest) XXX_DiscardUnknown()

func (*TNPingRequest) XXX_Marshal added in v1.0.0 

func (m *TNPingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TNPingRequest) XXX_Merge added in v1.0.0 

func (m *TNPingRequest) XXX_Merge(src proto.Message)

func (*TNPingRequest) XXX_Size added in v1.0.0 

func (m *TNPingRequest) XXX_Size() int

func (*TNPingRequest) XXX_Unmarshal added in v1.0.0 

func (m *TNPingRequest) XXX_Unmarshal(b []byte) error

type TNPingResponse added in v1.0.0 

type TNPingResponse struct {
	StoreID              string   `protobuf:"bytes,1,opt,name=storeID,proto3" json:"storeID,omitempty"`
	ServiceAddress       string   `protobuf:"bytes,2,opt,name=serviceAddress,proto3" json:"serviceAddress,omitempty"`
	ShardID              uint64   `protobuf:"varint,3,opt,name=shardID,proto3" json:"shardID,omitempty"`
	ReplicaID            uint64   `protobuf:"varint,4,opt,name=replicaID,proto3" json:"replicaID,omitempty"`
	LogShardID           uint64   `protobuf:"varint,5,opt,name=logShardID,proto3" json:"logShardID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TNPingResponse ping response

func (*TNPingResponse) Descriptor added in v1.0.0 

func (*TNPingResponse) Descriptor() ([]byte, []int)

func (*TNPingResponse) GetLogShardID added in v1.0.0 

func (m *TNPingResponse) GetLogShardID() uint64

func (*TNPingResponse) GetReplicaID added in v1.0.0 

func (m *TNPingResponse) GetReplicaID() uint64

func (*TNPingResponse) GetServiceAddress added in v1.0.0 

func (m *TNPingResponse) GetServiceAddress() string

func (*TNPingResponse) GetShardID added in v1.0.0 

func (m *TNPingResponse) GetShardID() uint64

func (*TNPingResponse) GetStoreID added in v1.0.0 

func (m *TNPingResponse) GetStoreID() string

func (*TNPingResponse) Marshal added in v1.0.0 

func (m *TNPingResponse) Marshal() (dAtA []byte, err error)

func (*TNPingResponse) MarshalTo added in v1.0.0 

func (m *TNPingResponse) MarshalTo(dAtA []byte) (int, error)

func (*TNPingResponse) MarshalToSizedBuffer added in v1.0.0 

func (m *TNPingResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TNPingResponse) ProtoMessage added in v1.0.0 

func (*TNPingResponse) ProtoMessage()

func (*TNPingResponse) Reset added in v1.0.0 

func (m *TNPingResponse) Reset()

func (*TNPingResponse) Size added in v1.0.0 

func (m *TNPingResponse) Size() (n int)

func (*TNPingResponse) String added in v1.0.0 

func (m *TNPingResponse) String() string

func (*TNPingResponse) Unmarshal added in v1.0.0 

func (m *TNPingResponse) Unmarshal(dAtA []byte) error

func (*TNPingResponse) XXX_DiscardUnknown added in v1.0.0 

func (m *TNPingResponse) XXX_DiscardUnknown()

func (*TNPingResponse) XXX_Marshal added in v1.0.0 

func (m *TNPingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TNPingResponse) XXX_Merge added in v1.0.0 

func (m *TNPingResponse) XXX_Merge(src proto.Message)

func (*TNPingResponse) XXX_Size added in v1.0.0 

func (m *TNPingResponse) XXX_Size() int

func (*TNPingResponse) XXX_Unmarshal added in v1.0.0 

func (m *TNPingResponse) XXX_Unmarshal(b []byte) error

type TNStringResponse added in v1.0.0 

type TNStringResponse struct {
	ReturnStr            string   `protobuf:"bytes,1,opt,name=returnStr,proto3" json:"returnStr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TNStringResponse string type response

func (*TNStringResponse) Descriptor added in v1.0.0 

func (*TNStringResponse) Descriptor() ([]byte, []int)

func (*TNStringResponse) GetReturnStr added in v1.0.0 

func (m *TNStringResponse) GetReturnStr() string

func (*TNStringResponse) Marshal added in v1.0.0 

func (m *TNStringResponse) Marshal() (dAtA []byte, err error)

func (*TNStringResponse) MarshalTo added in v1.0.0 

func (m *TNStringResponse) MarshalTo(dAtA []byte) (int, error)

func (*TNStringResponse) MarshalToSizedBuffer added in v1.0.0 

func (m *TNStringResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TNStringResponse) ProtoMessage added in v1.0.0 

func (*TNStringResponse) ProtoMessage()

func (*TNStringResponse) Reset added in v1.0.0 

func (m *TNStringResponse) Reset()

func (*TNStringResponse) Size added in v1.0.0 

func (m *TNStringResponse) Size() (n int)

func (*TNStringResponse) String added in v1.0.0 

func (m *TNStringResponse) String() string

func (*TNStringResponse) Unmarshal added in v1.0.0 

func (m *TNStringResponse) Unmarshal(dAtA []byte) error

func (*TNStringResponse) XXX_DiscardUnknown added in v1.0.0 

func (m *TNStringResponse) XXX_DiscardUnknown()

func (*TNStringResponse) XXX_Marshal added in v1.0.0 

func (m *TNStringResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TNStringResponse) XXX_Merge added in v1.0.0 

func (m *TNStringResponse) XXX_Merge(src proto.Message)

func (*TNStringResponse) XXX_Size added in v1.0.0 

func (m *TNStringResponse) XXX_Size() int

func (*TNStringResponse) XXX_Unmarshal added in v1.0.0 

func (m *TNStringResponse) XXX_Unmarshal(b []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.