subscribe

Documentation

Index

• type Option
  • func WithDBClient(dbClient *dao.DBClient) Option
• type Subscribe
  • func New(opts ...Option) *Subscribe
  • func (s *Subscribe) Convert(subscribe model.Subscribe) apistructs.Subscribe
  • func (s *Subscribe) GetSubscribes(req apistructs.GetSubscribeReq) ([]apistructs.Subscribe, error)
  • func (s *Subscribe) Subscribe(req apistructs.CreateSubscribeReq) (uint64, error)
  • func (s *Subscribe) UnSubscribe(req apistructs.UnSubscribeReq) error

Types

type Option

type Option func(*Subscribe)

func WithDBClient

func WithDBClient(dbClient *dao.DBClient) Option

type Subscribe

type Subscribe struct {
	// contains filtered or unexported fields
}

func New

func New(opts ...Option) *Subscribe

func (*Subscribe) Convert

func (s *Subscribe) Convert(subscribe model.Subscribe) apistructs.Subscribe

func (*Subscribe) GetSubscribes

func (s *Subscribe) GetSubscribes(req apistructs.GetSubscribeReq) ([]apistructs.Subscribe, error)

func (*Subscribe) Subscribe

func (s *Subscribe) Subscribe(req apistructs.CreateSubscribeReq) (uint64, error)

func (*Subscribe) UnSubscribe

func (s *Subscribe) UnSubscribe(req apistructs.UnSubscribeReq) error