database

func (m *MetaStore) FinishTask(ctx context.Context, ref *flexletpb.TaskRef, result *flex.TaskResult, needRetry bool) (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, beforeID 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)