Documentation ¶
Index ¶
Constants ¶
View Source
const ( MAX_STEP = 1000000 SEGMENT_DURATION = 15 * time.Minute )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) Init ¶
func (s *SegmentImpl) Init() (err error)
Click to show internal directories.
Click to hide internal directories.