luci: go.chromium.org/luci/logdog/appengine/coordinator/mutations Index | Files

package mutations

import "go.chromium.org/luci/logdog/appengine/coordinator/mutations"

Index

Package Files

createArchiveTask.go

type CreateArchiveTask Uses

type CreateArchiveTask struct {
    // ID is the hash ID of the LogStream whose archive task is being created.
    //
    // Note that the task will apply to the LogStreamState, not the stream
    // entity itself.
    ID  coordinator.HashID

    // SettleDelay is the settle delay (see ArchivalParams).
    SettleDelay time.Duration
    // CompletePeriod is the complete period to use (see ArchivalParams).
    CompletePeriod time.Duration

    // Expiration is the delay applied to the archive task via ProcessAfter.
    Expiration time.Time
}

CreateArchiveTask is a tumble Mutation that registers an archive task.

It is a named mutation.

func (*CreateArchiveTask) HighPriority Uses

func (m *CreateArchiveTask) HighPriority() bool

HighPriority implements tumble.DelayedMutation.

func (*CreateArchiveTask) ProcessAfter Uses

func (m *CreateArchiveTask) ProcessAfter() time.Time

ProcessAfter implements tumble.DelayedMutation.

func (*CreateArchiveTask) RollForward Uses

func (m *CreateArchiveTask) RollForward(c context.Context) ([]tumble.Mutation, error)

RollForward implements tumble.DelayedMutation.

func (*CreateArchiveTask) Root Uses

func (m *CreateArchiveTask) Root(c context.Context) *ds.Key

Root implements tumble.DelayedMutation.

func (*CreateArchiveTask) TaskName Uses

func (m *CreateArchiveTask) TaskName(c context.Context) string

TaskName returns the task's name, which is derived from its log stream ID.

Package mutations imports 9 packages (graph) and is imported by 2 packages. Updated 2018-08-21. Refresh now. Tools for package owners.