v1

package
v0.0.0-...-83adff0 Latest Latest
Warning

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

Go to latest
Published: Jul 6, 2020 License: GPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterRecsysRecallServer

func RegisterRecsysRecallServer(s *grpc.Server, srv RecsysRecallServer)

Types

type InvertedIndex

type InvertedIndex struct {
	Index                string   `protobuf:"bytes,1,opt,name=index,proto3" json:"index" form:"index"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name" form:"name"`
	Score                float32  `protobuf:"fixed32,3,opt,name=score,proto3" json:"score" form:"score"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InvertedIndex) Descriptor

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

func (*InvertedIndex) Marshal

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

func (*InvertedIndex) MarshalTo

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

func (*InvertedIndex) ProtoMessage

func (*InvertedIndex) ProtoMessage()

func (*InvertedIndex) Reset

func (m *InvertedIndex) Reset()

func (*InvertedIndex) Size

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

func (*InvertedIndex) String

func (this *InvertedIndex) String() string

func (*InvertedIndex) Unmarshal

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

func (*InvertedIndex) XXX_DiscardUnknown

func (m *InvertedIndex) XXX_DiscardUnknown()

func (*InvertedIndex) XXX_Marshal

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

func (*InvertedIndex) XXX_Merge

func (dst *InvertedIndex) XXX_Merge(src proto.Message)

func (*InvertedIndex) XXX_Size

func (m *InvertedIndex) XXX_Size() int

func (*InvertedIndex) XXX_Unmarshal

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

type NewIncomeVideoRequest

type NewIncomeVideoRequest struct {
	SVIDs                []int64  `protobuf:"varint,1,rep,packed,name=svids" json:"svids" form:"svids"`
	Key                  string   `protobuf:"bytes,2,opt,name=key,proto3" json:"key" form:"key"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewIncomeVideoRequest) Descriptor

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

func (*NewIncomeVideoRequest) Marshal

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

func (*NewIncomeVideoRequest) MarshalTo

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

func (*NewIncomeVideoRequest) ProtoMessage

func (*NewIncomeVideoRequest) ProtoMessage()

func (*NewIncomeVideoRequest) Reset

func (m *NewIncomeVideoRequest) Reset()

func (*NewIncomeVideoRequest) Size

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

func (*NewIncomeVideoRequest) String

func (this *NewIncomeVideoRequest) String() string

func (*NewIncomeVideoRequest) Unmarshal

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

func (*NewIncomeVideoRequest) XXX_DiscardUnknown

func (m *NewIncomeVideoRequest) XXX_DiscardUnknown()

func (*NewIncomeVideoRequest) XXX_Marshal

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

func (*NewIncomeVideoRequest) XXX_Merge

func (dst *NewIncomeVideoRequest) XXX_Merge(src proto.Message)

func (*NewIncomeVideoRequest) XXX_Size

func (m *NewIncomeVideoRequest) XXX_Size() int

func (*NewIncomeVideoRequest) XXX_Unmarshal

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

type RecallInfo

