Documentation ¶
Index ¶
- Variables
- type BoolReply
- func (*BoolReply) Descriptor() ([]byte, []int)
- func (m *BoolReply) GetResult() bool
- func (m *BoolReply) Marshal() (dAtA []byte, err error)
- func (m *BoolReply) MarshalTo(dAtA []byte) (int, error)
- func (m *BoolReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*BoolReply) ProtoMessage()
- func (m *BoolReply) Reset()
- func (m *BoolReply) Size() (n int)
- func (m *BoolReply) String() string
- func (m *BoolReply) Unmarshal(dAtA []byte) error
- func (m *BoolReply) XXX_DiscardUnknown()
- func (m *BoolReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BoolReply) XXX_Merge(src proto.Message)
- func (m *BoolReply) XXX_Size() int
- func (m *BoolReply) XXX_Unmarshal(b []byte) error
- type BootReq
- func (*BootReq) Descriptor() ([]byte, []int)
- func (m *BootReq) Marshal() (dAtA []byte, err error)
- func (m *BootReq) MarshalTo(dAtA []byte) (int, error)
- func (m *BootReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*BootReq) ProtoMessage()
- func (m *BootReq) Reset()
- func (m *BootReq) Size() (n int)
- func (m *BootReq) String() string
- func (m *BootReq) Unmarshal(dAtA []byte) error
- func (m *BootReq) XXX_DiscardUnknown()
- func (m *BootReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BootReq) XXX_Merge(src proto.Message)
- func (m *BootReq) XXX_Size() int
- func (m *BootReq) XXX_Unmarshal(b []byte) error
- type BootResp
- func (*BootResp) Descriptor() ([]byte, []int)
- func (m *BootResp) Marshal() (dAtA []byte, err error)
- func (m *BootResp) MarshalTo(dAtA []byte) (int, error)
- func (m *BootResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*BootResp) ProtoMessage()
- func (m *BootResp) Reset()
- func (m *BootResp) Size() (n int)
- func (m *BootResp) String() string
- func (m *BootResp) Unmarshal(dAtA []byte) error
- func (m *BootResp) XXX_DiscardUnknown()
- func (m *BootResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BootResp) XXX_Merge(src proto.Message)
- func (m *BootResp) XXX_Size() int
- func (m *BootResp) XXX_Unmarshal(b []byte) error
- type CloseReq
- func (*CloseReq) Descriptor() ([]byte, []int)
- func (m *CloseReq) GetAddr() int64
- func (m *CloseReq) Marshal() (dAtA []byte, err error)
- func (m *CloseReq) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseReq) ProtoMessage()
- func (m *CloseReq) Reset()
- func (m *CloseReq) Size() (n int)
- func (m *CloseReq) String() string
- func (m *CloseReq) Unmarshal(dAtA []byte) error
- func (m *CloseReq) XXX_DiscardUnknown()
- func (m *CloseReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseReq) XXX_Merge(src proto.Message)
- func (m *CloseReq) XXX_Size() int
- func (m *CloseReq) XXX_Unmarshal(b []byte) error
- type CloseResp
- func (*CloseResp) Descriptor() ([]byte, []int)
- func (m *CloseResp) Marshal() (dAtA []byte, err error)
- func (m *CloseResp) MarshalTo(dAtA []byte) (int, error)
- func (m *CloseResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloseResp) ProtoMessage()
- func (m *CloseResp) Reset()
- func (m *CloseResp) Size() (n int)
- func (m *CloseResp) String() string
- func (m *CloseResp) Unmarshal(dAtA []byte) error
- func (m *CloseResp) XXX_DiscardUnknown()
- func (m *CloseResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloseResp) XXX_Merge(src proto.Message)
- func (m *CloseResp) XXX_Size() int
- func (m *CloseResp) XXX_Unmarshal(b []byte) error
- type Filtered
- func (*Filtered) Descriptor() ([]byte, []int)
- func (m *Filtered) GetField() string
- func (m *Filtered) GetOp() string
- func (m *Filtered) GetValue() string
- func (m *Filtered) GetValueType() string
- func (m *Filtered) Marshal() (dAtA []byte, err error)
- func (m *Filtered) MarshalTo(dAtA []byte) (int, error)
- func (m *Filtered) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Filtered) ProtoMessage()
- func (m *Filtered) Reset()
- func (m *Filtered) Size() (n int)
- func (m *Filtered) String() string
- func (m *Filtered) Unmarshal(dAtA []byte) error
- func (m *Filtered) XXX_DiscardUnknown()
- func (m *Filtered) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Filtered) XXX_Merge(src proto.Message)
- func (m *Filtered) XXX_Size() int
- func (m *Filtered) XXX_Unmarshal(b []byte) error
- type IdReply
- func (*IdReply) Descriptor() ([]byte, []int)
- func (m *IdReply) GetId() int64
- func (m *IdReply) Marshal() (dAtA []byte, err error)
- func (m *IdReply) MarshalTo(dAtA []byte) (int, error)
- func (m *IdReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IdReply) ProtoMessage()
- func (m *IdReply) Reset()
- func (m *IdReply) Size() (n int)
- func (m *IdReply) String() string
- func (m *IdReply) Unmarshal(dAtA []byte) error
- func (m *IdReply) XXX_DiscardUnknown()
- func (m *IdReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IdReply) XXX_Merge(src proto.Message)
- func (m *IdReply) XXX_Size() int
- func (m *IdReply) XXX_Unmarshal(b []byte) error
- type IdReq
- func (*IdReq) Descriptor() ([]byte, []int)
- func (m *IdReq) GetId() int64
- func (m *IdReq) Marshal() (dAtA []byte, err error)
- func (m *IdReq) MarshalTo(dAtA []byte) (int, error)
- func (m *IdReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IdReq) ProtoMessage()
- func (m *IdReq) Reset()
- func (m *IdReq) Size() (n int)
- func (m *IdReq) String() string
- func (m *IdReq) Unmarshal(dAtA []byte) error
- func (m *IdReq) XXX_DiscardUnknown()
- func (m *IdReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IdReq) XXX_Merge(src proto.Message)
- func (m *IdReq) XXX_Size() int
- func (m *IdReq) XXX_Unmarshal(b []byte) error
- type IdResp
- func (*IdResp) Descriptor() ([]byte, []int)
- func (m *IdResp) GetId() int64
- func (m *IdResp) Marshal() (dAtA []byte, err error)
- func (m *IdResp) MarshalTo(dAtA []byte) (int, error)
- func (m *IdResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IdResp) ProtoMessage()
- func (m *IdResp) Reset()
- func (m *IdResp) Size() (n int)
- func (m *IdResp) String() string
- func (m *IdResp) Unmarshal(dAtA []byte) error
- func (m *IdResp) XXX_DiscardUnknown()
- func (m *IdResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IdResp) XXX_Merge(src proto.Message)
- func (m *IdResp) XXX_Size() int
- func (m *IdResp) XXX_Unmarshal(b []byte) error
- type IdsReply
- func (*IdsReply) Descriptor() ([]byte, []int)
- func (m *IdsReply) GetIds() []int64
- func (m *IdsReply) Marshal() (dAtA []byte, err error)
- func (m *IdsReply) MarshalTo(dAtA []byte) (int, error)
- func (m *IdsReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IdsReply) ProtoMessage()
- func (m *IdsReply) Reset()
- func (m *IdsReply) Size() (n int)
- func (m *IdsReply) String() string
- func (m *IdsReply) Unmarshal(dAtA []byte) error
- func (m *IdsReply) XXX_DiscardUnknown()
- func (m *IdsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IdsReply) XXX_Merge(src proto.Message)
- func (m *IdsReply) XXX_Size() int
- func (m *IdsReply) XXX_Unmarshal(b []byte) error
- type IdsReq
- func (*IdsReq) Descriptor() ([]byte, []int)
- func (m *IdsReq) GetIds() []int64
- func (m *IdsReq) Marshal() (dAtA []byte, err error)
- func (m *IdsReq) MarshalTo(dAtA []byte) (int, error)
- func (m *IdsReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IdsReq) ProtoMessage()
- func (m *IdsReq) Reset()
- func (m *IdsReq) Size() (n int)
- func (m *IdsReq) String() string
- func (m *IdsReq) Unmarshal(dAtA []byte) error
- func (m *IdsReq) XXX_DiscardUnknown()
- func (m *IdsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IdsReq) XXX_Merge(src proto.Message)
- func (m *IdsReq) XXX_Size() int
- func (m *IdsReq) XXX_Unmarshal(b []byte) error
- type ListReply
- func (*ListReply) Descriptor() ([]byte, []int)
- func (m *ListReply) GetPageNumber() int64
- func (m *ListReply) GetPageSize() int64
- func (m *ListReply) GetTotalPages() int64
- func (m *ListReply) GetTotalRecords() int64
- func (m *ListReply) Marshal() (dAtA []byte, err error)
- func (m *ListReply) MarshalTo(dAtA []byte) (int, error)
- func (m *ListReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListReply) ProtoMessage()
- func (m *ListReply) Reset()
- func (m *ListReply) Size() (n int)
- func (m *ListReply) String() string
- func (m *ListReply) Unmarshal(dAtA []byte) error
- func (m *ListReply) XXX_DiscardUnknown()
- func (m *ListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListReply) XXX_Merge(src proto.Message)
- func (m *ListReply) XXX_Size() int
- func (m *ListReply) XXX_Unmarshal(b []byte) error
- type OpenReq
- func (*OpenReq) Descriptor() ([]byte, []int)
- func (m *OpenReq) GetAddr() int64
- func (m *OpenReq) GetToken() string
- func (m *OpenReq) Marshal() (dAtA []byte, err error)
- func (m *OpenReq) MarshalTo(dAtA []byte) (int, error)
- func (m *OpenReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OpenReq) ProtoMessage()
- func (m *OpenReq) Reset()
- func (m *OpenReq) Size() (n int)
- func (m *OpenReq) String() string
- func (m *OpenReq) Unmarshal(dAtA []byte) error
- func (m *OpenReq) XXX_DiscardUnknown()
- func (m *OpenReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenReq) XXX_Merge(src proto.Message)
- func (m *OpenReq) XXX_Size() int
- func (m *OpenReq) XXX_Unmarshal(b []byte) error
- type OpenResp
- func (*OpenResp) Descriptor() ([]byte, []int)
- func (m *OpenResp) Marshal() (dAtA []byte, err error)
- func (m *OpenResp) MarshalTo(dAtA []byte) (int, error)
- func (m *OpenResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OpenResp) ProtoMessage()
- func (m *OpenResp) Reset()
- func (m *OpenResp) Size() (n int)
- func (m *OpenResp) String() string
- func (m *OpenResp) Unmarshal(dAtA []byte) error
- func (m *OpenResp) XXX_DiscardUnknown()
- func (m *OpenResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpenResp) XXX_Merge(src proto.Message)
- func (m *OpenResp) XXX_Size() int
- func (m *OpenResp) XXX_Unmarshal(b []byte) error
- type QueryReq
- func (*QueryReq) Descriptor() ([]byte, []int)
- func (m *QueryReq) GetFiltered() []*Filtered
- func (m *QueryReq) GetPage() int64
- func (m *QueryReq) GetPageSize() int64
- func (m *QueryReq) GetSorted() []*Sorted
- func (m *QueryReq) Marshal() (dAtA []byte, err error)
- func (m *QueryReq) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryReq) ProtoMessage()
- func (m *QueryReq) Reset()
- func (m *QueryReq) Size() (n int)
- func (m *QueryReq) String() string
- func (m *QueryReq) Unmarshal(dAtA []byte) error
- func (m *QueryReq) XXX_DiscardUnknown()
- func (m *QueryReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryReq) XXX_Merge(src proto.Message)
- func (m *QueryReq) XXX_Size() int
- func (m *QueryReq) XXX_Unmarshal(b []byte) error
- type Reply
- func (*Reply) Descriptor() ([]byte, []int)
- func (m *Reply) GetMessage() string
- func (m *Reply) GetStatus() int32
- func (m *Reply) Marshal() (dAtA []byte, err error)
- func (m *Reply) MarshalTo(dAtA []byte) (int, error)
- func (m *Reply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Reply) ProtoMessage()
- func (m *Reply) Reset()
- func (m *Reply) Size() (n int)
- func (m *Reply) String() string
- func (m *Reply) Unmarshal(dAtA []byte) error
- func (m *Reply) XXX_DiscardUnknown()
- func (m *Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Reply) XXX_Merge(src proto.Message)
- func (m *Reply) XXX_Size() int
- func (m *Reply) XXX_Unmarshal(b []byte) error
- type ShutdownReq
- func (*ShutdownReq) Descriptor() ([]byte, []int)
- func (m *ShutdownReq) Marshal() (dAtA []byte, err error)
- func (m *ShutdownReq) MarshalTo(dAtA []byte) (int, error)
- func (m *ShutdownReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ShutdownReq) ProtoMessage()
- func (m *ShutdownReq) Reset()
- func (m *ShutdownReq) Size() (n int)
- func (m *ShutdownReq) String() string
- func (m *ShutdownReq) Unmarshal(dAtA []byte) error
- func (m *ShutdownReq) XXX_DiscardUnknown()
- func (m *ShutdownReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShutdownReq) XXX_Merge(src proto.Message)
- func (m *ShutdownReq) XXX_Size() int
- func (m *ShutdownReq) XXX_Unmarshal(b []byte) error
- type ShutdownResp
- func (*ShutdownResp) Descriptor() ([]byte, []int)
- func (m *ShutdownResp) Marshal() (dAtA []byte, err error)
- func (m *ShutdownResp) MarshalTo(dAtA []byte) (int, error)
- func (m *ShutdownResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ShutdownResp) ProtoMessage()
- func (m *ShutdownResp) Reset()
- func (m *ShutdownResp) Size() (n int)
- func (m *ShutdownResp) String() string
- func (m *ShutdownResp) Unmarshal(dAtA []byte) error
- func (m *ShutdownResp) XXX_DiscardUnknown()
- func (m *ShutdownResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShutdownResp) XXX_Merge(src proto.Message)
- func (m *ShutdownResp) XXX_Size() int
- func (m *ShutdownResp) XXX_Unmarshal(b []byte) error
- type Sorted
- func (*Sorted) Descriptor() ([]byte, []int)
- func (m *Sorted) GetDesc() bool
- func (m *Sorted) GetId() string
- func (m *Sorted) Marshal() (dAtA []byte, err error)
- func (m *Sorted) MarshalTo(dAtA []byte) (int, error)
- func (m *Sorted) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Sorted) ProtoMessage()
- func (m *Sorted) Reset()
- func (m *Sorted) Size() (n int)
- func (m *Sorted) String() string
- func (m *Sorted) Unmarshal(dAtA []byte) error
- func (m *Sorted) XXX_DiscardUnknown()
- func (m *Sorted) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Sorted) XXX_Merge(src proto.Message)
- func (m *Sorted) XXX_Size() int
- func (m *Sorted) XXX_Unmarshal(b []byte) error
- type StrIdReq
- func (*StrIdReq) Descriptor() ([]byte, []int)
- func (m *StrIdReq) GetId() string
- func (m *StrIdReq) Marshal() (dAtA []byte, err error)
- func (m *StrIdReq) MarshalTo(dAtA []byte) (int, error)
- func (m *StrIdReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StrIdReq) ProtoMessage()
- func (m *StrIdReq) Reset()
- func (m *StrIdReq) Size() (n int)
- func (m *StrIdReq) String() string
- func (m *StrIdReq) Unmarshal(dAtA []byte) error
- func (m *StrIdReq) XXX_DiscardUnknown()
- func (m *StrIdReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StrIdReq) XXX_Merge(src proto.Message)
- func (m *StrIdReq) XXX_Size() int
- func (m *StrIdReq) XXX_Unmarshal(b []byte) error
- type StrIdsReq
- func (*StrIdsReq) Descriptor() ([]byte, []int)
- func (m *StrIdsReq) GetIds() []string
- func (m *StrIdsReq) Marshal() (dAtA []byte, err error)
- func (m *StrIdsReq) MarshalTo(dAtA []byte) (int, error)
- func (m *StrIdsReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StrIdsReq) ProtoMessage()
- func (m *StrIdsReq) Reset()
- func (m *StrIdsReq) Size() (n int)
- func (m *StrIdsReq) String() string
- func (m *StrIdsReq) Unmarshal(dAtA []byte) error
- func (m *StrIdsReq) XXX_DiscardUnknown()
- func (m *StrIdsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StrIdsReq) XXX_Merge(src proto.Message)
- func (m *StrIdsReq) XXX_Size() int
- func (m *StrIdsReq) XXX_Unmarshal(b []byte) error
- type TickReq
- func (*TickReq) Descriptor() ([]byte, []int)
- func (m *TickReq) Marshal() (dAtA []byte, err error)
- func (m *TickReq) MarshalTo(dAtA []byte) (int, error)
- func (m *TickReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TickReq) ProtoMessage()
- func (m *TickReq) Reset()
- func (m *TickReq) Size() (n int)
- func (m *TickReq) String() string
- func (m *TickReq) Unmarshal(dAtA []byte) error
- func (m *TickReq) XXX_DiscardUnknown()
- func (m *TickReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TickReq) XXX_Merge(src proto.Message)
- func (m *TickReq) XXX_Size() int
- func (m *TickReq) XXX_Unmarshal(b []byte) error
- type TickResp
- func (*TickResp) Descriptor() ([]byte, []int)
- func (m *TickResp) Marshal() (dAtA []byte, err error)
- func (m *TickResp) MarshalTo(dAtA []byte) (int, error)
- func (m *TickResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TickResp) ProtoMessage()
- func (m *TickResp) Reset()
- func (m *TickResp) Size() (n int)
- func (m *TickResp) String() string
- func (m *TickResp) Unmarshal(dAtA []byte) error
- func (m *TickResp) XXX_DiscardUnknown()
- func (m *TickResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TickResp) XXX_Merge(src proto.Message)
- func (m *TickResp) XXX_Size() int
- func (m *TickResp) XXX_Unmarshal(b []byte) error
- type TrafficBroadcastMsg
- func (*TrafficBroadcastMsg) Descriptor() ([]byte, []int)
- func (m *TrafficBroadcastMsg) GetBroadcastMsg() string
- func (m *TrafficBroadcastMsg) GetRemoteAddr() []string
- func (m *TrafficBroadcastMsg) Marshal() (dAtA []byte, err error)
- func (m *TrafficBroadcastMsg) MarshalTo(dAtA []byte) (int, error)
- func (m *TrafficBroadcastMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TrafficBroadcastMsg) ProtoMessage()
- func (m *TrafficBroadcastMsg) Reset()
- func (m *TrafficBroadcastMsg) Size() (n int)
- func (m *TrafficBroadcastMsg) String() string
- func (m *TrafficBroadcastMsg) Unmarshal(dAtA []byte) error
- func (m *TrafficBroadcastMsg) XXX_DiscardUnknown()
- func (m *TrafficBroadcastMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TrafficBroadcastMsg) XXX_Merge(src proto.Message)
- func (m *TrafficBroadcastMsg) XXX_Size() int
- func (m *TrafficBroadcastMsg) XXX_Unmarshal(b []byte) error
- type TrafficReq
- func (*TrafficReq) Descriptor() ([]byte, []int)
- func (m *TrafficReq) GetAction() string
- func (m *TrafficReq) GetAddr() int64
- func (m *TrafficReq) GetReqMsg() string
- func (m *TrafficReq) Marshal() (dAtA []byte, err error)
- func (m *TrafficReq) MarshalTo(dAtA []byte) (int, error)
- func (m *TrafficReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TrafficReq) ProtoMessage()
- func (m *TrafficReq) Reset()
- func (m *TrafficReq) Size() (n int)
- func (m *TrafficReq) String() string
- func (m *TrafficReq) Unmarshal(dAtA []byte) error
- func (m *TrafficReq) XXX_DiscardUnknown()
- func (m *TrafficReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TrafficReq) XXX_Merge(src proto.Message)
- func (m *TrafficReq) XXX_Size() int
- func (m *TrafficReq) XXX_Unmarshal(b []byte) error
- type TrafficResp
- func (*TrafficResp) Descriptor() ([]byte, []int)
- func (m *TrafficResp) GetBroadcastMsg() []*TrafficBroadcastMsg
- func (m *TrafficResp) GetRespMsg() string
- func (m *TrafficResp) Marshal() (dAtA []byte, err error)
- func (m *TrafficResp) MarshalTo(dAtA []byte) (int, error)
- func (m *TrafficResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TrafficResp) ProtoMessage()
- func (m *TrafficResp) Reset()
- func (m *TrafficResp) Size() (n int)
- func (m *TrafficResp) String() string
- func (m *TrafficResp) Unmarshal(dAtA []byte) error
- func (m *TrafficResp) XXX_DiscardUnknown()
- func (m *TrafficResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TrafficResp) XXX_Merge(src proto.Message)
- func (m *TrafficResp) XXX_Size() int
- func (m *TrafficResp) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type BoolReply ¶
type BoolReply struct {
Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
}
func (*BoolReply) Descriptor ¶
func (*BoolReply) MarshalToSizedBuffer ¶
func (*BoolReply) ProtoMessage ¶
func (*BoolReply) ProtoMessage()
func (*BoolReply) XXX_DiscardUnknown ¶
func (m *BoolReply) XXX_DiscardUnknown()
func (*BoolReply) XXX_Marshal ¶
func (*BoolReply) XXX_Unmarshal ¶
type BootReq ¶
type BootReq struct { }
func (*BootReq) Descriptor ¶
func (*BootReq) MarshalToSizedBuffer ¶
func (*BootReq) ProtoMessage ¶
func (*BootReq) ProtoMessage()
func (*BootReq) XXX_DiscardUnknown ¶
func (m *BootReq) XXX_DiscardUnknown()
func (*BootReq) XXX_Marshal ¶
func (*BootReq) XXX_Unmarshal ¶
type BootResp ¶
type BootResp struct { }
func (*BootResp) Descriptor ¶
func (*BootResp) MarshalToSizedBuffer ¶
func (*BootResp) ProtoMessage ¶
func (*BootResp) ProtoMessage()
func (*BootResp) XXX_DiscardUnknown ¶
func (m *BootResp) XXX_DiscardUnknown()
func (*BootResp) XXX_Marshal ¶
func (*BootResp) XXX_Unmarshal ¶
type CloseReq ¶
type CloseReq struct { // 客户端连接地址 Addr int64 `protobuf:"varint,1,opt,name=addr,proto3" json:"addr,omitempty"` }
func (*CloseReq) Descriptor ¶
func (*CloseReq) MarshalToSizedBuffer ¶
func (*CloseReq) ProtoMessage ¶
func (*CloseReq) ProtoMessage()
func (*CloseReq) XXX_DiscardUnknown ¶
func (m *CloseReq) XXX_DiscardUnknown()
func (*CloseReq) XXX_Marshal ¶
func (*CloseReq) XXX_Unmarshal ¶
type CloseResp ¶
type CloseResp struct { }
func (*CloseResp) Descriptor ¶
func (*CloseResp) MarshalToSizedBuffer ¶
func (*CloseResp) ProtoMessage ¶
func (*CloseResp) ProtoMessage()
func (*CloseResp) XXX_DiscardUnknown ¶
func (m *CloseResp) XXX_DiscardUnknown()
func (*CloseResp) XXX_Marshal ¶
func (*CloseResp) XXX_Unmarshal ¶
type Filtered ¶
type Filtered struct { Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"` Op string `protobuf:"bytes,2,opt,name=op,proto3" json:"op,omitempty"` Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` ValueType string `protobuf:"bytes,4,opt,name=valueType,proto3" json:"valueType,omitempty"` }
func (*Filtered) Descriptor ¶
func (*Filtered) GetValueType ¶
func (*Filtered) MarshalToSizedBuffer ¶
func (*Filtered) ProtoMessage ¶
func (*Filtered) ProtoMessage()
func (*Filtered) XXX_DiscardUnknown ¶
func (m *Filtered) XXX_DiscardUnknown()
func (*Filtered) XXX_Marshal ¶
func (*Filtered) XXX_Unmarshal ¶
type IdReply ¶
type IdReply struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id"`
}
func (*IdReply) Descriptor ¶
func (*IdReply) MarshalToSizedBuffer ¶
func (*IdReply) ProtoMessage ¶
func (*IdReply) ProtoMessage()
func (*IdReply) XXX_DiscardUnknown ¶
func (m *IdReply) XXX_DiscardUnknown()
func (*IdReply) XXX_Marshal ¶
func (*IdReply) XXX_Unmarshal ¶
type IdReq ¶
type IdReq struct { //主键id Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id" validate:"required"` }
func (*IdReq) Descriptor ¶
func (*IdReq) ProtoMessage ¶
func (*IdReq) ProtoMessage()
func (*IdReq) XXX_DiscardUnknown ¶
func (m *IdReq) XXX_DiscardUnknown()
func (*IdReq) XXX_Marshal ¶
func (*IdReq) XXX_Unmarshal ¶
type IdResp ¶
type IdResp struct { //主键id Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id" validate:"required"` }
func (*IdResp) Descriptor ¶
func (*IdResp) MarshalToSizedBuffer ¶
func (*IdResp) ProtoMessage ¶
func (*IdResp) ProtoMessage()
func (*IdResp) XXX_DiscardUnknown ¶
func (m *IdResp) XXX_DiscardUnknown()
func (*IdResp) XXX_Marshal ¶
func (*IdResp) XXX_Unmarshal ¶
type IdsReply ¶
type IdsReply struct {
Ids []int64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids"`
}
func (*IdsReply) Descriptor ¶
func (*IdsReply) MarshalToSizedBuffer ¶
func (*IdsReply) ProtoMessage ¶
func (*IdsReply) ProtoMessage()
func (*IdsReply) XXX_DiscardUnknown ¶
func (m *IdsReply) XXX_DiscardUnknown()
func (*IdsReply) XXX_Marshal ¶
func (*IdsReply) XXX_Unmarshal ¶
type IdsReq ¶
type IdsReq struct {
Ids []int64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids" validate:"required"`
}
func (*IdsReq) Descriptor ¶
func (*IdsReq) MarshalToSizedBuffer ¶
func (*IdsReq) ProtoMessage ¶
func (*IdsReq) ProtoMessage()
func (*IdsReq) XXX_DiscardUnknown ¶
func (m *IdsReq) XXX_DiscardUnknown()
func (*IdsReq) XXX_Marshal ¶
func (*IdsReq) XXX_Unmarshal ¶
type ListReply ¶
type ListReply struct { TotalPages int64 `protobuf:"varint,1,opt,name=totalPages,proto3" json:"totalPages"` TotalRecords int64 `protobuf:"varint,2,opt,name=totalRecords,proto3" json:"totalRecords"` PageSize int64 `protobuf:"varint,3,opt,name=pageSize,proto3" json:"pageSize"` PageNumber int64 `protobuf:"varint,4,opt,name=pageNumber,proto3" json:"pageNumber"` }
func (*ListReply) Descriptor ¶
func (*ListReply) GetPageNumber ¶
func (*ListReply) GetPageSize ¶
func (*ListReply) GetTotalPages ¶
func (*ListReply) GetTotalRecords ¶
func (*ListReply) MarshalToSizedBuffer ¶
func (*ListReply) ProtoMessage ¶
func (*ListReply) ProtoMessage()
func (*ListReply) XXX_DiscardUnknown ¶
func (m *ListReply) XXX_DiscardUnknown()
func (*ListReply) XXX_Marshal ¶
func (*ListReply) XXX_Unmarshal ¶
type OpenReq ¶
type OpenReq struct { // 客户端连接地址 Addr int64 `protobuf:"varint,1,opt,name=addr,proto3" json:"addr,omitempty"` // 用户登录token Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"` }
func (*OpenReq) Descriptor ¶
func (*OpenReq) MarshalToSizedBuffer ¶
func (*OpenReq) ProtoMessage ¶
func (*OpenReq) ProtoMessage()
func (*OpenReq) XXX_DiscardUnknown ¶
func (m *OpenReq) XXX_DiscardUnknown()
func (*OpenReq) XXX_Marshal ¶
func (*OpenReq) XXX_Unmarshal ¶
type OpenResp ¶
type OpenResp struct { }
func (*OpenResp) Descriptor ¶
func (*OpenResp) MarshalToSizedBuffer ¶
func (*OpenResp) ProtoMessage ¶
func (*OpenResp) ProtoMessage()
func (*OpenResp) XXX_DiscardUnknown ¶
func (m *OpenResp) XXX_DiscardUnknown()
func (*OpenResp) XXX_Marshal ¶
func (*OpenResp) XXX_Unmarshal ¶
type QueryReq ¶
type QueryReq struct { Page int64 `protobuf:"varint,1,opt,name=page,proto3" json:"page"` PageSize int64 `protobuf:"varint,2,opt,name=pageSize,proto3" json:"pageSize"` Sorted []*Sorted `protobuf:"bytes,3,rep,name=sorted,proto3" json:"sorted"` Filtered []*Filtered `protobuf:"bytes,4,rep,name=filtered,proto3" json:"filtered"` }
func (*QueryReq) Descriptor ¶
func (*QueryReq) GetFiltered ¶
func (*QueryReq) GetPageSize ¶
func (*QueryReq) MarshalToSizedBuffer ¶
func (*QueryReq) ProtoMessage ¶
func (*QueryReq) ProtoMessage()
func (*QueryReq) XXX_DiscardUnknown ¶
func (m *QueryReq) XXX_DiscardUnknown()
func (*QueryReq) XXX_Marshal ¶
func (*QueryReq) XXX_Unmarshal ¶
type Reply ¶
type Reply struct { //返回状态码,0表示失败 Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status"` //返回信息描述 Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message"` }
func (*Reply) Descriptor ¶
func (*Reply) GetMessage ¶
func (*Reply) ProtoMessage ¶
func (*Reply) ProtoMessage()
func (*Reply) XXX_DiscardUnknown ¶
func (m *Reply) XXX_DiscardUnknown()
func (*Reply) XXX_Marshal ¶
func (*Reply) XXX_Unmarshal ¶
type ShutdownReq ¶
type ShutdownReq struct { }
func (*ShutdownReq) Descriptor ¶
func (*ShutdownReq) Descriptor() ([]byte, []int)
func (*ShutdownReq) Marshal ¶
func (m *ShutdownReq) Marshal() (dAtA []byte, err error)
func (*ShutdownReq) MarshalToSizedBuffer ¶
func (m *ShutdownReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ShutdownReq) ProtoMessage ¶
func (*ShutdownReq) ProtoMessage()
func (*ShutdownReq) Reset ¶
func (m *ShutdownReq) Reset()
func (*ShutdownReq) Size ¶
func (m *ShutdownReq) Size() (n int)
func (*ShutdownReq) String ¶
func (m *ShutdownReq) String() string
func (*ShutdownReq) Unmarshal ¶
func (m *ShutdownReq) Unmarshal(dAtA []byte) error
func (*ShutdownReq) XXX_DiscardUnknown ¶
func (m *ShutdownReq) XXX_DiscardUnknown()
func (*ShutdownReq) XXX_Marshal ¶
func (m *ShutdownReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShutdownReq) XXX_Merge ¶
func (m *ShutdownReq) XXX_Merge(src proto.Message)
func (*ShutdownReq) XXX_Size ¶
func (m *ShutdownReq) XXX_Size() int
func (*ShutdownReq) XXX_Unmarshal ¶
func (m *ShutdownReq) XXX_Unmarshal(b []byte) error
type ShutdownResp ¶
type ShutdownResp struct { }
func (*ShutdownResp) Descriptor ¶
func (*ShutdownResp) Descriptor() ([]byte, []int)
func (*ShutdownResp) Marshal ¶
func (m *ShutdownResp) Marshal() (dAtA []byte, err error)
func (*ShutdownResp) MarshalToSizedBuffer ¶
func (m *ShutdownResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ShutdownResp) ProtoMessage ¶
func (*ShutdownResp) ProtoMessage()
func (*ShutdownResp) Reset ¶
func (m *ShutdownResp) Reset()
func (*ShutdownResp) Size ¶
func (m *ShutdownResp) Size() (n int)
func (*ShutdownResp) String ¶
func (m *ShutdownResp) String() string
func (*ShutdownResp) Unmarshal ¶
func (m *ShutdownResp) Unmarshal(dAtA []byte) error
func (*ShutdownResp) XXX_DiscardUnknown ¶
func (m *ShutdownResp) XXX_DiscardUnknown()
func (*ShutdownResp) XXX_Marshal ¶
func (m *ShutdownResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShutdownResp) XXX_Merge ¶
func (m *ShutdownResp) XXX_Merge(src proto.Message)
func (*ShutdownResp) XXX_Size ¶
func (m *ShutdownResp) XXX_Size() int
func (*ShutdownResp) XXX_Unmarshal ¶
func (m *ShutdownResp) XXX_Unmarshal(b []byte) error
type Sorted ¶
type Sorted struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Desc bool `protobuf:"varint,2,opt,name=desc,proto3" json:"desc,omitempty"` }
func (*Sorted) Descriptor ¶
func (*Sorted) MarshalToSizedBuffer ¶
func (*Sorted) ProtoMessage ¶
func (*Sorted) ProtoMessage()
func (*Sorted) XXX_DiscardUnknown ¶
func (m *Sorted) XXX_DiscardUnknown()
func (*Sorted) XXX_Marshal ¶
func (*Sorted) XXX_Unmarshal ¶
type StrIdReq ¶
type StrIdReq struct { // 主键id Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id" validate:"required"` }
func (*StrIdReq) Descriptor ¶
func (*StrIdReq) MarshalToSizedBuffer ¶
func (*StrIdReq) ProtoMessage ¶
func (*StrIdReq) ProtoMessage()
func (*StrIdReq) XXX_DiscardUnknown ¶
func (m *StrIdReq) XXX_DiscardUnknown()
func (*StrIdReq) XXX_Marshal ¶
func (*StrIdReq) XXX_Unmarshal ¶
type StrIdsReq ¶
type StrIdsReq struct {
Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids" validate:"required"`
}
func (*StrIdsReq) Descriptor ¶
func (*StrIdsReq) MarshalToSizedBuffer ¶
func (*StrIdsReq) ProtoMessage ¶
func (*StrIdsReq) ProtoMessage()
func (*StrIdsReq) XXX_DiscardUnknown ¶
func (m *StrIdsReq) XXX_DiscardUnknown()
func (*StrIdsReq) XXX_Marshal ¶
func (*StrIdsReq) XXX_Unmarshal ¶
type TickReq ¶
type TickReq struct { }
func (*TickReq) Descriptor ¶
func (*TickReq) MarshalToSizedBuffer ¶
func (*TickReq) ProtoMessage ¶
func (*TickReq) ProtoMessage()
func (*TickReq) XXX_DiscardUnknown ¶
func (m *TickReq) XXX_DiscardUnknown()
func (*TickReq) XXX_Marshal ¶
func (*TickReq) XXX_Unmarshal ¶
type TickResp ¶
type TickResp struct { }
func (*TickResp) Descriptor ¶
func (*TickResp) MarshalToSizedBuffer ¶
func (*TickResp) ProtoMessage ¶
func (*TickResp) ProtoMessage()
func (*TickResp) XXX_DiscardUnknown ¶
func (m *TickResp) XXX_DiscardUnknown()
func (*TickResp) XXX_Marshal ¶
func (*TickResp) XXX_Unmarshal ¶
type TrafficBroadcastMsg ¶
type TrafficBroadcastMsg struct { // 广播地址 RemoteAddr []string `protobuf:"bytes,1,rep,name=remoteAddr,proto3" json:"remoteAddr,omitempty"` // 广播消息 BroadcastMsg string `protobuf:"bytes,2,opt,name=broadcastMsg,proto3" json:"broadcastMsg,omitempty"` }
func (*TrafficBroadcastMsg) Descriptor ¶
func (*TrafficBroadcastMsg) Descriptor() ([]byte, []int)
func (*TrafficBroadcastMsg) GetBroadcastMsg ¶
func (m *TrafficBroadcastMsg) GetBroadcastMsg() string
func (*TrafficBroadcastMsg) GetRemoteAddr ¶
func (m *TrafficBroadcastMsg) GetRemoteAddr() []string
func (*TrafficBroadcastMsg) Marshal ¶
func (m *TrafficBroadcastMsg) Marshal() (dAtA []byte, err error)
func (*TrafficBroadcastMsg) MarshalTo ¶
func (m *TrafficBroadcastMsg) MarshalTo(dAtA []byte) (int, error)
func (*TrafficBroadcastMsg) MarshalToSizedBuffer ¶
func (m *TrafficBroadcastMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TrafficBroadcastMsg) ProtoMessage ¶
func (*TrafficBroadcastMsg) ProtoMessage()
func (*TrafficBroadcastMsg) Reset ¶
func (m *TrafficBroadcastMsg) Reset()
func (*TrafficBroadcastMsg) Size ¶
func (m *TrafficBroadcastMsg) Size() (n int)
func (*TrafficBroadcastMsg) String ¶
func (m *TrafficBroadcastMsg) String() string
func (*TrafficBroadcastMsg) Unmarshal ¶
func (m *TrafficBroadcastMsg) Unmarshal(dAtA []byte) error
func (*TrafficBroadcastMsg) XXX_DiscardUnknown ¶
func (m *TrafficBroadcastMsg) XXX_DiscardUnknown()
func (*TrafficBroadcastMsg) XXX_Marshal ¶
func (m *TrafficBroadcastMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TrafficBroadcastMsg) XXX_Merge ¶
func (m *TrafficBroadcastMsg) XXX_Merge(src proto.Message)
func (*TrafficBroadcastMsg) XXX_Size ¶
func (m *TrafficBroadcastMsg) XXX_Size() int
func (*TrafficBroadcastMsg) XXX_Unmarshal ¶
func (m *TrafficBroadcastMsg) XXX_Unmarshal(b []byte) error
type TrafficReq ¶
type TrafficReq struct { // 客户端连接地址 Addr int64 `protobuf:"varint,1,opt,name=addr,proto3" json:"addr,omitempty"` // 动作 Action string `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"` // 请求信息 ReqMsg string `protobuf:"bytes,3,opt,name=reqMsg,proto3" json:"reqMsg,omitempty"` }
func (*TrafficReq) Descriptor ¶
func (*TrafficReq) Descriptor() ([]byte, []int)
func (*TrafficReq) GetAction ¶
func (m *TrafficReq) GetAction() string
func (*TrafficReq) GetAddr ¶
func (m *TrafficReq) GetAddr() int64
func (*TrafficReq) GetReqMsg ¶
func (m *TrafficReq) GetReqMsg() string
func (*TrafficReq) Marshal ¶
func (m *TrafficReq) Marshal() (dAtA []byte, err error)
func (*TrafficReq) MarshalToSizedBuffer ¶
func (m *TrafficReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TrafficReq) ProtoMessage ¶
func (*TrafficReq) ProtoMessage()
func (*TrafficReq) Reset ¶
func (m *TrafficReq) Reset()
func (*TrafficReq) Size ¶
func (m *TrafficReq) Size() (n int)
func (*TrafficReq) String ¶
func (m *TrafficReq) String() string
func (*TrafficReq) Unmarshal ¶
func (m *TrafficReq) Unmarshal(dAtA []byte) error
func (*TrafficReq) XXX_DiscardUnknown ¶
func (m *TrafficReq) XXX_DiscardUnknown()
func (*TrafficReq) XXX_Marshal ¶
func (m *TrafficReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TrafficReq) XXX_Merge ¶
func (m *TrafficReq) XXX_Merge(src proto.Message)
func (*TrafficReq) XXX_Size ¶
func (m *TrafficReq) XXX_Size() int
func (*TrafficReq) XXX_Unmarshal ¶
func (m *TrafficReq) XXX_Unmarshal(b []byte) error
type TrafficResp ¶
type TrafficResp struct { // 广播信息 BroadcastMsg []*TrafficBroadcastMsg `protobuf:"bytes,1,rep,name=broadcastMsg,proto3" json:"broadcastMsg,omitempty"` // 响应信息 RespMsg string `protobuf:"bytes,2,opt,name=respMsg,proto3" json:"respMsg,omitempty"` }
func (*TrafficResp) Descriptor ¶
func (*TrafficResp) Descriptor() ([]byte, []int)
func (*TrafficResp) GetBroadcastMsg ¶
func (m *TrafficResp) GetBroadcastMsg() []*TrafficBroadcastMsg
func (*TrafficResp) GetRespMsg ¶
func (m *TrafficResp) GetRespMsg() string
func (*TrafficResp) Marshal ¶
func (m *TrafficResp) Marshal() (dAtA []byte, err error)
func (*TrafficResp) MarshalToSizedBuffer ¶
func (m *TrafficResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TrafficResp) ProtoMessage ¶
func (*TrafficResp) ProtoMessage()
func (*TrafficResp) Reset ¶
func (m *TrafficResp) Reset()
func (*TrafficResp) Size ¶
func (m *TrafficResp) Size() (n int)
func (*TrafficResp) String ¶
func (m *TrafficResp) String() string
func (*TrafficResp) Unmarshal ¶
func (m *TrafficResp) Unmarshal(dAtA []byte) error
func (*TrafficResp) XXX_DiscardUnknown ¶
func (m *TrafficResp) XXX_DiscardUnknown()
func (*TrafficResp) XXX_Marshal ¶
func (m *TrafficResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TrafficResp) XXX_Merge ¶
func (m *TrafficResp) XXX_Merge(src proto.Message)
func (*TrafficResp) XXX_Size ¶
func (m *TrafficResp) XXX_Size() int
func (*TrafficResp) XXX_Unmarshal ¶
func (m *TrafficResp) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.