stagelogstore

Documentation

Index

• Variables
• type Store
  • func NewStore(fs filestore.Store, c cache.Cache, logger *zap.Logger) Store

Variables

var (
	ErrNotFound         = errors.New("stage log was not found")
	ErrAlreadyCompleted = errors.New("stage log was already completed")
)

Types

type Store

type Store interface {
	// FetchLogs get the specified stage logs which filtered by index.
	FetchLogs(ctx context.Context, deploymentID, stageID string, retriedCount int32, offsetIndex int64) ([]*model.LogBlock, bool, error)
	// AppendLogs appends the stage logs. The stage logs are deduplicated with index value.
	AppendLogs(ctx context.Context, deploymentID, stageID string, retriedCount int32, newBlocks []*model.LogBlock) error
	// AppendLogsFromLastCheckpoint appends the stage logs. The stage logs are deduplicated with index value.
	// If completed is true, flush all the logs to that point and cannot append it after this.
	AppendLogsFromLastCheckpoint(ctx context.Context, deploymentID, stageID string, retriedCount int32, newBlocks []*model.LogBlock, completed bool) error
}

func NewStore

func NewStore(fs filestore.Store, c cache.Cache, logger *zap.Logger) Store