type RecallInfo struct {
	Tag                  string   `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag" form:"tag"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name" form:"name"`
	Scorer               string   `protobuf:"bytes,3,opt,name=scorer,proto3" json:"scorer" form:"scorer"`
	Filter               string   `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter" form:"filter"`
	Ranker               string   `protobuf:"bytes,5,opt,name=ranker,proto3" json:"ranker" form:"ranker"`
	Priority             int32    `protobuf:"varint,6,opt,name=priority,proto3" json:"priority" form:"priority"`
	Limit                int32    `protobuf:"varint,7,opt,name=limit,proto3" json:"limit" form:"limit"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RecallInfo) Descriptor

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

func (*RecallInfo) Marshal

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

func (*RecallInfo) MarshalTo

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

func (*RecallInfo) ProtoMessage

func (*RecallInfo) ProtoMessage()

func (*RecallInfo) Reset

func (m *RecallInfo) Reset()

func (*RecallInfo) Size

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

func (*RecallInfo) String

func (this *RecallInfo) String() string

func (*RecallInfo) Unmarshal

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

func (*RecallInfo) XXX_DiscardUnknown

func (m *RecallInfo) XXX_DiscardUnknown()

func (*RecallInfo) XXX_Marshal

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

func (*RecallInfo) XXX_Merge

func (dst *RecallInfo) XXX_Merge(src proto.Message)

func (*RecallInfo) XXX_Size

func (m *RecallInfo) XXX_Size() int

func (*RecallInfo) XXX_Unmarshal

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

type RecallRequest

type RecallRequest struct {
	MID                  int64         `protobuf:"varint,1,opt,name=mid,proto3" json:"mid" form:"mid"`
	BUVID                string        `protobuf:"bytes,2,opt,name=buvid,proto3" json:"buvid" form:"buvid"`
	Infos                []*RecallInfo `protobuf:"bytes,3,rep,name=info" json:"infos" form:"infos"`
	TotalLimit           int32         `protobuf:"varint,4,opt,name=total_limit,json=totalLimit,proto3" json:"total_limit" form:"total_limit"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*RecallRequest) Descriptor

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

func (*RecallRequest) Marshal

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

func (*RecallRequest) MarshalTo

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

func (*RecallRequest) ProtoMessage

func (*RecallRequest) ProtoMessage()

func (*RecallRequest) Reset

func (m *RecallRequest) Reset()

func (*RecallRequest) Size

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

func (*RecallRequest) String

func (this *RecallRequest) String() string

func (*RecallRequest) Unmarshal

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

func (*RecallRequest) XXX_DiscardUnknown

func (m *RecallRequest) XXX_DiscardUnknown()

func (*RecallRequest) XXX_Marshal

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

func (*RecallRequest) XXX_Merge

func (dst *RecallRequest) XXX_Merge(src proto.Message)

func (*RecallRequest) XXX_Size

func (m *RecallRequest) XXX_Size() int

func (*RecallRequest) XXX_Unmarshal

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

type RecallResponse

type RecallResponse struct {
	Total                int32        `protobuf:"varint,1,opt,name=total,proto3" json:"total" form:"total"`
	List                 []*Video     `protobuf:"bytes,2,rep,name=list" json:"list" form:"list"`
	SrcInfo              []*RecallSrc `protobuf:"bytes,3,rep,name=src_info,json=srcInfo" json:"src_info" form:"src_info"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*RecallResponse) Descriptor

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

func (*RecallResponse) Marshal

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

func (*RecallResponse) MarshalTo

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

func (*RecallResponse) ProtoMessage

func (*RecallResponse) ProtoMessage()

func (*RecallResponse) Reset

func (m *RecallResponse) Reset()

func (*RecallResponse) Size

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

func (*RecallResponse) String

func (this *RecallResponse) String() string

func (*RecallResponse) Unmarshal

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

func (*RecallResponse) XXX_DiscardUnknown

func (m *RecallResponse) XXX_DiscardUnknown()

func (*RecallResponse) XXX_Marshal

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

func (*RecallResponse) XXX_Merge

func (dst *RecallResponse) XXX_Merge(src proto.Message)

func (*RecallResponse) XXX_Size

func (m *RecallResponse) XXX_Size() int

func (*RecallResponse) XXX_Unmarshal

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

type RecallSrc

type RecallSrc struct {
	TotalHit             int32    `protobuf:"varint,1,opt,name=total_hit,json=totalHit,proto3" json:"total_hit" form:"total_hit"`
	Filter               int32    `protobuf:"varint,2,opt,name=filter,proto3" json:"filter" form:"filter"`
	Final                int32    `protobuf:"varint,3,opt,name=final,proto3" json:"final" form:"final"`
	Tag                  string   `protobuf:"bytes,4,opt,name=tag,proto3" json:"tag" form:"tag"`
	Name                 string   `protobuf:"bytes,5,opt,name=name,proto3" json:"name" form:"name"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RecallSrc) Descriptor

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

func (*RecallSrc) Marshal

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

func (*RecallSrc) MarshalTo

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

