ctl

package
v0.6.0 Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2022 License: Apache-2.0 Imports: 6 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",
}
View Source 
var CmdMethod_value = map[string]int32{
	"Ping":  0,
	"Flush": 1,
	"Task":  2,
}

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
)

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 DNPingRequest 

type DNPingRequest 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:"-"`
}

DNPingRequest ping request

func (*DNPingRequest) Descriptor 

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

func (*DNPingRequest) GetParameter 

func (m *DNPingRequest) GetParameter() string

func (*DNPingRequest) Marshal 

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

func (*DNPingRequest) MarshalTo 

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

func (*DNPingRequest) MarshalToSizedBuffer 

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

func (*DNPingRequest) ProtoMessage 

func (*DNPingRequest) ProtoMessage()

func (*DNPingRequest) Reset 

func (m *DNPingRequest) Reset()

func (*DNPingRequest) Size 

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

func (*DNPingRequest) String 

func (m *DNPingRequest) String() string

func (*DNPingRequest) Unmarshal 

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

func (*DNPingRequest) XXX_DiscardUnknown 

func (m *DNPingRequest) XXX_DiscardUnknown()

func (*DNPingRequest) XXX_Marshal 

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

func (*DNPingRequest) XXX_Merge 

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

func (*DNPingRequest) XXX_Size 

func (m *DNPingRequest) XXX_Size() int

func (*DNPingRequest) XXX_Unmarshal 

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

type DNPingResponse 

type DNPingResponse 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:"-"`
}

DNPingResponse ping response

func (*DNPingResponse) Descriptor 

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

func (*DNPingResponse) GetLogShardID 

func (m *DNPingResponse) GetLogShardID() uint64

func (*DNPingResponse) GetReplicaID 

func (m *DNPingResponse) GetReplicaID() uint64

func (*DNPingResponse) GetServiceAddress 

func (m *DNPingResponse) GetServiceAddress() string

func (*DNPingResponse) GetShardID 

func (m *DNPingResponse) GetShardID() uint64

func (*DNPingResponse) GetStoreID 

func (m *DNPingResponse) GetStoreID() string

func (*DNPingResponse) Marshal 

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

func (*DNPingResponse) MarshalTo 

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

func (*DNPingResponse) MarshalToSizedBuffer 

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

func (*DNPingResponse) ProtoMessage 

func (*DNPingResponse) ProtoMessage()

func (*DNPingResponse) Reset 

func (m *DNPingResponse) Reset()

func (*DNPingResponse) Size 

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

func (*DNPingResponse) String 

func (m *DNPingResponse) String() string

func (*DNPingResponse) Unmarshal 

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

func (*DNPingResponse) XXX_DiscardUnknown 

func (m *DNPingResponse) XXX_DiscardUnknown()

func (*DNPingResponse) XXX_Marshal 

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

func (*DNPingResponse) XXX_Merge 

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

func (*DNPingResponse) XXX_Size 

func (m *DNPingResponse) XXX_Size() int

func (*DNPingResponse) XXX_Unmarshal 

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

type DNStringResponse 

type DNStringResponse 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:"-"`
}

DNStringResponse string type response

func (*DNStringResponse) Descriptor 

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

func (*DNStringResponse) GetReturnStr 

func (m *DNStringResponse) GetReturnStr() string

func (*DNStringResponse) Marshal 

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

func (*DNStringResponse) MarshalTo 

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

func (*DNStringResponse) MarshalToSizedBuffer 

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

func (*DNStringResponse) ProtoMessage 

func (*DNStringResponse) ProtoMessage()

func (*DNStringResponse) Reset 

func (m *DNStringResponse) Reset()

func (*DNStringResponse) Size 

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

func (*DNStringResponse) String 

func (m *DNStringResponse) String() string

func (*DNStringResponse) Unmarshal 

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

func (*DNStringResponse) XXX_DiscardUnknown 

func (m *DNStringResponse) XXX_DiscardUnknown()

func (*DNStringResponse) XXX_Marshal 

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

func (*DNStringResponse) XXX_Merge 

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

func (*DNStringResponse) XXX_Size 

func (m *DNStringResponse) XXX_Size() int

func (*DNStringResponse) XXX_Unmarshal 

func (m *DNStringResponse) 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.