Documentation ¶
Index ¶
- type CommandReply
- func (*CommandReply) Descriptor() ([]byte, []int)
- func (m *CommandReply) GetData() []byte
- func (m *CommandReply) GetOP() string
- func (*CommandReply) ProtoMessage()
- func (m *CommandReply) Reset()
- func (m *CommandReply) String() string
- func (m *CommandReply) XXX_DiscardUnknown()
- func (m *CommandReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CommandReply) XXX_Merge(src proto.Message)
- func (m *CommandReply) XXX_Size() int
- func (m *CommandReply) XXX_Unmarshal(b []byte) error
- type CommandRequest
- func (*CommandRequest) Descriptor() ([]byte, []int)
- func (m *CommandRequest) GetData() []byte
- func (m *CommandRequest) GetOP() string
- func (*CommandRequest) ProtoMessage()
- func (m *CommandRequest) Reset()
- func (m *CommandRequest) String() string
- func (m *CommandRequest) XXX_DiscardUnknown()
- func (m *CommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CommandRequest) XXX_Merge(src proto.Message)
- func (m *CommandRequest) XXX_Size() int
- func (m *CommandRequest) XXX_Unmarshal(b []byte) error
- type Empty
- func (*Empty) Descriptor() ([]byte, []int)
- func (*Empty) ProtoMessage()
- func (m *Empty) Reset()
- func (m *Empty) String() string
- func (m *Empty) XXX_DiscardUnknown()
- func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Empty) XXX_Merge(src proto.Message)
- func (m *Empty) XXX_Size() int
- func (m *Empty) XXX_Unmarshal(b []byte) error
- type EmptyReply
- func (*EmptyReply) Descriptor() ([]byte, []int)
- func (*EmptyReply) ProtoMessage()
- func (m *EmptyReply) Reset()
- func (m *EmptyReply) String() string
- func (m *EmptyReply) XXX_DiscardUnknown()
- func (m *EmptyReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EmptyReply) XXX_Merge(src proto.Message)
- func (m *EmptyReply) XXX_Size() int
- func (m *EmptyReply) XXX_Unmarshal(b []byte) error
- type EmptyRequest
- func (*EmptyRequest) Descriptor() ([]byte, []int)
- func (*EmptyRequest) ProtoMessage()
- func (m *EmptyRequest) Reset()
- func (m *EmptyRequest) String() string
- func (m *EmptyRequest) XXX_DiscardUnknown()
- func (m *EmptyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EmptyRequest) XXX_Merge(src proto.Message)
- func (m *EmptyRequest) XXX_Size() int
- func (m *EmptyRequest) XXX_Unmarshal(b []byte) error
- type GetServerTimeReply
- func (*GetServerTimeReply) Descriptor() ([]byte, []int)
- func (m *GetServerTimeReply) GetTime() int64
- func (*GetServerTimeReply) ProtoMessage()
- func (m *GetServerTimeReply) Reset()
- func (m *GetServerTimeReply) String() string
- func (m *GetServerTimeReply) XXX_DiscardUnknown()
- func (m *GetServerTimeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetServerTimeReply) XXX_Merge(src proto.Message)
- func (m *GetServerTimeReply) XXX_Size() int
- func (m *GetServerTimeReply) XXX_Unmarshal(b []byte) error
- type Job
- func (*Job) Descriptor() ([]byte, []int)
- func (m *Job) GetData() []byte
- func (m *Job) GetTargetID() string
- func (m *Job) GetType() string
- func (*Job) ProtoMessage()
- func (m *Job) Reset()
- func (m *Job) String() string
- func (m *Job) XXX_DiscardUnknown()
- func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Job) XXX_Merge(src proto.Message)
- func (m *Job) XXX_Size() int
- func (m *Job) XXX_Unmarshal(b []byte) error
- type Message
- func (*Message) Descriptor() ([]byte, []int)
- func (m *Message) GetContent() string
- func (m *Message) GetGroupID() string
- func (m *Message) GetID() string
- func (m *Message) GetSeqID() int32
- func (m *Message) GetType() int32
- func (*Message) ProtoMessage()
- func (m *Message) Reset()
- func (m *Message) String() string
- func (m *Message) XXX_DiscardUnknown()
- func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Message) XXX_Merge(src proto.Message)
- func (m *Message) XXX_Size() int
- func (m *Message) XXX_Unmarshal(b []byte) error
- type SendJobRequest
- func (*SendJobRequest) Descriptor() ([]byte, []int)
- func (m *SendJobRequest) GetJobs() []*Job
- func (*SendJobRequest) ProtoMessage()
- func (m *SendJobRequest) Reset()
- func (m *SendJobRequest) String() string
- func (m *SendJobRequest) XXX_DiscardUnknown()
- func (m *SendJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SendJobRequest) XXX_Merge(src proto.Message)
- func (m *SendJobRequest) XXX_Size() int
- func (m *SendJobRequest) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CommandReply ¶
type CommandReply struct { OP string `protobuf:"bytes,1,opt,name=OP,proto3" json:"OP,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=Data,proto3" json:"Data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CommandReply) Descriptor ¶
func (*CommandReply) Descriptor() ([]byte, []int)
func (*CommandReply) GetData ¶
func (m *CommandReply) GetData() []byte
func (*CommandReply) GetOP ¶
func (m *CommandReply) GetOP() string
func (*CommandReply) ProtoMessage ¶
func (*CommandReply) ProtoMessage()
func (*CommandReply) Reset ¶
func (m *CommandReply) Reset()
func (*CommandReply) String ¶
func (m *CommandReply) String() string
func (*CommandReply) XXX_DiscardUnknown ¶
func (m *CommandReply) XXX_DiscardUnknown()
func (*CommandReply) XXX_Marshal ¶
func (m *CommandReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommandReply) XXX_Merge ¶
func (m *CommandReply) XXX_Merge(src proto.Message)
func (*CommandReply) XXX_Size ¶
func (m *CommandReply) XXX_Size() int
func (*CommandReply) XXX_Unmarshal ¶
func (m *CommandReply) XXX_Unmarshal(b []byte) error
type CommandRequest ¶
type CommandRequest struct { OP string `protobuf:"bytes,1,opt,name=OP,proto3" json:"OP,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=Data,proto3" json:"Data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CommandRequest) Descriptor ¶
func (*CommandRequest) Descriptor() ([]byte, []int)
func (*CommandRequest) GetData ¶
func (m *CommandRequest) GetData() []byte
func (*CommandRequest) GetOP ¶
func (m *CommandRequest) GetOP() string
func (*CommandRequest) ProtoMessage ¶
func (*CommandRequest) ProtoMessage()
func (*CommandRequest) Reset ¶
func (m *CommandRequest) Reset()
func (*CommandRequest) String ¶
func (m *CommandRequest) String() string
func (*CommandRequest) XXX_DiscardUnknown ¶
func (m *CommandRequest) XXX_DiscardUnknown()
func (*CommandRequest) XXX_Marshal ¶
func (m *CommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommandRequest) XXX_Merge ¶
func (m *CommandRequest) XXX_Merge(src proto.Message)
func (*CommandRequest) XXX_Size ¶
func (m *CommandRequest) XXX_Size() int
func (*CommandRequest) XXX_Unmarshal ¶
func (m *CommandRequest) XXX_Unmarshal(b []byte) error
type Empty ¶
type Empty struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) XXX_DiscardUnknown ¶
func (m *Empty) XXX_DiscardUnknown()
func (*Empty) XXX_Marshal ¶
func (*Empty) XXX_Unmarshal ¶
type EmptyReply ¶
type EmptyReply struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EmptyReply) Descriptor ¶
func (*EmptyReply) Descriptor() ([]byte, []int)
func (*EmptyReply) ProtoMessage ¶
func (*EmptyReply) ProtoMessage()
func (*EmptyReply) Reset ¶
func (m *EmptyReply) Reset()
func (*EmptyReply) String ¶
func (m *EmptyReply) String() string
func (*EmptyReply) XXX_DiscardUnknown ¶
func (m *EmptyReply) XXX_DiscardUnknown()
func (*EmptyReply) XXX_Marshal ¶
func (m *EmptyReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EmptyReply) XXX_Merge ¶
func (m *EmptyReply) XXX_Merge(src proto.Message)
func (*EmptyReply) XXX_Size ¶
func (m *EmptyReply) XXX_Size() int
func (*EmptyReply) XXX_Unmarshal ¶
func (m *EmptyReply) XXX_Unmarshal(b []byte) error
type EmptyRequest ¶
type EmptyRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EmptyRequest) Descriptor ¶
func (*EmptyRequest) Descriptor() ([]byte, []int)
func (*EmptyRequest) ProtoMessage ¶
func (*EmptyRequest) ProtoMessage()
func (*EmptyRequest) Reset ¶
func (m *EmptyRequest) Reset()
func (*EmptyRequest) String ¶
func (m *EmptyRequest) String() string
func (*EmptyRequest) XXX_DiscardUnknown ¶
func (m *EmptyRequest) XXX_DiscardUnknown()
func (*EmptyRequest) XXX_Marshal ¶
func (m *EmptyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EmptyRequest) XXX_Merge ¶
func (m *EmptyRequest) XXX_Merge(src proto.Message)
func (*EmptyRequest) XXX_Size ¶
func (m *EmptyRequest) XXX_Size() int
func (*EmptyRequest) XXX_Unmarshal ¶
func (m *EmptyRequest) XXX_Unmarshal(b []byte) error
type GetServerTimeReply ¶
type GetServerTimeReply struct { Time int64 `protobuf:"varint,1,opt,name=Time,proto3" json:"Time,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetServerTimeReply) Descriptor ¶
func (*GetServerTimeReply) Descriptor() ([]byte, []int)
func (*GetServerTimeReply) GetTime ¶
func (m *GetServerTimeReply) GetTime() int64
func (*GetServerTimeReply) ProtoMessage ¶
func (*GetServerTimeReply) ProtoMessage()
func (*GetServerTimeReply) Reset ¶
func (m *GetServerTimeReply) Reset()
func (*GetServerTimeReply) String ¶
func (m *GetServerTimeReply) String() string
func (*GetServerTimeReply) XXX_DiscardUnknown ¶
func (m *GetServerTimeReply) XXX_DiscardUnknown()
func (*GetServerTimeReply) XXX_Marshal ¶
func (m *GetServerTimeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetServerTimeReply) XXX_Merge ¶
func (m *GetServerTimeReply) XXX_Merge(src proto.Message)
func (*GetServerTimeReply) XXX_Size ¶
func (m *GetServerTimeReply) XXX_Size() int
func (*GetServerTimeReply) XXX_Unmarshal ¶
func (m *GetServerTimeReply) XXX_Unmarshal(b []byte) error
type Job ¶
type Job struct { Type string `protobuf:"bytes,1,opt,name=Type,proto3" json:"Type,omitempty"` TargetID string `protobuf:"bytes,2,opt,name=TargetID,proto3" json:"TargetID,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Job) Descriptor ¶
func (*Job) GetTargetID ¶
func (*Job) ProtoMessage ¶
func (*Job) ProtoMessage()
func (*Job) XXX_DiscardUnknown ¶
func (m *Job) XXX_DiscardUnknown()
func (*Job) XXX_Unmarshal ¶
type Message ¶
type Message struct { ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` SeqID int32 `protobuf:"varint,2,opt,name=SeqID,proto3" json:"seq_id" db:"seq_id"` Type int32 `protobuf:"varint,3,opt,name=Type,proto3" json:"Type,omitempty"` GroupID string `protobuf:"bytes,4,opt,name=GroupID,proto3" json:"GroupID,omitempty"` Content string `protobuf:"bytes,5,opt,name=Content,proto3" json:"Content,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Message) Descriptor ¶
func (*Message) GetContent ¶
func (*Message) GetGroupID ¶
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) XXX_DiscardUnknown ¶
func (m *Message) XXX_DiscardUnknown()
func (*Message) XXX_Marshal ¶
func (*Message) XXX_Unmarshal ¶
type SendJobRequest ¶
type SendJobRequest struct { Jobs []*Job `protobuf:"bytes,1,rep,name=Jobs,proto3" json:"Jobs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SendJobRequest) Descriptor ¶
func (*SendJobRequest) Descriptor() ([]byte, []int)
func (*SendJobRequest) GetJobs ¶
func (m *SendJobRequest) GetJobs() []*Job
func (*SendJobRequest) ProtoMessage ¶
func (*SendJobRequest) ProtoMessage()
func (*SendJobRequest) Reset ¶
func (m *SendJobRequest) Reset()
func (*SendJobRequest) String ¶
func (m *SendJobRequest) String() string
func (*SendJobRequest) XXX_DiscardUnknown ¶
func (m *SendJobRequest) XXX_DiscardUnknown()
func (*SendJobRequest) XXX_Marshal ¶
func (m *SendJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SendJobRequest) XXX_Merge ¶
func (m *SendJobRequest) XXX_Merge(src proto.Message)
func (*SendJobRequest) XXX_Size ¶
func (m *SendJobRequest) XXX_Size() int
func (*SendJobRequest) XXX_Unmarshal ¶
func (m *SendJobRequest) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.