func (*RecallSrc) ProtoMessage

func (*RecallSrc) ProtoMessage()

func (*RecallSrc) Reset

func (m *RecallSrc) Reset()

func (*RecallSrc) Size

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

func (*RecallSrc) String

func (this *RecallSrc) String() string

func (*RecallSrc) Unmarshal

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

func (*RecallSrc) XXX_DiscardUnknown

func (m *RecallSrc) XXX_DiscardUnknown()

func (*RecallSrc) XXX_Marshal

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

func (*RecallSrc) XXX_Merge

func (dst *RecallSrc) XXX_Merge(src proto.Message)

func (*RecallSrc) XXX_Size

func (m *RecallSrc) XXX_Size() int

func (*RecallSrc) XXX_Unmarshal

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

type RecsysRecallClient

type RecsysRecallClient interface {
	Recall(ctx context.Context, in *RecallRequest, opts ...grpc.CallOption) (*RecallResponse, error)
	VideoIndex(ctx context.Context, in *VideoIndexRequest, opts ...grpc.CallOption) (*VideoIndexResponse, error)
	NewIncomeVideo(ctx context.Context, in *NewIncomeVideoRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	VideosByIndex(ctx context.Context, in *VideosByIndexRequest, opts ...grpc.CallOption) (*VideosByIndexResponse, error)
}

RecsysRecallClient is the client API for RecsysRecall service.

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

func NewRecsysRecallClient

func NewRecsysRecallClient(cc *grpc.ClientConn) RecsysRecallClient

type RecsysRecallServer

RecsysRecallServer is the server API for RecsysRecall service.

type Video

type Video struct {
	SVID                 int64                `protobuf:"varint,1,opt,name=svid,proto3" json:"svid" form:"svid"`
	Score                float32              `protobuf:"fixed32,2,opt,name=score,proto3" json:"score" form:"score"`
	Name                 string               `protobuf:"bytes,3,opt,name=name,proto3" json:"name" form:"name"`
	ForwardIndex         *proto1.ForwardIndex `protobuf:"bytes,4,opt,name=forward_index,json=forwardIndex" json:"forward_index" form:"forward_index"`
	InvertedIndex        string               `protobuf:"bytes,5,opt,name=inverted_index,json=invertedIndex,proto3" json:"inverted_index" form:"inverted_index"`
	InvertedIndexes      []*InvertedIndex     `protobuf:"bytes,6,rep,name=indexes" json:"inverted_indexes" form:"inverted_indexes"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Video) Descriptor

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

func (*Video) Marshal

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

func (*Video) MarshalTo

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

func (*Video) ProtoMessage

func (*Video) ProtoMessage()

func (*Video) Reset

func (m *Video) Reset()

func (*Video) Size

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

func (*Video) String

func (this *Video) String() string

func (*Video) Unmarshal

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

func (*Video) XXX_DiscardUnknown

func (m *Video) XXX_DiscardUnknown()

func (*Video) XXX_Marshal

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

func (*Video) XXX_Merge

func (dst *Video) XXX_Merge(src proto.Message)

func (*Video) XXX_Size

func (m *Video) XXX_Size() int

func (*Video) XXX_Unmarshal

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

type VideoIndexRequest

type VideoIndexRequest struct {
	SVIDs                []int64  `protobuf:"varint,1,rep,packed,name=svids" json:"svids" form:"svids"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VideoIndexRequest) Descriptor

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

func (*VideoIndexRequest) Marshal

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

func (*VideoIndexRequest) MarshalTo

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

func (*VideoIndexRequest) ProtoMessage

func (*VideoIndexRequest) ProtoMessage()

func (*VideoIndexRequest) Reset

func (m *VideoIndexRequest) Reset()

func (*VideoIndexRequest) Size

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

func (*VideoIndexRequest) String

func (this *VideoIndexRequest) String() string

func (*VideoIndexRequest) Unmarshal

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

func (*VideoIndexRequest) XXX_DiscardUnknown

func (m *VideoIndexRequest) XXX_DiscardUnknown()

func (*VideoIndexRequest) XXX_Marshal

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

func (*VideoIndexRequest) XXX_Merge

func (dst *VideoIndexRequest) XXX_Merge(src proto.Message)

func (*VideoIndexRequest) XXX_Size

func (m *VideoIndexRequest) XXX_Size() int

func (*VideoIndexRequest) XXX_Unmarshal

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

type VideoIndexResponse

type VideoIndexResponse struct {
	List                 []*proto1.ForwardIndex `protobuf:"bytes,1,rep,name=list" json:"list" form:"list"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*VideoIndexResponse) Descriptor

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

func (*VideoIndexResponse) Marshal

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

func (*VideoIndexResponse) MarshalTo

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

func (*VideoIndexResponse) ProtoMessage

func (*VideoIndexResponse) ProtoMessage()

func (*VideoIndexResponse) Reset

func (m *VideoIndexResponse) Reset()

func (*VideoIndexResponse) Size

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

func (*VideoIndexResponse) String

func (this *VideoIndexResponse) String() string

func (*VideoIndexResponse) Unmarshal

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

func (*VideoIndexResponse) XXX_DiscardUnknown

func (m *VideoIndexResponse) XXX_DiscardUnknown()

func (*VideoIndexResponse) XXX_Marshal

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

func (*VideoIndexResponse) XXX_Merge

func (dst *VideoIndexResponse) XXX_Merge(src proto.Message)

func (*VideoIndexResponse) XXX_Size

func (m *VideoIndexResponse) XXX_Size() int

func (*VideoIndexResponse) XXX_Unmarshal

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

type VideosByIndexRequest

type VideosByIndexRequest struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key" form:"key"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VideosByIndexRequest) Descriptor

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

func (*VideosByIndexRequest) Marshal

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

func (*VideosByIndexRequest) MarshalTo

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

func (*VideosByIndexRequest) ProtoMessage

func (*VideosByIndexRequest) ProtoMessage()

func (*VideosByIndexRequest) Reset

func (m *VideosByIndexRequest) Reset()

func (*VideosByIndexRequest) Size

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

func (*VideosByIndexRequest) String

func (this *VideosByIndexRequest) String() string

func (*VideosByIndexRequest) Unmarshal

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

func (*VideosByIndexRequest) XXX_DiscardUnknown

func (m *VideosByIndexRequest) XXX_DiscardUnknown()

func (*VideosByIndexRequest) XXX_Marshal

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

func (*VideosByIndexRequest) XXX_Merge

func (dst *VideosByIndexRequest) XXX_Merge(src proto.Message)

func (*VideosByIndexRequest) XXX_Size

func (m *VideosByIndexRequest) XXX_Size() int

func (*VideosByIndexRequest) XXX_Unmarshal

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

type VideosByIndexResponse

type VideosByIndexResponse struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key" form:"key"`
	SVIDs                []int64  `protobuf:"varint,2,rep,packed,name=svids" json:"svids" form:"svids"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VideosByIndexResponse) Descriptor

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

func (*VideosByIndexResponse) Marshal

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

func (*VideosByIndexResponse) MarshalTo

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

func (*VideosByIndexResponse) ProtoMessage

func (*VideosByIndexResponse) ProtoMessage()

func (*VideosByIndexResponse) Reset

func (m *VideosByIndexResponse) Reset()

func (*VideosByIndexResponse) Size

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

func (*VideosByIndexResponse) String

func (this *VideosByIndexResponse) String() string

func (*VideosByIndexResponse) Unmarshal

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

func (*VideosByIndexResponse) XXX_DiscardUnknown

func (m *VideosByIndexResponse) XXX_DiscardUnknown()

func (*VideosByIndexResponse) XXX_Marshal

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

func (*VideosByIndexResponse) XXX_Merge

func (dst *VideosByIndexResponse) XXX_Merge(src proto.Message)

func (*VideosByIndexResponse) XXX_Size

func (m *VideosByIndexResponse) XXX_Size() int

func (*VideosByIndexResponse) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL