database

Documentation

Index

• Variables
• type MetaStore
  • func NewMetaStore(db *sql.DB) *MetaStore
  • func (m *MetaStore) FinishTask(ctx context.Context, ref *flexletpb.TaskRef, result *flex.TaskResult, ...) (err error)
  • func (m *MetaStore) GetJob(ctx context.Context, id int64) (status *flex.JobStatus, err error)
  • func (m *MetaStore) GetStats(ctx context.Context) (stats *flex.Stats, err error)
  • func (m *MetaStore) InitTables(ctx context.Context) (err error)
  • func (m *MetaStore) InsertJob(ctx context.Context, spec *flex.JobSpec) (id int64, err error)
  • func (m *MetaStore) ListFlexlets(ctx context.Context) (statuses []*flex.FlexletStatus, err error)
  • func (m *MetaStore) ListJobs(ctx context.Context, state flex.JobState, label string, limit int64, ...) (statuses []*flex.JobStatus, err error)
  • func (m *MetaStore) ListTags(ctx context.Context) (tags []*flex.Tag, err error)
  • func (m *MetaStore) LookupTag(ctx context.Context, tag string) (hash string, err error)
  • func (m *MetaStore) Maintain(ctx context.Context) (err error)
  • func (m *MetaStore) TakeTask(ctx context.Context, flexletName string) (ref *flexletpb.TaskRef, jobSpec *flex.JobSpec, err error)
  • func (m *MetaStore) UpdateFlexlet(ctx context.Context, status *flex.FlexletStatus) (err error)
  • func (m *MetaStore) UpdateJobLabels(ctx context.Context, id int64, adds, dels []string) (err error)
  • func (m *MetaStore) UpdateTag(ctx context.Context, name, hash string) (err error)
  • func (m *MetaStore) UpdateTask(ctx context.Context, ref *flexletpb.TaskRef) (err error)

Variables

var ErrNoPendingTask = errors.New("no pending task")

Types

type MetaStore

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

func NewMetaStore

func NewMetaStore(db *sql.DB) *MetaStore

func (*MetaStore) FinishTask

func (m *MetaStore) FinishTask(ctx context.Context, ref *flexletpb.TaskRef, result *flex.TaskResult, needRetry bool) (err error)

func (*MetaStore) GetJob

func (m *MetaStore) GetJob(ctx context.Context, id int64) (status *flex.JobStatus, err error)

func (*MetaStore) GetStats

func (m *MetaStore) GetStats(ctx context.Context) (stats *flex.Stats, err error)

func (*MetaStore) InitTables

func (m *MetaStore) InitTables(ctx context.Context) (err error)

func (*MetaStore) InsertJob

func (m *MetaStore) InsertJob(ctx context.Context, spec *flex.JobSpec) (id int64, err error)

func (*MetaStore) ListFlexlets

func (m *MetaStore) ListFlexlets(ctx context.Context) (statuses []*flex.FlexletStatus, err error)

func (*MetaStore) ListJobs

func (m *MetaStore) ListJobs(ctx context.Context, state flex.JobState, label string, limit int64, beforeID int64) (statuses []*flex.JobStatus, err error)

func (*MetaStore) ListTags

func (m *MetaStore) ListTags(ctx context.Context) (tags []*flex.Tag, err error)

func (*MetaStore) LookupTag

func (m *MetaStore) LookupTag(ctx context.Context, tag string) (hash string, err error)

func (*MetaStore) Maintain

func (m *MetaStore) Maintain(ctx context.Context) (err error)

func (*MetaStore) TakeTask

func (m *MetaStore) TakeTask(ctx context.Context, flexletName string) (ref *flexletpb.TaskRef, jobSpec *flex.JobSpec, err error)

func (*MetaStore) UpdateFlexlet

func (m *MetaStore) UpdateFlexlet(ctx context.Context, status *flex.FlexletStatus) (err error)

func (*MetaStore) UpdateJobLabels

func (m *MetaStore) UpdateJobLabels(ctx context.Context, id int64, adds, dels []string) (err error)

func (*MetaStore) UpdateTag

func (m *MetaStore) UpdateTag(ctx context.Context, name, hash string) (err error)

func (*MetaStore) UpdateTask

func (m *MetaStore) UpdateTask(ctx context.Context, ref *flexletpb.TaskRef) (err error)