mongo

package
v0.0.0-...-b63aa1a Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2019 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterService 

func RegisterService(s giraffe_micro.Server, srv Service)

Types

type Client 

type Client interface {
	Insert(ctx context.Context, in *InsertRequest) (*types.Empty, error)
	Remove(ctx context.Context, in *RemoveRequest) (*types.Empty, error)
	RemoveAll(ctx context.Context, in *RemoveAllRequest) (*RemoveAllResponse, error)
	Search(ctx context.Context, in *SearchRequest) (*SearchResponse, error)
	SearchAll(ctx context.Context, in *SearchAllRequest) (*SearchAllResponse, error)
	SearchOne(ctx context.Context, in *SearchOneRequest) (*SearchOneResponse, error)
	Update(ctx context.Context, in *UpdateRequest) (*types.Empty, error)
	UpdateAll(ctx context.Context, in *UpdateAllRequest) (*UpdateAllResponse, error)
}

Client is the client API for mongo service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClient 

func NewClient(c giraffe_micro.Client) Client

type InsertRequest 

type InsertRequest struct {
	//
	//表名
	Collection string `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection" form:"collection"`
	//
	//待插入的记录列表
	DocList              []*types.Struct `protobuf:"bytes,2,rep,name=docList,proto3" json:"docList" form:"docList"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Insert请求

func (*InsertRequest) Descriptor 

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

func (*InsertRequest) GetCollection 

func (m *InsertRequest) GetCollection() string

func (*InsertRequest) GetDocList 

func (m *InsertRequest) GetDocList() []*types.Struct

func (*InsertRequest) ProtoMessage 

func (*InsertRequest) ProtoMessage()

func (*InsertRequest) Reset 

func (m *InsertRequest) Reset()

func (*InsertRequest) String 

func (m *InsertRequest) String() string

func (*InsertRequest) Validate 

func (this *InsertRequest) Validate() error

func (*InsertRequest) XXX_DiscardUnknown 

func (m *InsertRequest) XXX_DiscardUnknown()

func (*InsertRequest) XXX_Marshal 

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

func (*InsertRequest) XXX_Merge 

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

func (*InsertRequest) XXX_Size 

func (m *InsertRequest) XXX_Size() int

func (*InsertRequest) XXX_Unmarshal 

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

type InsertResponseWrapper 

type InsertResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *types.Empty `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

InsertApi返回

func (*InsertResponseWrapper) Descriptor 

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

func (*InsertResponseWrapper) GetCode 

func (m *InsertResponseWrapper) GetCode() int32

func (*InsertResponseWrapper) GetCodeExplain 

func (m *InsertResponseWrapper) GetCodeExplain() string

func (*InsertResponseWrapper) GetData 

func (m *InsertResponseWrapper) GetData() *types.Empty

func (*InsertResponseWrapper) GetError 

func (m *InsertResponseWrapper) GetError() string

func (*InsertResponseWrapper) ProtoMessage 

func (*InsertResponseWrapper) ProtoMessage()

func (*InsertResponseWrapper) Reset 

func (m *InsertResponseWrapper) Reset()

func (*InsertResponseWrapper) String 

func (m *InsertResponseWrapper) String() string

func (*InsertResponseWrapper) Validate 

func (this *InsertResponseWrapper) Validate() error

func (*InsertResponseWrapper) XXX_DiscardUnknown 

func (m *InsertResponseWrapper) XXX_DiscardUnknown()

func (*InsertResponseWrapper) XXX_Marshal 

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

func (*InsertResponseWrapper) XXX_Merge 

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

func (*InsertResponseWrapper) XXX_Size 

func (m *InsertResponseWrapper) XXX_Size() int

func (*InsertResponseWrapper) XXX_Unmarshal 

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

type RemoveAllRequest 

type RemoveAllRequest struct {
	//
	//表名
	Collection string `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection" form:"collection"`
	//
	//删除条件
	Selector             *types.Struct `protobuf:"bytes,2,opt,name=selector,proto3" json:"selector" form:"selector"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

RemoveAll请求

func (*RemoveAllRequest) Descriptor 

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

func (*RemoveAllRequest) GetCollection 

func (m *RemoveAllRequest) GetCollection() string

func (*RemoveAllRequest) GetSelector 

func (m *RemoveAllRequest) GetSelector() *types.Struct

func (*RemoveAllRequest) ProtoMessage 

func (*RemoveAllRequest) ProtoMessage()

func (*RemoveAllRequest) Reset 

func (m *RemoveAllRequest) Reset()

func (*RemoveAllRequest) String 

func (m *RemoveAllRequest) String() string

func (*RemoveAllRequest) Validate 

func (this *RemoveAllRequest) Validate() error

func (*RemoveAllRequest) XXX_DiscardUnknown 

func (m *RemoveAllRequest) XXX_DiscardUnknown()

func (*RemoveAllRequest) XXX_Marshal 

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

func (*RemoveAllRequest) XXX_Merge 

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

func (*RemoveAllRequest) XXX_Size 

func (m *RemoveAllRequest) XXX_Size() int

func (*RemoveAllRequest) XXX_Unmarshal 

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

type RemoveAllResponse 

type RemoveAllResponse struct {
	//
	//删除总数
	Removed              int32    `protobuf:"varint,1,opt,name=removed,proto3" json:"removed" form:"removed"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RemoveAll返回

func (*RemoveAllResponse) Descriptor 

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

func (*RemoveAllResponse) GetRemoved 

func (m *RemoveAllResponse) GetRemoved() int32

func (*RemoveAllResponse) ProtoMessage 

func (*RemoveAllResponse) ProtoMessage()

func (*RemoveAllResponse) Reset 

func (m *RemoveAllResponse) Reset()

func (*RemoveAllResponse) String 

func (m *RemoveAllResponse) String() string

func (*RemoveAllResponse) Validate 

func (this *RemoveAllResponse) Validate() error

func (*RemoveAllResponse) XXX_DiscardUnknown 

func (m *RemoveAllResponse) XXX_DiscardUnknown()

func (*RemoveAllResponse) XXX_Marshal 

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

func (*RemoveAllResponse) XXX_Merge 

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

func (*RemoveAllResponse) XXX_Size 

func (m *RemoveAllResponse) XXX_Size() int

func (*RemoveAllResponse) XXX_Unmarshal 

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

type RemoveAllResponseWrapper 

type RemoveAllResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *RemoveAllResponse `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

RemoveAllApi返回

func (*RemoveAllResponseWrapper) Descriptor 

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

func (*RemoveAllResponseWrapper) GetCode 

func (m *RemoveAllResponseWrapper) GetCode() int32

func (*RemoveAllResponseWrapper) GetCodeExplain 

func (m *RemoveAllResponseWrapper) GetCodeExplain() string

func (*RemoveAllResponseWrapper) GetData 

func (m *RemoveAllResponseWrapper) GetData() *RemoveAllResponse

func (*RemoveAllResponseWrapper) GetError 

func (m *RemoveAllResponseWrapper) GetError() string

func (*RemoveAllResponseWrapper) ProtoMessage 

func (*RemoveAllResponseWrapper) ProtoMessage()

func (*RemoveAllResponseWrapper) Reset 

func (m *RemoveAllResponseWrapper) Reset()

func (*RemoveAllResponseWrapper) String 

func (m *RemoveAllResponseWrapper) String() string

func (*RemoveAllResponseWrapper) Validate 

func (this *RemoveAllResponseWrapper) Validate() error

func (*RemoveAllResponseWrapper) XXX_DiscardUnknown 

func (m *RemoveAllResponseWrapper) XXX_DiscardUnknown()

func (*RemoveAllResponseWrapper) XXX_Marshal 

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

func (*RemoveAllResponseWrapper) XXX_Merge 

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

func (*RemoveAllResponseWrapper) XXX_Size 

func (m *RemoveAllResponseWrapper) XXX_Size() int

func (*RemoveAllResponseWrapper) XXX_Unmarshal 

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

type RemoveRequest 

type RemoveRequest struct {
	//
	//表名
	Collection string `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection" form:"collection"`
	//
	//删除条件
	Selector             *types.Struct `protobuf:"bytes,2,opt,name=selector,proto3" json:"selector" form:"selector"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Remove请求

func (*RemoveRequest) Descriptor 

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

func (*RemoveRequest) GetCollection 

func (m *RemoveRequest) GetCollection() string

func (*RemoveRequest) GetSelector 

func (m *RemoveRequest) GetSelector() *types.Struct

func (*RemoveRequest) ProtoMessage 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) Reset 

func (m *RemoveRequest) Reset()

func (*RemoveRequest) String 

func (m *RemoveRequest) String() string

func (*RemoveRequest) Validate 

func (this *RemoveRequest) Validate() error

func (*RemoveRequest) XXX_DiscardUnknown 

func (m *RemoveRequest) XXX_DiscardUnknown()

func (*RemoveRequest) XXX_Marshal 

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

func (*RemoveRequest) XXX_Merge 

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

func (*RemoveRequest) XXX_Size 

func (m *RemoveRequest) XXX_Size() int

func (*RemoveRequest) XXX_Unmarshal 

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

type RemoveResponseWrapper 

type RemoveResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *types.Empty `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

RemoveApi返回

func (*RemoveResponseWrapper) Descriptor 

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

func (*RemoveResponseWrapper) GetCode 

func (m *RemoveResponseWrapper) GetCode() int32

func (*RemoveResponseWrapper) GetCodeExplain 

func (m *RemoveResponseWrapper) GetCodeExplain() string

func (*RemoveResponseWrapper) GetData 

func (m *RemoveResponseWrapper) GetData() *types.Empty

func (*RemoveResponseWrapper) GetError 

func (m *RemoveResponseWrapper) GetError() string

func (*RemoveResponseWrapper) ProtoMessage 

func (*RemoveResponseWrapper) ProtoMessage()

func (*RemoveResponseWrapper) Reset 

func (m *RemoveResponseWrapper) Reset()

func (*RemoveResponseWrapper) String 

func (m *RemoveResponseWrapper) String() string

func (*RemoveResponseWrapper) Validate 

func (this *RemoveResponseWrapper) Validate() error

func (*RemoveResponseWrapper) XXX_DiscardUnknown 

func (m *RemoveResponseWrapper) XXX_DiscardUnknown()

func (*RemoveResponseWrapper) XXX_Marshal 

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

func (*RemoveResponseWrapper) XXX_Merge 

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

func (*RemoveResponseWrapper) XXX_Size 

func (m *RemoveResponseWrapper) XXX_Size() int

func (*RemoveResponseWrapper) XXX_Unmarshal 

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

type SearchAllRequest 

type SearchAllRequest struct {
	//
	//表名
	Collection string `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection" form:"collection"`
	//
	//查询条件
	Query *types.Struct `protobuf:"bytes,2,opt,name=query,proto3" json:"query" form:"query"`
	//
	//fields
	Fields []string `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields" form:"fields"`
	//
	//sort
	Sort                 []string `protobuf:"bytes,4,rep,name=sort,proto3" json:"sort" form:"sort"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SearchAll请求

func (*SearchAllRequest) Descriptor 

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

func (*SearchAllRequest) GetCollection 

func (m *SearchAllRequest) GetCollection() string

func (*SearchAllRequest) GetFields 

func (m *SearchAllRequest) GetFields() []string

func (*SearchAllRequest) GetQuery 

func (m *SearchAllRequest) GetQuery() *types.Struct

func (*SearchAllRequest) GetSort 

func (m *SearchAllRequest) GetSort() []string

func (*SearchAllRequest) ProtoMessage 

func (*SearchAllRequest) ProtoMessage()

func (*SearchAllRequest) Reset 

func (m *SearchAllRequest) Reset()

func (*SearchAllRequest) String 

func (m *SearchAllRequest) String() string

func (*SearchAllRequest) Validate 

func (this *SearchAllRequest) Validate() error

func (*SearchAllRequest) XXX_DiscardUnknown 

func (m *SearchAllRequest) XXX_DiscardUnknown()

func (*SearchAllRequest) XXX_Marshal 

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

func (*SearchAllRequest) XXX_Merge 

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

func (*SearchAllRequest) XXX_Size 

func (m *SearchAllRequest) XXX_Size() int

func (*SearchAllRequest) XXX_Unmarshal 

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

type SearchAllResponse 

type SearchAllResponse struct {
	//
	//记录列表
	DocList              []*types.Struct `protobuf:"bytes,1,rep,name=docList,proto3" json:"docList" form:"docList"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

SearchAll返回

func (*SearchAllResponse) Descriptor 

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

func (*SearchAllResponse) GetDocList 

func (m *SearchAllResponse) GetDocList() []*types.Struct

func (*SearchAllResponse) ProtoMessage 

func (*SearchAllResponse) ProtoMessage()

func (*SearchAllResponse) Reset 

func (m *SearchAllResponse) Reset()

func (*SearchAllResponse) String 

func (m *SearchAllResponse) String() string

func (*SearchAllResponse) Validate 

func (this *SearchAllResponse) Validate() error

func (*SearchAllResponse) XXX_DiscardUnknown 

func (m *SearchAllResponse) XXX_DiscardUnknown()

func (*SearchAllResponse) XXX_Marshal 

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

func (*SearchAllResponse) XXX_Merge 

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

func (*SearchAllResponse) XXX_Size 

func (m *SearchAllResponse) XXX_Size() int

func (*SearchAllResponse) XXX_Unmarshal 

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

type SearchAllResponseWrapper 

type SearchAllResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *SearchAllResponse `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

SearchAllApi返回

func (*SearchAllResponseWrapper) Descriptor 

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

func (*SearchAllResponseWrapper) GetCode 

func (m *SearchAllResponseWrapper) GetCode() int32

func (*SearchAllResponseWrapper) GetCodeExplain 

func (m *SearchAllResponseWrapper) GetCodeExplain() string

func (*SearchAllResponseWrapper) GetData 

func (m *SearchAllResponseWrapper) GetData() *SearchAllResponse

func (*SearchAllResponseWrapper) GetError 

func (m *SearchAllResponseWrapper) GetError() string

func (*SearchAllResponseWrapper) ProtoMessage 

func (*SearchAllResponseWrapper) ProtoMessage()

func (*SearchAllResponseWrapper) Reset 

func (m *SearchAllResponseWrapper) Reset()

func (*SearchAllResponseWrapper) String 

func (m *SearchAllResponseWrapper) String() string

func (*SearchAllResponseWrapper) Validate 

func (this *SearchAllResponseWrapper) Validate() error

func (*SearchAllResponseWrapper) XXX_DiscardUnknown 

func (m *SearchAllResponseWrapper) XXX_DiscardUnknown()

func (*SearchAllResponseWrapper) XXX_Marshal 

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

func (*SearchAllResponseWrapper) XXX_Merge 

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

func (*SearchAllResponseWrapper) XXX_Size 

func (m *SearchAllResponseWrapper) XXX_Size() int

func (*SearchAllResponseWrapper) XXX_Unmarshal 

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

type SearchOneRequest 

type SearchOneRequest struct {
	//
	//表名
	Collection string `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection" form:"collection"`
	//
	//查询条件
	Query *types.Struct `protobuf:"bytes,2,opt,name=query,proto3" json:"query" form:"query"`
	//
	//fields
	Fields []string `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields" form:"fields"`
	//
	//sort
	Sort                 []string `protobuf:"bytes,4,rep,name=sort,proto3" json:"sort" form:"sort"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SearchOne请求

func (*SearchOneRequest) Descriptor 

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

func (*SearchOneRequest) GetCollection 

func (m *SearchOneRequest) GetCollection() string

func (*SearchOneRequest) GetFields 

func (m *SearchOneRequest) GetFields() []string

func (*SearchOneRequest) GetQuery 

func (m *SearchOneRequest) GetQuery() *types.Struct

func (*SearchOneRequest) GetSort 

func (m *SearchOneRequest) GetSort() []string

func (*SearchOneRequest) ProtoMessage 

func (*SearchOneRequest) ProtoMessage()

func (*SearchOneRequest) Reset 

func (m *SearchOneRequest) Reset()

func (*SearchOneRequest) String 

func (m *SearchOneRequest) String() string

func (*SearchOneRequest) Validate 

func (this *SearchOneRequest) Validate() error

func (*SearchOneRequest) XXX_DiscardUnknown 

func (m *SearchOneRequest) XXX_DiscardUnknown()

func (*SearchOneRequest) XXX_Marshal 

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

func (*SearchOneRequest) XXX_Merge 

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

func (*SearchOneRequest) XXX_Size 

func (m *SearchOneRequest) XXX_Size() int

func (*SearchOneRequest) XXX_Unmarshal 

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

type SearchOneResponse 

type SearchOneResponse struct {
	//
	//记录
	Doc                  *types.Struct `protobuf:"bytes,1,opt,name=doc,proto3" json:"doc" form:"doc"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

SearchOne返回

func (*SearchOneResponse) Descriptor 

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

func (*SearchOneResponse) GetDoc 

func (m *SearchOneResponse) GetDoc() *types.Struct

func (*SearchOneResponse) ProtoMessage 

func (*SearchOneResponse) ProtoMessage()

func (*SearchOneResponse) Reset 

func (m *SearchOneResponse) Reset()

func (*SearchOneResponse) String 

func (m *SearchOneResponse) String() string

func (*SearchOneResponse) Validate 

func (this *SearchOneResponse) Validate() error

func (*SearchOneResponse) XXX_DiscardUnknown 

func (m *SearchOneResponse) XXX_DiscardUnknown()

func (*SearchOneResponse) XXX_Marshal 

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

func (*SearchOneResponse) XXX_Merge 

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

func (*SearchOneResponse) XXX_Size 

func (m *SearchOneResponse) XXX_Size() int

func (*SearchOneResponse) XXX_Unmarshal 

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

type SearchOneResponseWrapper 

type SearchOneResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *SearchOneResponse `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

SearchOneApi返回

func (*SearchOneResponseWrapper) Descriptor 

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

func (*SearchOneResponseWrapper) GetCode 

func (m *SearchOneResponseWrapper) GetCode() int32

func (*SearchOneResponseWrapper) GetCodeExplain 

func (m *SearchOneResponseWrapper) GetCodeExplain() string

func (*SearchOneResponseWrapper) GetData 

func (m *SearchOneResponseWrapper) GetData() *SearchOneResponse

func (*SearchOneResponseWrapper) GetError 

func (m *SearchOneResponseWrapper) GetError() string

func (*SearchOneResponseWrapper) ProtoMessage 

func (*SearchOneResponseWrapper) ProtoMessage()

func (*SearchOneResponseWrapper) Reset 

func (m *SearchOneResponseWrapper) Reset()

func (*SearchOneResponseWrapper) String 

func (m *SearchOneResponseWrapper) String() string

func (*SearchOneResponseWrapper) Validate 

func (this *SearchOneResponseWrapper) Validate() error

func (*SearchOneResponseWrapper) XXX_DiscardUnknown 

func (m *SearchOneResponseWrapper) XXX_DiscardUnknown()

func (*SearchOneResponseWrapper) XXX_Marshal 

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

func (*SearchOneResponseWrapper) XXX_Merge 

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

func (*SearchOneResponseWrapper) XXX_Size 

func (m *SearchOneResponseWrapper) XXX_Size() int

func (*SearchOneResponseWrapper) XXX_Unmarshal 

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

type SearchRequest 

type SearchRequest struct {
	//
	//表名
	Collection string `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection" form:"collection"`
	//
	//查询条件
	Query *types.Struct `protobuf:"bytes,2,opt,name=query,proto3" json:"query" form:"query"`
	//
	//fields
	Fields []string `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields" form:"fields"`
	//
	//sort
	Sort []string `protobuf:"bytes,4,rep,name=sort,proto3" json:"sort" form:"sort"`
	//
	//页码
	Page int32 `protobuf:"varint,5,opt,name=page,proto3" json:"page" form:"page"`
	//
	//页大小
	PageSize             int32    `protobuf:"varint,6,opt,name=pageSize,proto3" json:"pageSize" form:"pageSize"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Search请求

func (*SearchRequest) Descriptor 

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

func (*SearchRequest) GetCollection 

func (m *SearchRequest) GetCollection() string

func (*SearchRequest) GetFields 

func (m *SearchRequest) GetFields() []string

func (*SearchRequest) GetPage 

func (m *SearchRequest) GetPage() int32

func (*SearchRequest) GetPageSize 

func (m *SearchRequest) GetPageSize() int32

func (*SearchRequest) GetQuery 

func (m *SearchRequest) GetQuery() *types.Struct

func (*SearchRequest) GetSort 

func (m *SearchRequest) GetSort() []string

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) Reset 

func (m *SearchRequest) Reset()

func (*SearchRequest) String 

func (m *SearchRequest) String() string

func (*SearchRequest) Validate 

func (this *SearchRequest) Validate() error

func (*SearchRequest) XXX_DiscardUnknown 

func (m *SearchRequest) XXX_DiscardUnknown()

func (*SearchRequest) XXX_Marshal 

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

func (*SearchRequest) XXX_Merge 

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

func (*SearchRequest) XXX_Size 

func (m *SearchRequest) XXX_Size() int

func (*SearchRequest) XXX_Unmarshal 

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

type SearchResponse 

type SearchResponse struct {
	//
	//总数
	Total int32 `protobuf:"varint,1,opt,name=total,proto3" json:"total" form:"total"`
	//
	//记录列表
	List []*types.Struct `protobuf:"bytes,2,rep,name=list,proto3" json:"list" form:"list"`
	//
	//页码
	Page int32 `protobuf:"varint,3,opt,name=page,proto3" json:"page" form:"page"`
	//
	//页大小
	PageSize             int32    `protobuf:"varint,4,opt,name=pageSize,proto3" json:"pageSize" form:"pageSize"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Search返回

func (*SearchResponse) Descriptor 

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

func (*SearchResponse) GetList 

func (m *SearchResponse) GetList() []*types.Struct

func (*SearchResponse) GetPage 

func (m *SearchResponse) GetPage() int32

func (*SearchResponse) GetPageSize 

func (m *SearchResponse) GetPageSize() int32

func (*SearchResponse) GetTotal 

func (m *SearchResponse) GetTotal() int32

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) Reset 

func (m *SearchResponse) Reset()

func (*SearchResponse) String 

func (m *SearchResponse) String() string

func (*SearchResponse) Validate 

func (this *SearchResponse) Validate() error

func (*SearchResponse) XXX_DiscardUnknown 

func (m *SearchResponse) XXX_DiscardUnknown()

func (*SearchResponse) XXX_Marshal 

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

func (*SearchResponse) XXX_Merge 

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

func (*SearchResponse) XXX_Size 

func (m *SearchResponse) XXX_Size() int

func (*SearchResponse) XXX_Unmarshal 

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

type SearchResponseWrapper 

type SearchResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *SearchResponse `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

SearchApi返回

func (*SearchResponseWrapper) Descriptor 

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

func (*SearchResponseWrapper) GetCode 

func (m *SearchResponseWrapper) GetCode() int32

func (*SearchResponseWrapper) GetCodeExplain 

func (m *SearchResponseWrapper) GetCodeExplain() string

func (*SearchResponseWrapper) GetData 

func (m *SearchResponseWrapper) GetData() *SearchResponse

func (*SearchResponseWrapper) GetError 

func (m *SearchResponseWrapper) GetError() string

func (*SearchResponseWrapper) ProtoMessage 

func (*SearchResponseWrapper) ProtoMessage()

func (*SearchResponseWrapper) Reset 

func (m *SearchResponseWrapper) Reset()

func (*SearchResponseWrapper) String 

func (m *SearchResponseWrapper) String() string

func (*SearchResponseWrapper) Validate 

func (this *SearchResponseWrapper) Validate() error

func (*SearchResponseWrapper) XXX_DiscardUnknown 

func (m *SearchResponseWrapper) XXX_DiscardUnknown()

func (*SearchResponseWrapper) XXX_Marshal 

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

func (*SearchResponseWrapper) XXX_Merge 

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

func (*SearchResponseWrapper) XXX_Size 

func (m *SearchResponseWrapper) XXX_Size() int

func (*SearchResponseWrapper) XXX_Unmarshal 

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

type Service 

type Service interface {
	Insert(context.Context, *InsertRequest) (*types.Empty, error)
	Remove(context.Context, *RemoveRequest) (*types.Empty, error)
	RemoveAll(context.Context, *RemoveAllRequest) (*RemoveAllResponse, error)
	Search(context.Context, *SearchRequest) (*SearchResponse, error)
	SearchAll(context.Context, *SearchAllRequest) (*SearchAllResponse, error)
	SearchOne(context.Context, *SearchOneRequest) (*SearchOneResponse, error)
	Update(context.Context, *UpdateRequest) (*types.Empty, error)
	UpdateAll(context.Context, *UpdateAllRequest) (*UpdateAllResponse, error)
}

Service is the server API for mongo service.

type UpdateAllRequest 

type UpdateAllRequest struct {
	//
	//表名
	Collection string `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection" form:"collection"`
	//
	//更新条件
	Selector *types.Struct `protobuf:"bytes,2,opt,name=selector,proto3" json:"selector" form:"selector"`
	//
	//更新的值
	Update               *types.Struct `protobuf:"bytes,3,opt,name=update,proto3" json:"update" form:"update"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

UpdateAll请求

func (*UpdateAllRequest) Descriptor 

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

func (*UpdateAllRequest) GetCollection 

func (m *UpdateAllRequest) GetCollection() string

func (*UpdateAllRequest) GetSelector 

func (m *UpdateAllRequest) GetSelector() *types.Struct

func (*UpdateAllRequest) GetUpdate 

func (m *UpdateAllRequest) GetUpdate() *types.Struct

func (*UpdateAllRequest) ProtoMessage 

func (*UpdateAllRequest) ProtoMessage()

func (*UpdateAllRequest) Reset 

func (m *UpdateAllRequest) Reset()

func (*UpdateAllRequest) String 

func (m *UpdateAllRequest) String() string

func (*UpdateAllRequest) Validate 

func (this *UpdateAllRequest) Validate() error

func (*UpdateAllRequest) XXX_DiscardUnknown 

func (m *UpdateAllRequest) XXX_DiscardUnknown()

func (*UpdateAllRequest) XXX_Marshal 

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

func (*UpdateAllRequest) XXX_Merge 

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

func (*UpdateAllRequest) XXX_Size 

func (m *UpdateAllRequest) XXX_Size() int

func (*UpdateAllRequest) XXX_Unmarshal 

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

type UpdateAllResponse 

type UpdateAllResponse struct {
	//
	//更新总数
	Updated              int32    `protobuf:"varint,1,opt,name=updated,proto3" json:"updated" form:"updated"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

UpdateAll返回

func (*UpdateAllResponse) Descriptor 

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

func (*UpdateAllResponse) GetUpdated 

func (m *UpdateAllResponse) GetUpdated() int32

func (*UpdateAllResponse) ProtoMessage 

func (*UpdateAllResponse) ProtoMessage()

func (*UpdateAllResponse) Reset 

func (m *UpdateAllResponse) Reset()

func (*UpdateAllResponse) String 

func (m *UpdateAllResponse) String() string

func (*UpdateAllResponse) Validate 

func (this *UpdateAllResponse) Validate() error

func (*UpdateAllResponse) XXX_DiscardUnknown 

func (m *UpdateAllResponse) XXX_DiscardUnknown()

func (*UpdateAllResponse) XXX_Marshal 

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

func (*UpdateAllResponse) XXX_Merge 

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

func (*UpdateAllResponse) XXX_Size 

func (m *UpdateAllResponse) XXX_Size() int

func (*UpdateAllResponse) XXX_Unmarshal 

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

type UpdateAllResponseWrapper 

type UpdateAllResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *UpdateAllResponse `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

UpdateAllApi返回

func (*UpdateAllResponseWrapper) Descriptor 

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

func (*UpdateAllResponseWrapper) GetCode 

func (m *UpdateAllResponseWrapper) GetCode() int32

func (*UpdateAllResponseWrapper) GetCodeExplain 

func (m *UpdateAllResponseWrapper) GetCodeExplain() string

func (*UpdateAllResponseWrapper) GetData 

func (m *UpdateAllResponseWrapper) GetData() *UpdateAllResponse

func (*UpdateAllResponseWrapper) GetError 

func (m *UpdateAllResponseWrapper) GetError() string

func (*UpdateAllResponseWrapper) ProtoMessage 

func (*UpdateAllResponseWrapper) ProtoMessage()

func (*UpdateAllResponseWrapper) Reset 

func (m *UpdateAllResponseWrapper) Reset()

func (*UpdateAllResponseWrapper) String 

func (m *UpdateAllResponseWrapper) String() string

func (*UpdateAllResponseWrapper) Validate 

func (this *UpdateAllResponseWrapper) Validate() error

func (*UpdateAllResponseWrapper) XXX_DiscardUnknown 

func (m *UpdateAllResponseWrapper) XXX_DiscardUnknown()

func (*UpdateAllResponseWrapper) XXX_Marshal 

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

func (*UpdateAllResponseWrapper) XXX_Merge 

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

func (*UpdateAllResponseWrapper) XXX_Size 

func (m *UpdateAllResponseWrapper) XXX_Size() int

func (*UpdateAllResponseWrapper) XXX_Unmarshal 

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

type UpdateRequest 

type UpdateRequest struct {
	//
	//表名
	Collection string `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection" form:"collection"`
	//
	//更新条件
	Selector *types.Struct `protobuf:"bytes,2,opt,name=selector,proto3" json:"selector" form:"selector"`
	//
	//更新的值
	Update               *types.Struct `protobuf:"bytes,3,opt,name=update,proto3" json:"update" form:"update"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Update请求

func (*UpdateRequest) Descriptor 

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

func (*UpdateRequest) GetCollection 

func (m *UpdateRequest) GetCollection() string

func (*UpdateRequest) GetSelector 

func (m *UpdateRequest) GetSelector() *types.Struct

func (*UpdateRequest) GetUpdate 

func (m *UpdateRequest) GetUpdate() *types.Struct

func (*UpdateRequest) ProtoMessage 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) Reset 

func (m *UpdateRequest) Reset()

func (*UpdateRequest) String 

func (m *UpdateRequest) String() string

func (*UpdateRequest) Validate 

func (this *UpdateRequest) Validate() error

func (*UpdateRequest) XXX_DiscardUnknown 

func (m *UpdateRequest) XXX_DiscardUnknown()

func (*UpdateRequest) XXX_Marshal 

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

func (*UpdateRequest) XXX_Merge 

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

func (*UpdateRequest) XXX_Size 

func (m *UpdateRequest) XXX_Size() int

func (*UpdateRequest) XXX_Unmarshal 

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

type UpdateResponseWrapper 

type UpdateResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *types.Empty `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

UpdateApi返回

func (*UpdateResponseWrapper) Descriptor 

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

func (*UpdateResponseWrapper) GetCode 

func (m *UpdateResponseWrapper) GetCode() int32

func (*UpdateResponseWrapper) GetCodeExplain 

func (m *UpdateResponseWrapper) GetCodeExplain() string

func (*UpdateResponseWrapper) GetData 

func (m *UpdateResponseWrapper) GetData() *types.Empty

func (*UpdateResponseWrapper) GetError 

func (m *UpdateResponseWrapper) GetError() string

func (*UpdateResponseWrapper) ProtoMessage 

func (*UpdateResponseWrapper) ProtoMessage()

func (*UpdateResponseWrapper) Reset 

func (m *UpdateResponseWrapper) Reset()

func (*UpdateResponseWrapper) String 

func (m *UpdateResponseWrapper) String() string

func (*UpdateResponseWrapper) Validate 

func (this *UpdateResponseWrapper) Validate() error

func (*UpdateResponseWrapper) XXX_DiscardUnknown 

func (m *UpdateResponseWrapper) XXX_DiscardUnknown()

func (*UpdateResponseWrapper) XXX_Marshal 

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

func (*UpdateResponseWrapper) XXX_Merge 

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

func (*UpdateResponseWrapper) XXX_Size 

func (m *UpdateResponseWrapper) XXX_Size() int

func (*UpdateResponseWrapper) XXX_Unmarshal 

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