segment

Documentation

Index

• Constants
• type Repo
• type SegmentImpl
  • func NewSegmentImpl(repo Repo) *SegmentImpl
  • func (s *SegmentImpl) Get(ctx context.Context, key string) (int64, error)
  • func (s *SegmentImpl) Init() (err error)

Constants

const (
	MAX_STEP         = 1000000
	SEGMENT_DURATION = 15 * time.Minute
)

Types

type Repo

type Repo interface {
	GetAllLeafAllocs(ctx context.Context) ([]*entity.LeafAlloc, error)
	UpdateMaxIdAndGetLeafAlloc(ctx context.Context, tag string) (*entity.LeafAlloc, error)
	UpdateMaxIdByCustomStepAndGetLeafAlloc(ctx context.Context, leafAlloc *entity.LeafAlloc) (*entity.LeafAlloc, error)
	GetAllTags(ctx context.Context) ([]string, error)
}

type SegmentImpl

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

[string]*entity.SegmentBuffer

func NewSegmentImpl

func NewSegmentImpl(repo Repo) *SegmentImpl

func (*SegmentImpl) Get

func (s *SegmentImpl) Get(ctx context.Context, key string) (int64, error)

func (*SegmentImpl) Init

func (s *SegmentImpl) Init() (err error)