dto

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Aug 29, 2022 License: MPL-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBaseDto        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBaseDto          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBaseDto = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthServerDto        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowServerDto          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupServerDto = fmt.Errorf("proto: unexpected end of group")
)

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) Descriptor() ([]byte, []int)

func (*BoolReply) GetResult 

func (m *BoolReply) GetResult() bool

func (*BoolReply) Marshal 

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

func (*BoolReply) MarshalTo 

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

func (*BoolReply) MarshalToSizedBuffer 

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

func (*BoolReply) ProtoMessage 

func (*BoolReply) ProtoMessage()

func (*BoolReply) Reset 

func (m *BoolReply) Reset()

func (*BoolReply) Size 

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

func (*BoolReply) String 

func (m *BoolReply) String() string

func (*BoolReply) Unmarshal 

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

func (*BoolReply) XXX_DiscardUnknown 

func (m *BoolReply) XXX_DiscardUnknown()

func (*BoolReply) XXX_Marshal 

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

func (*BoolReply) XXX_Merge 

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

func (*BoolReply) XXX_Size 

func (m *BoolReply) XXX_Size() int

func (*BoolReply) XXX_Unmarshal 

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

type BootReq 

type BootReq struct {
}

func (*BootReq) Descriptor 

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

func (*BootReq) Marshal 

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

func (*BootReq) MarshalTo 

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

func (*BootReq) MarshalToSizedBuffer 

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

func (*BootReq) ProtoMessage 

func (*BootReq) ProtoMessage()

func (*BootReq) Reset 

func (m *BootReq) Reset()

func (*BootReq) Size 

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

func (*BootReq) String 

func (m *BootReq) String() string

func (*BootReq) Unmarshal 

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

func (*BootReq) XXX_DiscardUnknown 

func (m *BootReq) XXX_DiscardUnknown()

func (*BootReq) XXX_Marshal 

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

func (*BootReq) XXX_Merge 

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

func (*BootReq) XXX_Size 

func (m *BootReq) XXX_Size() int

func (*BootReq) XXX_Unmarshal 

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

type BootResp 

type BootResp struct {
}

func (*BootResp) Descriptor 

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

func (*BootResp) Marshal 

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

func (*BootResp) MarshalTo 

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

func (*BootResp) MarshalToSizedBuffer 

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

func (*BootResp) ProtoMessage 

func (*BootResp) ProtoMessage()

func (*BootResp) Reset 

func (m *BootResp) Reset()

func (*BootResp) Size 

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

func (*BootResp) String 

func (m *BootResp) String() string

func (*BootResp) Unmarshal 

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

func (*BootResp) XXX_DiscardUnknown 

func (m *BootResp) XXX_DiscardUnknown()

func (*BootResp) XXX_Marshal 

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

func (*BootResp) XXX_Merge 

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

func (*BootResp) XXX_Size 

func (m *BootResp) XXX_Size() int

func (*BootResp) XXX_Unmarshal 

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

type CloseReq 

type CloseReq struct {
	// 客户端连接地址
	Addr int64 `protobuf:"varint,1,opt,name=addr,proto3" json:"addr,omitempty"`
}

func (*CloseReq) Descriptor 

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

func (*CloseReq) GetAddr 

func (m *CloseReq) GetAddr() int64

func (*CloseReq) Marshal 

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

func (*CloseReq) MarshalTo 

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

func (*CloseReq) MarshalToSizedBuffer 

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

func (*CloseReq) ProtoMessage 

func (*CloseReq) ProtoMessage()

func (*CloseReq) Reset 

func (m *CloseReq) Reset()

func (*CloseReq) Size 

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

func (*CloseReq) String 

func (m *CloseReq) String() string

func (*CloseReq) Unmarshal 

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

func (*CloseReq) XXX_DiscardUnknown 

func (m *CloseReq) XXX_DiscardUnknown()

func (*CloseReq) XXX_Marshal 

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

func (*CloseReq) XXX_Merge 

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

func (*CloseReq) XXX_Size 

func (m *CloseReq) XXX_Size() int

func (*CloseReq) XXX_Unmarshal 

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

type CloseResp 

type CloseResp struct {
}

func (*CloseResp) Descriptor 

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

func (*CloseResp) Marshal 

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

func (*CloseResp) MarshalTo 

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

func (*CloseResp) MarshalToSizedBuffer 

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

