types

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

const (
	// SubscriptionKeyPrefix is the prefix to retrieve all Subscription
	SubscriptionKeyPrefix = "Subscribe/value/"
)

Variables

var (
	ErrInvalidLengthSubscription        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSubscription          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSubscription = fmt.Errorf("proto: unexpected end of group")
)

Functions

func KeyPrefix

func KeyPrefix(p string) []byte

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

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