segment

Documentation

Index

• Variables
• type Repository
  • func NewDefaultRepository(db *sql.DB) (Repository, error)
• type Segment
• type Service
  • func NewService(repo Repository, logger log.Logger) *Service
  • func (s *Service) Close() error
  • func (s *Service) Get(ctx context.Context, biztag string, count int) (ids []int64, err error)

Variables

var (
	ErrClosed         = errors.New("service closed")
	ErrBizTagNotFound = errors.New("biztag not found")
)

Types

type Repository

type Repository interface {
	List(ctx context.Context) ([]*Segment, error)
	Get(ctx context.Context, biztag string) (*Segment, error)
	UpdateMaxID(ctx context.Context, biztag string) (*Segment, error)
	UpdateMaxIDWithStep(ctx context.Context, biztag string, step int32) (*Segment, error)
	ListBizTags(ctx context.Context) ([]string, error)
}

func NewDefaultRepository

func NewDefaultRepository(db *sql.DB) (Repository, error)

type Segment

type Segment struct {
	BizTag      string
	MaxID       int64
	Step        int32
	Description string
	Updated     time.Time
}

type Service

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

func NewService

func NewService(repo Repository, logger log.Logger) *Service

func (*Service) Close

func (s *Service) Close() error

func (*Service) Get

func (s *Service) Get(ctx context.Context, biztag string, count int) (ids []int64, err error)