func (*CloseResp) ProtoMessage 

func (*CloseResp) ProtoMessage()

func (*CloseResp) Reset 

func (m *CloseResp) Reset()

func (*CloseResp) Size 

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

func (*CloseResp) String 

func (m *CloseResp) String() string

func (*CloseResp) Unmarshal 

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

func (*CloseResp) XXX_DiscardUnknown 

func (m *CloseResp) XXX_DiscardUnknown()

func (*CloseResp) XXX_Marshal 

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

func (*CloseResp) XXX_Merge 

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

func (*CloseResp) XXX_Size 

func (m *CloseResp) XXX_Size() int

func (*CloseResp) XXX_Unmarshal 

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

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) Descriptor() ([]byte, []int)

func (*Filtered) GetField 

func (m *Filtered) GetField() string

func (*Filtered) GetOp 

func (m *Filtered) GetOp() string

func (*Filtered) GetValue 

func (m *Filtered) GetValue() string

func (*Filtered) GetValueType 

func (m *Filtered) GetValueType() string

func (*Filtered) Marshal 

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

func (*Filtered) MarshalTo 

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

func (*Filtered) MarshalToSizedBuffer 

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

func (*Filtered) ProtoMessage 

func (*Filtered) ProtoMessage()

func (*Filtered) Reset 

func (m *Filtered) Reset()

func (*Filtered) Size 

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

func (*Filtered) String 

func (m *Filtered) String() string

func (*Filtered) Unmarshal 

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

func (*Filtered) XXX_DiscardUnknown 

func (m *Filtered) XXX_DiscardUnknown()

func (*Filtered) XXX_Marshal 

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

func (*Filtered) XXX_Merge 

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

func (*Filtered) XXX_Size 

func (m *Filtered) XXX_Size() int

func (*Filtered) XXX_Unmarshal 

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

type IdReply 

type IdReply struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id"`
}

func (*IdReply) Descriptor 

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

func (*IdReply) GetId 

func (m *IdReply) GetId() int64

func (*IdReply) Marshal 

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

func (*IdReply) MarshalTo 

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

func (*IdReply) MarshalToSizedBuffer 

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

func (*IdReply) ProtoMessage 

func (*IdReply) ProtoMessage()

func (*IdReply) Reset 

func (m *IdReply) Reset()

func (*IdReply) Size 

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

func (*IdReply) String 

func (m *IdReply) String() string

func (*IdReply) Unmarshal 

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

func (*IdReply) XXX_DiscardUnknown 

func (m *IdReply) XXX_DiscardUnknown()

func (*IdReply) XXX_Marshal 

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

func (*IdReply) XXX_Merge 

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

func (*IdReply) XXX_Size 

func (m *IdReply) XXX_Size() int

func (*IdReply) XXX_Unmarshal 

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

type IdReq 

type IdReq struct {
	//主键id
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id" validate:"required"`
}

func (*IdReq) Descriptor 

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

func (*IdReq) GetId 

func (m *IdReq) GetId() int64

func (*IdReq) Marshal 

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

func (*IdReq) MarshalTo 

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

func (*IdReq) MarshalToSizedBuffer 

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

func (*IdReq) ProtoMessage 

func (*IdReq) ProtoMessage()

func (*IdReq) Reset 

func (m *IdReq) Reset()

func (*IdReq) Size 

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

func (*IdReq) String 

func (m *IdReq) String() string

func (*IdReq) Unmarshal 

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

func (*IdReq) XXX_DiscardUnknown 

func (m *IdReq) XXX_DiscardUnknown()

func (*IdReq) XXX_Marshal 

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

func (*IdReq) XXX_Merge 

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

func (*IdReq) XXX_Size 

func (m *IdReq) XXX_Size() int

func (*IdReq) XXX_Unmarshal 

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

type IdResp 

type IdResp struct {
	//主键id
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id" validate:"required"`
}

func (*IdResp) Descriptor 

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

func (*IdResp) GetId 

func (m *IdResp) GetId() int64

func (*IdResp) Marshal 

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

func (*IdResp) MarshalTo 

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

func (*IdResp) MarshalToSizedBuffer 

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

func (*IdResp) ProtoMessage 

func (*IdResp) ProtoMessage()

func (*IdResp) Reset 

func (m *IdResp) Reset()

func (*IdResp) Size 

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

func (*IdResp) String 

func (m *IdResp) String() string

