Documentation ¶
Index ¶
- Constants
- Variables
- func KeyPrefix(p string) []byte
- type Subscription
- func (*Subscription) Descriptor() ([]byte, []int)
- func (m *Subscription) GetBlock() uint64
- func (m *Subscription) GetConsumer() string
- func (m *Subscription) GetCreator() string
- func (m *Subscription) GetDurationLeft() uint64
- func (m *Subscription) GetDurationTotal() uint64
- func (m *Subscription) GetMonthCuLeft() uint64
- func (m *Subscription) GetMonthCuTotal() uint64
- func (m *Subscription) GetMonthExpiryTime() uint64
- func (m *Subscription) GetPlanBlock() uint64
- func (m *Subscription) GetPlanIndex() string
- func (m *Subscription) GetPrevCuLeft() uint64
- func (m *Subscription) GetPrevExpiryBlock() uint64
- func (m *Subscription) Marshal() (dAtA []byte, err error)
- func (m *Subscription) MarshalTo(dAtA []byte) (int, error)
- func (m *Subscription) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Subscription) ProtoMessage()
- func (m *Subscription) Reset()
- func (m *Subscription) Size() (n int)
- func (m *Subscription) String() string
- func (m *Subscription) Unmarshal(dAtA []byte) error
- func (m *Subscription) XXX_DiscardUnknown()
- func (m *Subscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Subscription) XXX_Merge(src proto.Message)
- func (m *Subscription) XXX_Size() int
- func (m *Subscription) XXX_Unmarshal(b []byte) error
Constants ¶
View Source
const (
// SubscriptionKeyPrefix is the prefix to retrieve all Subscription
SubscriptionKeyPrefix = "Subscribe/value/"
)
Variables ¶
Functions ¶
Types ¶
type Subscription ¶
type Subscription struct { Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"` Consumer string `protobuf:"bytes,2,opt,name=consumer,proto3" json:"consumer,omitempty"` Block uint64 `protobuf:"varint,3,opt,name=block,proto3" json:"block,omitempty"` PlanIndex string `protobuf:"bytes,4,opt,name=plan_index,json=planIndex,proto3" json:"plan_index,omitempty"` PlanBlock uint64 `protobuf:"varint,5,opt,name=plan_block,json=planBlock,proto3" json:"plan_block,omitempty"` DurationTotal uint64 `protobuf:"varint,6,opt,name=duration_total,json=durationTotal,proto3" json:"duration_total,omitempty"` DurationLeft uint64 `protobuf:"varint,7,opt,name=duration_left,json=durationLeft,proto3" json:"duration_left,omitempty"` MonthExpiryTime uint64 `protobuf:"varint,8,opt,name=month_expiry_time,json=monthExpiryTime,proto3" json:"month_expiry_time,omitempty"` PrevExpiryBlock uint64 `protobuf:"varint,9,opt,name=prev_expiry_block,json=prevExpiryBlock,proto3" json:"prev_expiry_block,omitempty"` MonthCuTotal uint64 `protobuf:"varint,10,opt,name=month_cu_total,json=monthCuTotal,proto3" json:"month_cu_total,omitempty"` MonthCuLeft uint64 `protobuf:"varint,11,opt,name=month_cu_left,json=monthCuLeft,proto3" json:"month_cu_left,omitempty"` PrevCuLeft uint64 `protobuf:"varint,12,opt,name=prev_cu_left,json=prevCuLeft,proto3" json:"prev_cu_left,omitempty"` }
func (*Subscription) Descriptor ¶
func (*Subscription) Descriptor() ([]byte, []int)
func (*Subscription) GetBlock ¶
func (m *Subscription) GetBlock() uint64
func (*Subscription) GetConsumer ¶
func (m *Subscription) GetConsumer() string
func (*Subscription) GetCreator ¶
func (m *Subscription) GetCreator() string
func (*Subscription) GetDurationLeft ¶
func (m *Subscription) GetDurationLeft() uint64
func (*Subscription) GetDurationTotal ¶
func (m *Subscription) GetDurationTotal() uint64
func (*Subscription) GetMonthCuLeft ¶
func (m *Subscription) GetMonthCuLeft() uint64
func (*Subscription) GetMonthCuTotal ¶
func (m *Subscription) GetMonthCuTotal() uint64
func (*Subscription) GetMonthExpiryTime ¶
func (m *Subscription) GetMonthExpiryTime() uint64
func (*Subscription) GetPlanBlock ¶
func (m *Subscription) GetPlanBlock() uint64
func (*Subscription) GetPlanIndex ¶
func (m *Subscription) GetPlanIndex() string
func (*Subscription) GetPrevCuLeft ¶
func (m *Subscription) GetPrevCuLeft() uint64
func (*Subscription) GetPrevExpiryBlock ¶
func (m *Subscription) GetPrevExpiryBlock() uint64
func (*Subscription) Marshal ¶
func (m *Subscription) Marshal() (dAtA []byte, err error)
func (*Subscription) MarshalToSizedBuffer ¶
func (m *Subscription) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Subscription) ProtoMessage ¶
func (*Subscription) ProtoMessage()
func (*Subscription) Reset ¶
func (m *Subscription) Reset()
func (*Subscription) Size ¶
func (m *Subscription) Size() (n int)
func (*Subscription) String ¶
func (m *Subscription) String() string
func (*Subscription) Unmarshal ¶
func (m *Subscription) Unmarshal(dAtA []byte) error
func (*Subscription) XXX_DiscardUnknown ¶
func (m *Subscription) XXX_DiscardUnknown()
func (*Subscription) XXX_Marshal ¶
func (m *Subscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Subscription) XXX_Merge ¶
func (m *Subscription) XXX_Merge(src proto.Message)
func (*Subscription) XXX_Size ¶
func (m *Subscription) XXX_Size() int
func (*Subscription) XXX_Unmarshal ¶
func (m *Subscription) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.