Documentation ¶
Overview ¶
Package v1 is a generated protocol buffer package.
It is generated from these files:
api.proto
It has these top-level messages:
AddHistoryReply AddHistoryReq ClearHistoryReply ClearHistoryReq DeleteReply DeleteReq FlushHistoryReply FlushHistoryReq HistoriesReply HistoriesReq HistoryCursorReply HistoryCursorReq ModelHistory ModelResource PositionReply PositionReq ProgressReply ProgressReq
Index ¶
- Variables
- func RegisterHistoryServer(s *grpc.Server, srv HistoryServer)
- type AddHistoryReply
- func (*AddHistoryReply) Descriptor() ([]byte, []int)
- func (m *AddHistoryReply) Marshal() (dAtA []byte, err error)
- func (m *AddHistoryReply) MarshalTo(dAtA []byte) (int, error)
- func (*AddHistoryReply) ProtoMessage()
- func (m *AddHistoryReply) Reset()
- func (m *AddHistoryReply) Size() (n int)
- func (m *AddHistoryReply) String() string
- func (m *AddHistoryReply) Unmarshal(dAtA []byte) error
- type AddHistoryReq
- func (*AddHistoryReq) Descriptor() ([]byte, []int)
- func (m *AddHistoryReq) GetH() *ModelHistory
- func (m *AddHistoryReq) GetMid() int64
- func (m *AddHistoryReq) GetRtime() int64
- func (m *AddHistoryReq) Marshal() (dAtA []byte, err error)
- func (m *AddHistoryReq) MarshalTo(dAtA []byte) (int, error)
- func (*AddHistoryReq) ProtoMessage()
- func (m *AddHistoryReq) Reset()
- func (m *AddHistoryReq) Size() (n int)
- func (m *AddHistoryReq) String() string
- func (m *AddHistoryReq) Unmarshal(dAtA []byte) error
- type ClearHistoryReply
- func (*ClearHistoryReply) Descriptor() ([]byte, []int)
- func (m *ClearHistoryReply) Marshal() (dAtA []byte, err error)
- func (m *ClearHistoryReply) MarshalTo(dAtA []byte) (int, error)
- func (*ClearHistoryReply) ProtoMessage()
- func (m *ClearHistoryReply) Reset()
- func (m *ClearHistoryReply) Size() (n int)
- func (m *ClearHistoryReply) String() string
- func (m *ClearHistoryReply) Unmarshal(dAtA []byte) error
- type ClearHistoryReq
- func (*ClearHistoryReq) Descriptor() ([]byte, []int)
- func (m *ClearHistoryReq) GetBusinesses() []string
- func (m *ClearHistoryReq) GetMid() int64
- func (m *ClearHistoryReq) Marshal() (dAtA []byte, err error)
- func (m *ClearHistoryReq) MarshalTo(dAtA []byte) (int, error)
- func (*ClearHistoryReq) ProtoMessage()
- func (m *ClearHistoryReq) Reset()
- func (m *ClearHistoryReq) Size() (n int)
- func (m *ClearHistoryReq) String() string
- func (m *ClearHistoryReq) Unmarshal(dAtA []byte) error
- type DeleteReply
- func (*DeleteReply) Descriptor() ([]byte, []int)
- func (m *DeleteReply) Marshal() (dAtA []byte, err error)
- func (m *DeleteReply) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteReply) ProtoMessage()
- func (m *DeleteReply) Reset()
- func (m *DeleteReply) Size() (n int)
- func (m *DeleteReply) String() string
- func (m *DeleteReply) Unmarshal(dAtA []byte) error
- type DeleteReq
- func (*DeleteReq) Descriptor() ([]byte, []int)
- func (m *DeleteReq) GetHis() []*ModelHistory
- func (m *DeleteReq) GetMid() int64
- func (m *DeleteReq) Marshal() (dAtA []byte, err error)
- func (m *DeleteReq) MarshalTo(dAtA []byte) (int, error)
- func (*DeleteReq) ProtoMessage()
- func (m *DeleteReq) Reset()
- func (m *DeleteReq) Size() (n int)
- func (m *DeleteReq) String() string
- func (m *DeleteReq) Unmarshal(dAtA []byte) error
- type FlushHistoryReply
- func (*FlushHistoryReply) Descriptor() ([]byte, []int)
- func (m *FlushHistoryReply) Marshal() (dAtA []byte, err error)
- func (m *FlushHistoryReply) MarshalTo(dAtA []byte) (int, error)
- func (*FlushHistoryReply) ProtoMessage()
- func (m *FlushHistoryReply) Reset()
- func (m *FlushHistoryReply) Size() (n int)
- func (m *FlushHistoryReply) String() string
- func (m *FlushHistoryReply) Unmarshal(dAtA []byte) error
- type FlushHistoryReq
- func (*FlushHistoryReq) Descriptor() ([]byte, []int)
- func (m *FlushHistoryReq) GetMids() []int64
- func (m *FlushHistoryReq) GetStime() int64
- func (m *FlushHistoryReq) Marshal() (dAtA []byte, err error)
- func (m *FlushHistoryReq) MarshalTo(dAtA []byte) (int, error)
- func (*FlushHistoryReq) ProtoMessage()
- func (m *FlushHistoryReq) Reset()
- func (m *FlushHistoryReq) Size() (n int)
- func (m *FlushHistoryReq) String() string
- func (m *FlushHistoryReq) Unmarshal(dAtA []byte) error
- type HistoriesReply
- func (*HistoriesReply) Descriptor() ([]byte, []int)
- func (m *HistoriesReply) GetRes() []*ModelResource
- func (m *HistoriesReply) Marshal() (dAtA []byte, err error)
- func (m *HistoriesReply) MarshalTo(dAtA []byte) (int, error)
- func (*HistoriesReply) ProtoMessage()
- func (m *HistoriesReply) Reset()
- func (m *HistoriesReply) Size() (n int)
- func (m *HistoriesReply) String() string
- func (m *HistoriesReply) Unmarshal(dAtA []byte) error
- type HistoriesReq
- func (*HistoriesReq) Descriptor() ([]byte, []int)
- func (m *HistoriesReq) GetBusiness() string
- func (m *HistoriesReq) GetMid() int64
- func (m *HistoriesReq) GetPn() int32
- func (m *HistoriesReq) GetPs() int32
- func (m *HistoriesReq) Marshal() (dAtA []byte, err error)
- func (m *HistoriesReq) MarshalTo(dAtA []byte) (int, error)
- func (*HistoriesReq) ProtoMessage()
- func (m *HistoriesReq) Reset()
- func (m *HistoriesReq) Size() (n int)
- func (m *HistoriesReq) String() string
- func (m *HistoriesReq) Unmarshal(dAtA []byte) error
- type HistoryClient
- type HistoryCursorReply
- func (*HistoryCursorReply) Descriptor() ([]byte, []int)
- func (m *HistoryCursorReply) GetRes() []*ModelResource
- func (m *HistoryCursorReply) Marshal() (dAtA []byte, err error)
- func (m *HistoryCursorReply) MarshalTo(dAtA []byte) (int, error)
- func (*HistoryCursorReply) ProtoMessage()
- func (m *HistoryCursorReply) Reset()
- func (m *HistoryCursorReply) Size() (n int)
- func (m *HistoryCursorReply) String() string
- func (m *HistoryCursorReply) Unmarshal(dAtA []byte) error
- type HistoryCursorReq
- func (*HistoryCursorReq) Descriptor() ([]byte, []int)
- func (m *HistoryCursorReq) GetBusiness() string
- func (m *HistoryCursorReq) GetBusinesses() []string
- func (m *HistoryCursorReq) GetIp() string
- func (m *HistoryCursorReq) GetMax() int64
- func (m *HistoryCursorReq) GetMid() int64
- func (m *HistoryCursorReq) GetPs() int32
- func (m *HistoryCursorReq) GetViewAt() int64
- func (m *HistoryCursorReq) Marshal() (dAtA []byte, err error)
- func (m *HistoryCursorReq) MarshalTo(dAtA []byte) (int, error)
- func (*HistoryCursorReq) ProtoMessage()
- func (m *HistoryCursorReq) Reset()
- func (m *HistoryCursorReq) Size() (n int)
- func (m *HistoryCursorReq) String() string
- func (m *HistoryCursorReq) Unmarshal(dAtA []byte) error
- type HistoryServer
- type ModelHistory
- func (*ModelHistory) Descriptor() ([]byte, []int)
- func (m *ModelHistory) GetAid() int64
- func (m *ModelHistory) GetBusiness() string
- func (m *ModelHistory) GetCid() int64
- func (m *ModelHistory) GetDt() int32
- func (m *ModelHistory) GetEpid() int64
- func (m *ModelHistory) GetMid() int64
- func (m *ModelHistory) GetPro() int64
- func (m *ModelHistory) GetSid() int64
- func (m *ModelHistory) GetStp() int32
- func (m *ModelHistory) GetTp() int32
- func (m *ModelHistory) GetUnix() int64
- func (m *ModelHistory) Marshal() (dAtA []byte, err error)
- func (m *ModelHistory) MarshalTo(dAtA []byte) (int, error)
- func (*ModelHistory) ProtoMessage()
- func (m *ModelHistory) Reset()
- func (m *ModelHistory) Size() (n int)
- func (m *ModelHistory) String() string
- func (m *ModelHistory) Unmarshal(dAtA []byte) error
- type ModelResource
- func (*ModelResource) Descriptor() ([]byte, []int)
- func (m *ModelResource) GetBusiness() string
- func (m *ModelResource) GetCid() int64
- func (m *ModelResource) GetDt() int32
- func (m *ModelResource) GetEpid() int64
- func (m *ModelResource) GetMid() int64
- func (m *ModelResource) GetOid() int64
- func (m *ModelResource) GetPro() int64
- func (m *ModelResource) GetSid() int64
- func (m *ModelResource) GetStp() int32
- func (m *ModelResource) GetTp() int32
- func (m *ModelResource) GetUnix() int64
- func (m *ModelResource) Marshal() (dAtA []byte, err error)
- func (m *ModelResource) MarshalTo(dAtA []byte) (int, error)
- func (*ModelResource) ProtoMessage()
- func (m *ModelResource) Reset()
- func (m *ModelResource) Size() (n int)
- func (m *ModelResource) String() string
- func (m *ModelResource) Unmarshal(dAtA []byte) error
- type PositionReply
- func (*PositionReply) Descriptor() ([]byte, []int)
- func (m *PositionReply) GetRes() *ModelHistory
- func (m *PositionReply) Marshal() (dAtA []byte, err error)
- func (m *PositionReply) MarshalTo(dAtA []byte) (int, error)
- func (*PositionReply) ProtoMessage()
- func (m *PositionReply) Reset()
- func (m *PositionReply) Size() (n int)
- func (m *PositionReply) String() string
- func (m *PositionReply) Unmarshal(dAtA []byte) error
- type PositionReq
- func (*PositionReq) Descriptor() ([]byte, []int)
- func (m *PositionReq) GetAid() int64
- func (m *PositionReq) GetBusiness() string
- func (m *PositionReq) GetMid() int64
- func (m *PositionReq) Marshal() (dAtA []byte, err error)
- func (m *PositionReq) MarshalTo(dAtA []byte) (int, error)
- func (*PositionReq) ProtoMessage()
- func (m *PositionReq) Reset()
- func (m *PositionReq) Size() (n int)
- func (m *PositionReq) String() string
- func (m *PositionReq) Unmarshal(dAtA []byte) error
- type ProgressReply
- func (*ProgressReply) Descriptor() ([]byte, []int)
- func (m *ProgressReply) GetRes() map[int64]*ModelHistory
- func (m *ProgressReply) Marshal() (dAtA []byte, err error)
- func (m *ProgressReply) MarshalTo(dAtA []byte) (int, error)
- func (*ProgressReply) ProtoMessage()
- func (m *ProgressReply) Reset()
- func (m *ProgressReply) Size() (n int)
- func (m *ProgressReply) String() string
- func (m *ProgressReply) Unmarshal(dAtA []byte) error
- type ProgressReq
- func (*ProgressReq) Descriptor() ([]byte, []int)
- func (m *ProgressReq) GetAids() []int64
- func (m *ProgressReq) GetMid() int64
- func (m *ProgressReq) Marshal() (dAtA []byte, err error)
- func (m *ProgressReq) MarshalTo(dAtA []byte) (int, error)
- func (*ProgressReq) ProtoMessage()
- func (m *ProgressReq) Reset()
- func (m *ProgressReq) Size() (n int)
- func (m *ProgressReq) String() string
- func (m *ProgressReq) Unmarshal(dAtA []byte) error
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 RegisterHistoryServer ¶
func RegisterHistoryServer(s *grpc.Server, srv HistoryServer)
Types ¶
type AddHistoryReply ¶
type AddHistoryReply struct { }
func (*AddHistoryReply) Descriptor ¶
func (*AddHistoryReply) Descriptor() ([]byte, []int)
func (*AddHistoryReply) Marshal ¶
func (m *AddHistoryReply) Marshal() (dAtA []byte, err error)
func (*AddHistoryReply) ProtoMessage ¶
func (*AddHistoryReply) ProtoMessage()
func (*AddHistoryReply) Reset ¶
func (m *AddHistoryReply) Reset()
func (*AddHistoryReply) Size ¶
func (m *AddHistoryReply) Size() (n int)
func (*AddHistoryReply) String ¶
func (m *AddHistoryReply) String() string
func (*AddHistoryReply) Unmarshal ¶
func (m *AddHistoryReply) Unmarshal(dAtA []byte) error
type AddHistoryReq ¶
type AddHistoryReq struct { Mid int64 `protobuf:"varint,2,opt,name=mid,proto3" json:"mid,omitempty"` Rtime int64 `protobuf:"varint,3,opt,name=rtime,proto3" json:"rtime,omitempty"` H *ModelHistory `protobuf:"bytes,4,opt,name=h" json:"h,omitempty"` }
func (*AddHistoryReq) Descriptor ¶
func (*AddHistoryReq) Descriptor() ([]byte, []int)
func (*AddHistoryReq) GetH ¶
func (m *AddHistoryReq) GetH() *ModelHistory
func (*AddHistoryReq) GetMid ¶
func (m *AddHistoryReq) GetMid() int64
func (*AddHistoryReq) GetRtime ¶
func (m *AddHistoryReq) GetRtime() int64
func (*AddHistoryReq) Marshal ¶
func (m *AddHistoryReq) Marshal() (dAtA []byte, err error)
func (*AddHistoryReq) ProtoMessage ¶
func (*AddHistoryReq) ProtoMessage()
func (*AddHistoryReq) Reset ¶
func (m *AddHistoryReq) Reset()
func (*AddHistoryReq) Size ¶
func (m *AddHistoryReq) Size() (n int)
func (*AddHistoryReq) String ¶
func (m *AddHistoryReq) String() string
func (*AddHistoryReq) Unmarshal ¶
func (m *AddHistoryReq) Unmarshal(dAtA []byte) error
type ClearHistoryReply ¶
type ClearHistoryReply struct { }
func (*ClearHistoryReply) Descriptor ¶
func (*ClearHistoryReply) Descriptor() ([]byte, []int)
func (*ClearHistoryReply) Marshal ¶
func (m *ClearHistoryReply) Marshal() (dAtA []byte, err error)
func (*ClearHistoryReply) MarshalTo ¶
func (m *ClearHistoryReply) MarshalTo(dAtA []byte) (int, error)
func (*ClearHistoryReply) ProtoMessage ¶
func (*ClearHistoryReply) ProtoMessage()
func (*ClearHistoryReply) Reset ¶
func (m *ClearHistoryReply) Reset()
func (*ClearHistoryReply) Size ¶
func (m *ClearHistoryReply) Size() (n int)
func (*ClearHistoryReply) String ¶
func (m *ClearHistoryReply) String() string
func (*ClearHistoryReply) Unmarshal ¶
func (m *ClearHistoryReply) Unmarshal(dAtA []byte) error
type ClearHistoryReq ¶
type ClearHistoryReq struct { Mid int64 `protobuf:"varint,2,opt,name=mid,proto3" json:"mid,omitempty"` Businesses []string `protobuf:"bytes,3,rep,name=businesses" json:"businesses,omitempty"` }
func (*ClearHistoryReq) Descriptor ¶
func (*ClearHistoryReq) Descriptor() ([]byte, []int)
func (*ClearHistoryReq) GetBusinesses ¶
func (m *ClearHistoryReq) GetBusinesses() []string
func (*ClearHistoryReq) GetMid ¶
func (m *ClearHistoryReq) GetMid() int64
func (*ClearHistoryReq) Marshal ¶
func (m *ClearHistoryReq) Marshal() (dAtA []byte, err error)
func (*ClearHistoryReq) ProtoMessage ¶
func (*ClearHistoryReq) ProtoMessage()
func (*ClearHistoryReq) Reset ¶
func (m *ClearHistoryReq) Reset()
func (*ClearHistoryReq) Size ¶
func (m *ClearHistoryReq) Size() (n int)
func (*ClearHistoryReq) String ¶
func (m *ClearHistoryReq) String() string
func (*ClearHistoryReq) Unmarshal ¶
func (m *ClearHistoryReq) Unmarshal(dAtA []byte) error
type DeleteReply ¶
type DeleteReply struct { }
func (*DeleteReply) Descriptor ¶
func (*DeleteReply) Descriptor() ([]byte, []int)
func (*DeleteReply) Marshal ¶
func (m *DeleteReply) Marshal() (dAtA []byte, err error)
func (*DeleteReply) ProtoMessage ¶
func (*DeleteReply) ProtoMessage()
func (*DeleteReply) Reset ¶
func (m *DeleteReply) Reset()
func (*DeleteReply) Size ¶
func (m *DeleteReply) Size() (n int)
func (*DeleteReply) String ¶
func (m *DeleteReply) String() string
func (*DeleteReply) Unmarshal ¶
func (m *DeleteReply) Unmarshal(dAtA []byte) error
type DeleteReq ¶
type DeleteReq struct { Mid int64 `protobuf:"varint,2,opt,name=mid,proto3" json:"mid,omitempty"` His []*ModelHistory `protobuf:"bytes,3,rep,name=his" json:"his,omitempty"` }
func (*DeleteReq) Descriptor ¶
func (*DeleteReq) GetHis ¶
func (m *DeleteReq) GetHis() []*ModelHistory
func (*DeleteReq) ProtoMessage ¶
func (*DeleteReq) ProtoMessage()
type FlushHistoryReply ¶
type FlushHistoryReply struct { }
func (*FlushHistoryReply) Descriptor ¶
func (*FlushHistoryReply) Descriptor() ([]byte, []int)
func (*FlushHistoryReply) Marshal ¶
func (m *FlushHistoryReply) Marshal() (dAtA []byte, err error)
func (*FlushHistoryReply) MarshalTo ¶
func (m *FlushHistoryReply) MarshalTo(dAtA []byte) (int, error)
func (*FlushHistoryReply) ProtoMessage ¶
func (*FlushHistoryReply) ProtoMessage()
func (*FlushHistoryReply) Reset ¶
func (m *FlushHistoryReply) Reset()
func (*FlushHistoryReply) Size ¶
func (m *FlushHistoryReply) Size() (n int)
func (*FlushHistoryReply) String ¶
func (m *FlushHistoryReply) String() string
func (*FlushHistoryReply) Unmarshal ¶
func (m *FlushHistoryReply) Unmarshal(dAtA []byte) error
type FlushHistoryReq ¶
type FlushHistoryReq struct { Mids []int64 `protobuf:"varint,2,rep,packed,name=mids" json:"mids,omitempty"` Stime int64 `protobuf:"varint,3,opt,name=stime,proto3" json:"stime,omitempty"` }
func (*FlushHistoryReq) Descriptor ¶
func (*FlushHistoryReq) Descriptor() ([]byte, []int)
func (*FlushHistoryReq) GetMids ¶
func (m *FlushHistoryReq) GetMids() []int64
func (*FlushHistoryReq) GetStime ¶
func (m *FlushHistoryReq) GetStime() int64
func (*FlushHistoryReq) Marshal ¶
func (m *FlushHistoryReq) Marshal() (dAtA []byte, err error)
func (*FlushHistoryReq) ProtoMessage ¶
func (*FlushHistoryReq) ProtoMessage()
func (*FlushHistoryReq) Reset ¶
func (m *FlushHistoryReq) Reset()
func (*FlushHistoryReq) Size ¶
func (m *FlushHistoryReq) Size() (n int)
func (*FlushHistoryReq) String ¶
func (m *FlushHistoryReq) String() string
func (*FlushHistoryReq) Unmarshal ¶
func (m *FlushHistoryReq) Unmarshal(dAtA []byte) error
type HistoriesReply ¶
type HistoriesReply struct {
Res []*ModelResource `protobuf:"bytes,1,rep,name=res" json:"res,omitempty"`
}
func (*HistoriesReply) Descriptor ¶
func (*HistoriesReply) Descriptor() ([]byte, []int)
func (*HistoriesReply) GetRes ¶
func (m *HistoriesReply) GetRes() []*ModelResource
func (*HistoriesReply) Marshal ¶
func (m *HistoriesReply) Marshal() (dAtA []byte, err error)
func (*HistoriesReply) ProtoMessage ¶
func (*HistoriesReply) ProtoMessage()
func (*HistoriesReply) Reset ¶
func (m *HistoriesReply) Reset()
func (*HistoriesReply) Size ¶
func (m *HistoriesReply) Size() (n int)
func (*HistoriesReply) String ¶
func (m *HistoriesReply) String() string
func (*HistoriesReply) Unmarshal ¶
func (m *HistoriesReply) Unmarshal(dAtA []byte) error
type HistoriesReq ¶
type HistoriesReq struct { Mid int64 `protobuf:"varint,2,opt,name=mid,proto3" json:"mid,omitempty"` Business string `protobuf:"bytes,3,opt,name=business,proto3" json:"business,omitempty"` Pn int32 `protobuf:"varint,4,opt,name=pn,proto3" json:"pn,omitempty"` Ps int32 `protobuf:"varint,5,opt,name=ps,proto3" json:"ps,omitempty"` }
func (*HistoriesReq) Descriptor ¶
func (*HistoriesReq) Descriptor() ([]byte, []int)
func (*HistoriesReq) GetBusiness ¶
func (m *HistoriesReq) GetBusiness() string
func (*HistoriesReq) GetMid ¶
func (m *HistoriesReq) GetMid() int64
func (*HistoriesReq) GetPn ¶
func (m *HistoriesReq) GetPn() int32
func (*HistoriesReq) GetPs ¶
func (m *HistoriesReq) GetPs() int32
func (*HistoriesReq) Marshal ¶
func (m *HistoriesReq) Marshal() (dAtA []byte, err error)
func (*HistoriesReq) ProtoMessage ¶
func (*HistoriesReq) ProtoMessage()
func (*HistoriesReq) Reset ¶
func (m *HistoriesReq) Reset()
func (*HistoriesReq) Size ¶
func (m *HistoriesReq) Size() (n int)
func (*HistoriesReq) String ¶
func (m *HistoriesReq) String() string
func (*HistoriesReq) Unmarshal ¶
func (m *HistoriesReq) Unmarshal(dAtA []byte) error
type HistoryClient ¶
type HistoryClient interface { // AddHistory add hisotry progress into hbase. AddHistory(ctx context.Context, in *AddHistoryReq, opts ...grpc.CallOption) (*AddHistoryReply, error) // Progress get view progress from cache/hbase. Progress(ctx context.Context, in *ProgressReq, opts ...grpc.CallOption) (*ProgressReply, error) // Position get view progress from cache/hbase. Position(ctx context.Context, in *PositionReq, opts ...grpc.CallOption) (*PositionReply, error) // ClearHistory clear user's historys. ClearHistory(ctx context.Context, in *ClearHistoryReq, opts ...grpc.CallOption) (*ClearHistoryReply, error) // Histories return the user all av history. Histories(ctx context.Context, in *HistoriesReq, opts ...grpc.CallOption) (*HistoriesReply, error) // HistoryCursor return the user all av history. HistoryCursor(ctx context.Context, in *HistoryCursorReq, opts ...grpc.CallOption) (*HistoryCursorReply, error) // Delete . Delete(ctx context.Context, in *DeleteReq, opts ...grpc.CallOption) (*DeleteReply, error) // FlushHistory flush to hbase from cache. FlushHistory(ctx context.Context, in *FlushHistoryReq, opts ...grpc.CallOption) (*FlushHistoryReply, error) }
func NewHistoryClient ¶
func NewHistoryClient(cc *grpc.ClientConn) HistoryClient
type HistoryCursorReply ¶
type HistoryCursorReply struct {
Res []*ModelResource `protobuf:"bytes,1,rep,name=res" json:"res,omitempty"`
}
func (*HistoryCursorReply) Descriptor ¶
func (*HistoryCursorReply) Descriptor() ([]byte, []int)
func (*HistoryCursorReply) GetRes ¶
func (m *HistoryCursorReply) GetRes() []*ModelResource
func (*HistoryCursorReply) Marshal ¶
func (m *HistoryCursorReply) Marshal() (dAtA []byte, err error)
func (*HistoryCursorReply) MarshalTo ¶
func (m *HistoryCursorReply) MarshalTo(dAtA []byte) (int, error)
func (*HistoryCursorReply) ProtoMessage ¶
func (*HistoryCursorReply) ProtoMessage()
func (*HistoryCursorReply) Reset ¶
func (m *HistoryCursorReply) Reset()
func (*HistoryCursorReply) Size ¶
func (m *HistoryCursorReply) Size() (n int)
func (*HistoryCursorReply) String ¶
func (m *HistoryCursorReply) String() string
func (*HistoryCursorReply) Unmarshal ¶
func (m *HistoryCursorReply) Unmarshal(dAtA []byte) error
type HistoryCursorReq ¶
type HistoryCursorReq struct { Mid int64 `protobuf:"varint,2,opt,name=mid,proto3" json:"mid,omitempty"` Max int64 `protobuf:"varint,3,opt,name=max,proto3" json:"max,omitempty"` ViewAt int64 `protobuf:"varint,4,opt,name=view_at,json=viewAt,proto3" json:"view_at,omitempty"` Ps int32 `protobuf:"varint,5,opt,name=ps,proto3" json:"ps,omitempty"` Business string `protobuf:"bytes,6,opt,name=business,proto3" json:"business,omitempty"` Businesses []string `protobuf:"bytes,7,rep,name=businesses" json:"businesses,omitempty"` Ip string `protobuf:"bytes,8,opt,name=ip,proto3" json:"ip,omitempty"` }
func (*HistoryCursorReq) Descriptor ¶
func (*HistoryCursorReq) Descriptor() ([]byte, []int)
func (*HistoryCursorReq) GetBusiness ¶
func (m *HistoryCursorReq) GetBusiness() string
func (*HistoryCursorReq) GetBusinesses ¶
func (m *HistoryCursorReq) GetBusinesses() []string
func (*HistoryCursorReq) GetIp ¶
func (m *HistoryCursorReq) GetIp() string
func (*HistoryCursorReq) GetMax ¶
func (m *HistoryCursorReq) GetMax() int64
func (*HistoryCursorReq) GetMid ¶
func (m *HistoryCursorReq) GetMid() int64
func (*HistoryCursorReq) GetPs ¶
func (m *HistoryCursorReq) GetPs() int32
func (*HistoryCursorReq) GetViewAt ¶
func (m *HistoryCursorReq) GetViewAt() int64
func (*HistoryCursorReq) Marshal ¶
func (m *HistoryCursorReq) Marshal() (dAtA []byte, err error)
func (*HistoryCursorReq) ProtoMessage ¶
func (*HistoryCursorReq) ProtoMessage()
func (*HistoryCursorReq) Reset ¶
func (m *HistoryCursorReq) Reset()
func (*HistoryCursorReq) Size ¶
func (m *HistoryCursorReq) Size() (n int)
func (*HistoryCursorReq) String ¶
func (m *HistoryCursorReq) String() string
func (*HistoryCursorReq) Unmarshal ¶
func (m *HistoryCursorReq) Unmarshal(dAtA []byte) error
type HistoryServer ¶
type HistoryServer interface { // AddHistory add hisotry progress into hbase. AddHistory(context.Context, *AddHistoryReq) (*AddHistoryReply, error) // Progress get view progress from cache/hbase. Progress(context.Context, *ProgressReq) (*ProgressReply, error) // Position get view progress from cache/hbase. Position(context.Context, *PositionReq) (*PositionReply, error) // ClearHistory clear user's historys. ClearHistory(context.Context, *ClearHistoryReq) (*ClearHistoryReply, error) // Histories return the user all av history. Histories(context.Context, *HistoriesReq) (*HistoriesReply, error) // HistoryCursor return the user all av history. HistoryCursor(context.Context, *HistoryCursorReq) (*HistoryCursorReply, error) // Delete . Delete(context.Context, *DeleteReq) (*DeleteReply, error) // FlushHistory flush to hbase from cache. FlushHistory(context.Context, *FlushHistoryReq) (*FlushHistoryReply, error) }
type ModelHistory ¶
type ModelHistory struct { Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"` Aid int64 `protobuf:"varint,2,opt,name=aid,proto3" json:"aid,omitempty"` Sid int64 `protobuf:"varint,3,opt,name=sid,proto3" json:"sid,omitempty"` Epid int64 `protobuf:"varint,4,opt,name=epid,proto3" json:"epid,omitempty"` Tp int32 `protobuf:"varint,5,opt,name=tp,proto3" json:"tp,omitempty"` Business string `protobuf:"bytes,6,opt,name=business,proto3" json:"business,omitempty"` Stp int32 `protobuf:"varint,7,opt,name=stp,proto3" json:"stp,omitempty"` Cid int64 `protobuf:"varint,8,opt,name=cid,proto3" json:"cid,omitempty"` Dt int32 `protobuf:"varint,9,opt,name=dt,proto3" json:"dt,omitempty"` Pro int64 `protobuf:"varint,10,opt,name=pro,proto3" json:"pro,omitempty"` Unix int64 `protobuf:"varint,11,opt,name=unix,proto3" json:"unix,omitempty"` }
func (*ModelHistory) Descriptor ¶
func (*ModelHistory) Descriptor() ([]byte, []int)
func (*ModelHistory) GetAid ¶
func (m *ModelHistory) GetAid() int64
func (*ModelHistory) GetBusiness ¶
func (m *ModelHistory) GetBusiness() string
func (*ModelHistory) GetCid ¶
func (m *ModelHistory) GetCid() int64
func (*ModelHistory) GetDt ¶
func (m *ModelHistory) GetDt() int32
func (*ModelHistory) GetEpid ¶
func (m *ModelHistory) GetEpid() int64
func (*ModelHistory) GetMid ¶
func (m *ModelHistory) GetMid() int64
func (*ModelHistory) GetPro ¶
func (m *ModelHistory) GetPro() int64
func (*ModelHistory) GetSid ¶
func (m *ModelHistory) GetSid() int64
func (*ModelHistory) GetStp ¶
func (m *ModelHistory) GetStp() int32
func (*ModelHistory) GetTp ¶
func (m *ModelHistory) GetTp() int32
func (*ModelHistory) GetUnix ¶
func (m *ModelHistory) GetUnix() int64
func (*ModelHistory) Marshal ¶
func (m *ModelHistory) Marshal() (dAtA []byte, err error)
func (*ModelHistory) ProtoMessage ¶
func (*ModelHistory) ProtoMessage()
func (*ModelHistory) Reset ¶
func (m *ModelHistory) Reset()
func (*ModelHistory) Size ¶
func (m *ModelHistory) Size() (n int)
func (*ModelHistory) String ¶
func (m *ModelHistory) String() string
func (*ModelHistory) Unmarshal ¶
func (m *ModelHistory) Unmarshal(dAtA []byte) error
type ModelResource ¶
type ModelResource struct { Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"` Oid int64 `protobuf:"varint,2,opt,name=oid,proto3" json:"oid,omitempty"` Sid int64 `protobuf:"varint,3,opt,name=sid,proto3" json:"sid,omitempty"` Epid int64 `protobuf:"varint,4,opt,name=epid,proto3" json:"epid,omitempty"` Tp int32 `protobuf:"varint,5,opt,name=tp,proto3" json:"tp,omitempty"` Stp int32 `protobuf:"varint,6,opt,name=stp,proto3" json:"stp,omitempty"` Cid int64 `protobuf:"varint,7,opt,name=cid,proto3" json:"cid,omitempty"` Business string `protobuf:"bytes,8,opt,name=business,proto3" json:"business,omitempty"` Dt int32 `protobuf:"varint,9,opt,name=dt,proto3" json:"dt,omitempty"` Pro int64 `protobuf:"varint,10,opt,name=pro,proto3" json:"pro,omitempty"` Unix int64 `protobuf:"varint,11,opt,name=unix,proto3" json:"unix,omitempty"` }
func (*ModelResource) Descriptor ¶
func (*ModelResource) Descriptor() ([]byte, []int)
func (*ModelResource) GetBusiness ¶
func (m *ModelResource) GetBusiness() string
func (*ModelResource) GetCid ¶
func (m *ModelResource) GetCid() int64
func (*ModelResource) GetDt ¶
func (m *ModelResource) GetDt() int32
func (*ModelResource) GetEpid ¶
func (m *ModelResource) GetEpid() int64
func (*ModelResource) GetMid ¶
func (m *ModelResource) GetMid() int64
func (*ModelResource) GetOid ¶
func (m *ModelResource) GetOid() int64
func (*ModelResource) GetPro ¶
func (m *ModelResource) GetPro() int64
func (*ModelResource) GetSid ¶
func (m *ModelResource) GetSid() int64
func (*ModelResource) GetStp ¶
func (m *ModelResource) GetStp() int32
func (*ModelResource) GetTp ¶
func (m *ModelResource) GetTp() int32
func (*ModelResource) GetUnix ¶
func (m *ModelResource) GetUnix() int64
func (*ModelResource) Marshal ¶
func (m *ModelResource) Marshal() (dAtA []byte, err error)
func (*ModelResource) ProtoMessage ¶
func (*ModelResource) ProtoMessage()
func (*ModelResource) Reset ¶
func (m *ModelResource) Reset()
func (*ModelResource) Size ¶
func (m *ModelResource) Size() (n int)
func (*ModelResource) String ¶
func (m *ModelResource) String() string
func (*ModelResource) Unmarshal ¶
func (m *ModelResource) Unmarshal(dAtA []byte) error
type PositionReply ¶
type PositionReply struct {
Res *ModelHistory `protobuf:"bytes,1,opt,name=res" json:"res,omitempty"`
}
func (*PositionReply) Descriptor ¶
func (*PositionReply) Descriptor() ([]byte, []int)
func (*PositionReply) GetRes ¶
func (m *PositionReply) GetRes() *ModelHistory
func (*PositionReply) Marshal ¶
func (m *PositionReply) Marshal() (dAtA []byte, err error)
func (*PositionReply) ProtoMessage ¶
func (*PositionReply) ProtoMessage()
func (*PositionReply) Reset ¶
func (m *PositionReply) Reset()
func (*PositionReply) Size ¶
func (m *PositionReply) Size() (n int)
func (*PositionReply) String ¶
func (m *PositionReply) String() string
func (*PositionReply) Unmarshal ¶
func (m *PositionReply) Unmarshal(dAtA []byte) error
type PositionReq ¶
type PositionReq struct { Mid int64 `protobuf:"varint,2,opt,name=mid,proto3" json:"mid,omitempty"` Aid int64 `protobuf:"varint,3,opt,name=aid,proto3" json:"aid,omitempty"` Business string `protobuf:"bytes,4,opt,name=business,proto3" json:"business,omitempty"` }
func (*PositionReq) Descriptor ¶
func (*PositionReq) Descriptor() ([]byte, []int)
func (*PositionReq) GetAid ¶
func (m *PositionReq) GetAid() int64
func (*PositionReq) GetBusiness ¶
func (m *PositionReq) GetBusiness() string
func (*PositionReq) GetMid ¶
func (m *PositionReq) GetMid() int64
func (*PositionReq) Marshal ¶
func (m *PositionReq) Marshal() (dAtA []byte, err error)
func (*PositionReq) ProtoMessage ¶
func (*PositionReq) ProtoMessage()
func (*PositionReq) Reset ¶
func (m *PositionReq) Reset()
func (*PositionReq) Size ¶
func (m *PositionReq) Size() (n int)
func (*PositionReq) String ¶
func (m *PositionReq) String() string
func (*PositionReq) Unmarshal ¶
func (m *PositionReq) Unmarshal(dAtA []byte) error
type ProgressReply ¶
type ProgressReply struct {
Res map[int64]*ModelHistory `` /* 134-byte string literal not displayed */
}
func (*ProgressReply) Descriptor ¶
func (*ProgressReply) Descriptor() ([]byte, []int)
func (*ProgressReply) GetRes ¶
func (m *ProgressReply) GetRes() map[int64]*ModelHistory
func (*ProgressReply) Marshal ¶
func (m *ProgressReply) Marshal() (dAtA []byte, err error)
func (*ProgressReply) ProtoMessage ¶
func (*ProgressReply) ProtoMessage()
func (*ProgressReply) Reset ¶
func (m *ProgressReply) Reset()
func (*ProgressReply) Size ¶
func (m *ProgressReply) Size() (n int)
func (*ProgressReply) String ¶
func (m *ProgressReply) String() string
func (*ProgressReply) Unmarshal ¶
func (m *ProgressReply) Unmarshal(dAtA []byte) error
type ProgressReq ¶
type ProgressReq struct { Mid int64 `protobuf:"varint,2,opt,name=mid,proto3" json:"mid,omitempty"` Aids []int64 `protobuf:"varint,3,rep,packed,name=aids" json:"aids,omitempty"` }
func (*ProgressReq) Descriptor ¶
func (*ProgressReq) Descriptor() ([]byte, []int)
func (*ProgressReq) GetAids ¶
func (m *ProgressReq) GetAids() []int64
func (*ProgressReq) GetMid ¶
func (m *ProgressReq) GetMid() int64
func (*ProgressReq) Marshal ¶
func (m *ProgressReq) Marshal() (dAtA []byte, err error)
func (*ProgressReq) ProtoMessage ¶
func (*ProgressReq) ProtoMessage()
func (*ProgressReq) Reset ¶
func (m *ProgressReq) Reset()
func (*ProgressReq) Size ¶
func (m *ProgressReq) Size() (n int)
func (*ProgressReq) String ¶
func (m *ProgressReq) String() string
func (*ProgressReq) Unmarshal ¶
func (m *ProgressReq) Unmarshal(dAtA []byte) error
Click to show internal directories.
Click to hide internal directories.