func (*IdResp) Unmarshal 

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

func (*IdResp) XXX_DiscardUnknown 

func (m *IdResp) XXX_DiscardUnknown()

func (*IdResp) XXX_Marshal 

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

func (*IdResp) XXX_Merge 

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

func (*IdResp) XXX_Size 

func (m *IdResp) XXX_Size() int

func (*IdResp) XXX_Unmarshal 

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

type IdsReply 

type IdsReply struct {
	Ids []int64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids"`
}

func (*IdsReply) Descriptor 

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

func (*IdsReply) GetIds 

func (m *IdsReply) GetIds() []int64

func (*IdsReply) Marshal 

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

func (*IdsReply) MarshalTo 

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

func (*IdsReply) MarshalToSizedBuffer 

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

func (*IdsReply) ProtoMessage 

func (*IdsReply) ProtoMessage()

func (*IdsReply) Reset 

func (m *IdsReply) Reset()

func (*IdsReply) Size 

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

func (*IdsReply) String 

func (m *IdsReply) String() string

func (*IdsReply) Unmarshal 

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

func (*IdsReply) XXX_DiscardUnknown 

func (m *IdsReply) XXX_DiscardUnknown()

func (*IdsReply) XXX_Marshal 

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

func (*IdsReply) XXX_Merge 

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

func (*IdsReply) XXX_Size 

func (m *IdsReply) XXX_Size() int

func (*IdsReply) XXX_Unmarshal 

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

type IdsReq 

type IdsReq struct {
	Ids []int64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids" validate:"required"`
}

func (*IdsReq) Descriptor 

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

func (*IdsReq) GetIds 

func (m *IdsReq) GetIds() []int64

func (*IdsReq) Marshal 

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

func (*IdsReq) MarshalTo 

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

func (*IdsReq) MarshalToSizedBuffer 

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

func (*IdsReq) ProtoMessage 

func (*IdsReq) ProtoMessage()

func (*IdsReq) Reset 

func (m *IdsReq) Reset()

func (*IdsReq) Size 

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

func (*IdsReq) String 

func (m *IdsReq) String() string

func (*IdsReq) Unmarshal 

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

func (*IdsReq) XXX_DiscardUnknown 

func (m *IdsReq) XXX_DiscardUnknown()

func (*IdsReq) XXX_Marshal 

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

func (*IdsReq) XXX_Merge 

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

func (*IdsReq) XXX_Size 

func (m *IdsReq) XXX_Size() int

func (*IdsReq) XXX_Unmarshal 

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

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) Descriptor() ([]byte, []int)

func (*ListReply) GetPageNumber 

func (m *ListReply) GetPageNumber() int64

func (*ListReply) GetPageSize 

func (m *ListReply) GetPageSize() int64

func (*ListReply) GetTotalPages 

func (m *ListReply) GetTotalPages() int64

func (*ListReply) GetTotalRecords 

func (m *ListReply) GetTotalRecords() int64

func (*ListReply) Marshal 

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

func (*ListReply) MarshalTo 

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

func (*ListReply) MarshalToSizedBuffer 

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

func (*ListReply) ProtoMessage 

func (*ListReply) ProtoMessage()

func (*ListReply) Reset 

func (m *ListReply) Reset()

func (*ListReply) Size 

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

func (*ListReply) String 

func (m *ListReply) String() string

func (*ListReply) Unmarshal 

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

func (*ListReply) XXX_DiscardUnknown 

func (m *ListReply) XXX_DiscardUnknown()

func (*ListReply) XXX_Marshal 

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

func (*ListReply) XXX_Merge 

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

func (*ListReply) XXX_Size 

func (m *ListReply) XXX_Size() int

func (*ListReply) XXX_Unmarshal 

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

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) Descriptor() ([]byte, []int)

func (*OpenReq) GetAddr 

func (m *OpenReq) GetAddr() int64

func (*OpenReq) GetToken 

func (m *OpenReq) GetToken() string

func (*OpenReq) Marshal 

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

func (*OpenReq) MarshalTo 

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

func (*OpenReq) MarshalToSizedBuffer 

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

func (*OpenReq) ProtoMessage 

func (*OpenReq) ProtoMessage()

func (*OpenReq) Reset 

func (m *OpenReq) Reset()

func (*OpenReq) Size 

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

func (*OpenReq) String 

func (m *OpenReq) String() string

func (*OpenReq) Unmarshal 

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

func (*OpenReq) XXX_DiscardUnknown 

func (m *OpenReq) XXX_DiscardUnknown()

func (*OpenReq) XXX_Marshal 

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

func (*OpenReq) XXX_Merge 

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

func (*OpenReq) XXX_Size 

func (m *OpenReq) XXX_Size() int

func (*OpenReq) XXX_Unmarshal 

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

type OpenResp 

type OpenResp struct {
}

func (*OpenResp) Descriptor 

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

func (*OpenResp) Marshal 

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

func (*OpenResp) MarshalTo 

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

func (*OpenResp) MarshalToSizedBuffer 

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

func (*OpenResp) ProtoMessage 

func (*OpenResp) ProtoMessage()

func (*OpenResp) Reset 

func (m *OpenResp) Reset()

func (*OpenResp) Size 

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

func (*OpenResp) String 

func (m *OpenResp) String() string

func (*OpenResp) Unmarshal 

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

func (*OpenResp) XXX_DiscardUnknown 

func (m *OpenResp) XXX_DiscardUnknown()

func (*OpenResp) XXX_Marshal 

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

func (*OpenResp) XXX_Merge 

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

func (*OpenResp) XXX_Size 

func (m *OpenResp) XXX_Size() int

func (*OpenResp) XXX_Unmarshal 

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

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) Descriptor() ([]byte, []int)

func (*QueryReq) GetFiltered 

func (m *QueryReq) GetFiltered() []*Filtered

func (*QueryReq) GetPage 

func (m *QueryReq) GetPage() int64

func (*QueryReq) GetPageSize 

func (m *QueryReq) GetPageSize() int64

func (*QueryReq) GetSorted 

func (m *QueryReq) GetSorted() []*Sorted

func (*QueryReq) Marshal 

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

func (*QueryReq) MarshalTo 

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

func (*QueryReq) MarshalToSizedBuffer 

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

func (*QueryReq) ProtoMessage 

func (*QueryReq) ProtoMessage()

func (*QueryReq) Reset 

func (m *QueryReq) Reset()

func (*QueryReq) Size 

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

func (*QueryReq) String 

func (m *QueryReq) String() string

func (*QueryReq) Unmarshal 

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

func (*QueryReq) XXX_DiscardUnknown 

func (m *QueryReq) XXX_DiscardUnknown()

func (*QueryReq) XXX_Marshal 

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

func (*QueryReq) XXX_Merge 

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

func (*QueryReq) XXX_Size 

func (m *QueryReq) XXX_Size() int

func (*QueryReq) XXX_Unmarshal 

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

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) Descriptor() ([]byte, []int)

func (*Reply) GetMessage 

func (m *Reply) GetMessage() string

func (*Reply) GetStatus 

func (m *Reply) GetStatus() int32

func (*Reply) Marshal 

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

func (*Reply) MarshalTo 

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

func (*Reply) MarshalToSizedBuffer 

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

func (*Reply) ProtoMessage 

func (*Reply) ProtoMessage()

func (*Reply) Reset 

func (m *Reply) Reset()

func (*Reply) Size 

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

func (*Reply) String 

func (m *Reply) String() string

func (*Reply) Unmarshal 

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

func (*Reply) XXX_DiscardUnknown 

func (m *Reply) XXX_DiscardUnknown()

func (*Reply) XXX_Marshal 

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

func (*Reply) XXX_Merge 

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

func (*Reply) XXX_Size 

func (m *Reply) XXX_Size() int

func (*Reply) XXX_Unmarshal 

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

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) MarshalTo 

func (m *ShutdownReq) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ShutdownResp) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Sorted) GetDesc 

func (m *Sorted) GetDesc() bool

func (*Sorted) GetId 

func (m *Sorted) GetId() string

func (*Sorted) Marshal 

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

func (*Sorted) MarshalTo 

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

func (*Sorted) MarshalToSizedBuffer 

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

func (*Sorted) ProtoMessage 

func (*Sorted) ProtoMessage()

func (*Sorted) Reset 

func (m *Sorted) Reset()

func (*Sorted) Size 

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

func (*Sorted) String 

func (m *Sorted) String() string

func (*Sorted) Unmarshal 

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

func (*Sorted) XXX_DiscardUnknown 

func (m *Sorted) XXX_DiscardUnknown()

func (*Sorted) XXX_Marshal 

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

func (*Sorted) XXX_Merge 

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

func (*Sorted) XXX_Size 

func (m *Sorted) XXX_Size() int

func (*Sorted) XXX_Unmarshal 

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

type StrIdReq 

type StrIdReq struct {
	// 主键id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id" validate:"required"`
}

func (*StrIdReq) Descriptor 

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

func (*StrIdReq) GetId 

func (m *StrIdReq) GetId() string

func (*StrIdReq) Marshal 

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

func (*StrIdReq) MarshalTo 

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

func (*StrIdReq) MarshalToSizedBuffer 

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

func (*StrIdReq) ProtoMessage 

func (*StrIdReq) ProtoMessage()

func (*StrIdReq) Reset 

func (m *StrIdReq) Reset()

func (*StrIdReq) Size 

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

func (*StrIdReq) String 

func (m *StrIdReq) String() string

func (*StrIdReq) Unmarshal 

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

func (*StrIdReq) XXX_DiscardUnknown 

func (m *StrIdReq) XXX_DiscardUnknown()

func (*StrIdReq) XXX_Marshal 

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

func (*StrIdReq) XXX_Merge 

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

func (*StrIdReq) XXX_Size 

func (m *StrIdReq) XXX_Size() int

func (*StrIdReq) XXX_Unmarshal 

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

type StrIdsReq 

type StrIdsReq struct {
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids" validate:"required"`
}

func (*StrIdsReq) Descriptor 

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

func (*StrIdsReq) GetIds 

func (m *StrIdsReq) GetIds() []string

func (*StrIdsReq) Marshal 

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

func (*StrIdsReq) MarshalTo 

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

func (*StrIdsReq) MarshalToSizedBuffer 

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

func (*StrIdsReq) ProtoMessage 

func (*StrIdsReq) ProtoMessage()

func (*StrIdsReq) Reset 

func (m *StrIdsReq) Reset()

func (*StrIdsReq) Size 

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

func (*StrIdsReq) String 

func (m *StrIdsReq) String() string

func (*StrIdsReq) Unmarshal 

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

func (*StrIdsReq) XXX_DiscardUnknown 

func (m *StrIdsReq) XXX_DiscardUnknown()

func (*StrIdsReq) XXX_Marshal 

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

func (*StrIdsReq) XXX_Merge 

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

func (*StrIdsReq) XXX_Size 

func (m *StrIdsReq) XXX_Size() int

func (*StrIdsReq) XXX_Unmarshal 

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

type TickReq 

type TickReq struct {
}

func (*TickReq) Descriptor 

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

func (*TickReq) Marshal 

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

func (*TickReq) MarshalTo 

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

func (*TickReq) MarshalToSizedBuffer 

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

func (*TickReq) ProtoMessage 

func (*TickReq) ProtoMessage()

func (*TickReq) Reset 

func (m *TickReq) Reset()

func (*TickReq) Size 

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

func (*TickReq) String 

func (m *TickReq) String() string

func (*TickReq) Unmarshal 

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

func (*TickReq) XXX_DiscardUnknown 

func (m *TickReq) XXX_DiscardUnknown()

func (*TickReq) XXX_Marshal 

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

func (*TickReq) XXX_Merge 

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

func (*TickReq) XXX_Size 

func (m *TickReq) XXX_Size() int

func (*TickReq) XXX_Unmarshal 

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

type TickResp 

type TickResp struct {
}

func (*TickResp) Descriptor 

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

func (*TickResp) Marshal 

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

func (*TickResp) MarshalTo 

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

func (*TickResp) MarshalToSizedBuffer 

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

func (*TickResp) ProtoMessage 

func (*TickResp) ProtoMessage()

func (*TickResp) Reset 

func (m *TickResp) Reset()

func (*TickResp) Size 

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

func (*TickResp) String 

func (m *TickResp) String() string

func (*TickResp) Unmarshal 

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

func (*TickResp) XXX_DiscardUnknown 

func (m *TickResp) XXX_DiscardUnknown()

func (*TickResp) XXX_Marshal 

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

func (*TickResp) XXX_Merge 

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

func (*TickResp) XXX_Size 

func (m *TickResp) XXX_Size() int

func (*TickResp) XXX_Unmarshal 

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

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) MarshalTo 

func (m *TrafficReq) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *TrafficResp) MarshalTo(dAtA []byte) (int, 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

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.