state

Mar 28, 2024 GO-2024-2692

  GO-2024-2692: Pebble service manager's file pull API allows access by any user in github.com/canonical/pebble

Mar 28, 2024 GO-2024-2692

  GO-2024-2692: Pebble service manager's file pull API allows access by any user in github.com/canonical/pebble

Mar 21, 2024 GO-2024-2692

  GO-2024-2692: Pebble service manager's file pull API allows access by any user in github.com/canonical/pebble

Feb 28, 2024 GO-2024-2692

  GO-2024-2692: Pebble service manager's file pull API allows access by any user in github.com/canonical/pebble

Feb 15, 2024 GO-2024-2692

  GO-2024-2692: Pebble service manager's file pull API allows access by any user in github.com/canonical/pebble

Changes in this version

type Change

+ func (c *Change) AbortUnreadyLanes()

+ func (c *Change) CheckTaskDependencies() error

+ func (c *Change) Has(key string) bool

+ type NoStateError struct

+ Key string

+ func (e *NoStateError) Error() string

+ func (e *NoStateError) Is(err error) bool

type State

+ func (s *State) AddChangeStatusChangedHandler(f func(chg *Change, old, new Status)) (id int)

+ func (s *State) AddTaskStatusChangedHandler(f func(t *Task, old, new Status)) (id int)

+ func (s *State) GetMaybeTimings(timings interface{}) error

+ func (s *State) Has(key string) bool

+ func (s *State) RegisterPendingChangeByAttr(attr string, f func(*Change) bool)

+ func (s *State) RemoveChangeStatusChangedHandler(id int)

+ func (s *State) RemoveTaskStatusChangedHandler(id int)

+ func (s *State) SaveTimings(timings interface{})

+ func (s *State) Unlocker() (unlock func() (relock func()))

type Status

+ const WaitStatus

type Task

+ func (t *Task) SetToWait(resultStatus Status)

+ func (t *Task) WaitedStatus() Status

+ type TaskDependencyCycleError struct

+ IDs []string

+ func (e *TaskDependencyCycleError) Error() string

+ func (e *TaskDependencyCycleError) Is(err error) bool

type TaskRunner

+ func (r *TaskRunner) OnTaskError(f func(err error))

type TaskSet

+ func (ts TaskSet) MaybeEdge(e TaskSetEdge) *Task

+ type Wait struct

+ Reason string

+ WaitedStatus Status

+ func (r *Wait) Error() string

Feb 28, 2024 GO-2024-2692

  GO-2024-2692: Pebble service manager's file pull API allows access by any user in github.com/canonical/pebble

Changes in this version

type State

+ func (s *State) LockCount() int

Feb 20, 2024 GO-2024-2692

  GO-2024-2692: Pebble service manager's file pull API allows access by any user in github.com/canonical/pebble

Dec 14, 2023 GO-2024-2692

  GO-2024-2692: Pebble service manager's file pull API allows access by any user in github.com/canonical/pebble

Changes in this version

type Notice

+ func (n *Notice) UserID() (userID uint32, isSet bool)

type NoticeFilter

+ UserID *uint32

Nov 30, 2023 GO-2024-2692

  GO-2024-2692: Pebble service manager's file pull API allows access by any user in github.com/canonical/pebble

Oct 30, 2023 GO-2024-2692

  GO-2024-2692: Pebble service manager's file pull API allows access by any user in github.com/canonical/pebble

Changes in this version

+ type AddNoticeOptions struct

+ Data map[string]string

+ RepeatAfter time.Duration

+ Time time.Time

+ type Notice struct

+ func (n *Notice) MarshalJSON() ([]byte, error)

+ func (n *Notice) String() string

+ func (n *Notice) UnmarshalJSON(data []byte) error

+ type NoticeFilter struct

+ After time.Time

+ Keys []string

+ Types []NoticeType

+ type NoticeType string

+ const ChangeUpdateNotice

+ const CustomNotice

+ const WarningNotice

+ func (t NoticeType) Valid() bool

type State

+ func (s *State) AddNotice(noticeType NoticeType, key string, options *AddNoticeOptions) (string, error)

+ func (s *State) Notice(id string) *Notice

+ func (s *State) Notices(filter *NoticeFilter) []*Notice

+ func (s *State) WaitNotices(ctx context.Context, filter *NoticeFilter) ([]*Notice, error)

Feb 20, 2024 GO-2024-2692

  GO-2024-2692: Pebble service manager's file pull API allows access by any user in github.com/canonical/pebble

Sep 28, 2023 GO-2024-2692

  GO-2024-2692: Pebble service manager's file pull API allows access by any user in github.com/canonical/pebble

Sep 3, 2023 GO-2024-2692

  GO-2024-2692: Pebble service manager's file pull API allows access by any user in github.com/canonical/pebble

Changes in this version

+ const LogError

+ const LogInfo

+ var DefaultExpireAfter = time.Hour * 24 * 28

+ var DefaultRepeatAfter = time.Hour * 24

+ var ErrNoState = errors.New("no state entry for key")

+ func FakeTime(now time.Time) (restore func())

+ type Backend interface

+ Checkpoint func(data []byte) error

+ EnsureBefore func(d time.Duration)

+ type Change struct

+ func (c *Change) Abort()

+ func (c *Change) AbortLanes(lanes []int)

+ func (c *Change) AddAll(ts *TaskSet)

+ func (c *Change) AddTask(t *Task)

+ func (c *Change) Err() error

+ func (c *Change) Get(key string, value interface{}) error

+ func (c *Change) ID() string

+ func (c *Change) IsClean() bool

+ func (c *Change) IsReady() bool

+ func (c *Change) Kind() string

+ func (c *Change) LaneTasks(lanes ...int) []*Task

+ func (c *Change) MarshalJSON() ([]byte, error)

+ func (c *Change) Ready() <-chan struct{}

+ func (c *Change) ReadyTime() time.Time

+ func (c *Change) Set(key string, value interface{})

+ func (c *Change) SetStatus(s Status)

+ func (c *Change) SpawnTime() time.Time

+ func (c *Change) State() *State

+ func (c *Change) Status() Status

+ func (c *Change) Summary() string

+ func (c *Change) Tasks() []*Task

+ func (c *Change) UnmarshalJSON(data []byte) error

+ type HandlerFunc func(task *Task, tomb *tomb.Tomb) error

+ type Retry struct

+ After time.Duration

+ Reason string

+ func (r *Retry) Error() string

+ type State struct

+ func New(backend Backend) *State

+ func ReadState(backend Backend, r io.Reader) (*State, error)

+ func (s *State) AllWarnings() []*Warning

+ func (s *State) Cache(key, value interface{})

+ func (s *State) Cached(key interface{}) interface{}

+ func (s *State) Change(id string) *Change

+ func (s *State) Changes() []*Change

+ func (s *State) EnsureBefore(d time.Duration)

+ func (s *State) Get(key string, value interface{}) error

+ func (s *State) Lock()

+ func (s *State) MarshalJSON() ([]byte, error)

+ func (s *State) Modified() bool

+ func (s *State) NewChange(kind, summary string) *Change

+ func (s *State) NewLane() int

+ func (s *State) NewTask(kind, summary string) *Task

+ func (s *State) OkayWarnings(t time.Time) int

+ func (s *State) PendingWarnings() ([]*Warning, time.Time)

+ func (s *State) Prune(pruneWait, abortWait time.Duration, maxReadyChanges int)

+ func (s *State) Set(key string, value interface{})

+ func (s *State) Task(id string) *Task

+ func (s *State) TaskCount() int

+ func (s *State) Tasks() []*Task

+ func (s *State) Unlock()

+ func (s *State) UnmarshalJSON(data []byte) error

+ func (s *State) UnshowAllWarnings()

+ func (s *State) Warnf(template string, args ...interface{})

+ func (s *State) WarningsSummary() (int, time.Time)

+ type Status int

+ const AbortStatus

+ const DefaultStatus

+ const DoStatus

+ const DoingStatus

+ const DoneStatus

+ const ErrorStatus

+ const HoldStatus

+ const UndoStatus

+ const UndoingStatus

+ const UndoneStatus

+ func (s Status) Ready() bool

+ func (s Status) String() string

+ type Task struct

+ func (t *Task) At(when time.Time)

+ func (t *Task) AtTime() time.Time

+ func (t *Task) Change() *Change

+ func (t *Task) Clear(key string)

+ func (t *Task) DoingTime() time.Duration

+ func (t *Task) Errorf(format string, args ...interface{})

+ func (t *Task) Get(key string, value interface{}) error

+ func (t *Task) HaltTasks() []*Task

+ func (t *Task) Has(key string) bool

+ func (t *Task) ID() string

+ func (t *Task) IsClean() bool

+ func (t *Task) JoinLane(lane int)

+ func (t *Task) Kind() string

+ func (t *Task) Lanes() []int

+ func (t *Task) Log() []string

+ func (t *Task) Logf(format string, args ...interface{})

+ func (t *Task) MarshalJSON() ([]byte, error)

+ func (t *Task) NumHaltTasks() int

+ func (t *Task) Progress() (label string, done, total int)

+ func (t *Task) ReadyTime() time.Time

+ func (t *Task) Set(key string, value interface{})

+ func (t *Task) SetClean()

+ func (t *Task) SetProgress(label string, done, total int)

+ func (t *Task) SetStatus(new Status)

+ func (t *Task) SpawnTime() time.Time

+ func (t *Task) State() *State

+ func (t *Task) Status() Status

+ func (t *Task) Summary() string

+ func (t *Task) UndoingTime() time.Duration

+ func (t *Task) UnmarshalJSON(data []byte) error

+ func (t *Task) WaitAll(ts *TaskSet)

+ func (t *Task) WaitFor(another *Task)

+ func (t *Task) WaitTasks() []*Task

+ type TaskRunner struct

+ func NewTaskRunner(s *State) *TaskRunner

+ func (r *TaskRunner) AddBlocked(pred func(t *Task, running []*Task) bool)

+ func (r *TaskRunner) AddCleanup(kind string, cleanup HandlerFunc)

+ func (r *TaskRunner) AddHandler(kind string, do, undo HandlerFunc)

+ func (r *TaskRunner) AddOptionalHandler(match func(t *Task) bool, do, undo HandlerFunc)

+ func (r *TaskRunner) Ensure() error

+ func (r *TaskRunner) KnownTaskKinds() []string

+ func (r *TaskRunner) SetBlocked(pred func(t *Task, running []*Task) bool)

+ func (r *TaskRunner) Stop()

+ func (r *TaskRunner) StopKinds(kind ...string)

+ func (r *TaskRunner) Wait()

+ type TaskSet struct

+ func NewTaskSet(tasks ...*Task) *TaskSet

+ func (ts *TaskSet) AddAll(anotherTs *TaskSet)

+ func (ts *TaskSet) AddAllWithEdges(anotherTs *TaskSet) error

+ func (ts *TaskSet) AddTask(task *Task)

+ func (ts *TaskSet) JoinLane(lane int)

+ func (ts *TaskSet) MarkEdge(task *Task, edge TaskSetEdge)

+ func (ts *TaskSet) WaitAll(anotherTs *TaskSet)

+ func (ts TaskSet) Edge(e TaskSetEdge) (*Task, error)

+ func (ts TaskSet) Tasks() []*Task

+ func (ts TaskSet) WaitFor(another *Task)

+ type TaskSetEdge string

+ type Warning struct

+ func (w *Warning) ExpiredBefore(now time.Time) bool

+ func (w *Warning) MarshalJSON() ([]byte, error)

+ func (w *Warning) ShowAfter(t time.Time) bool

+ func (w *Warning) String() string

+ func (w *Warning) UnmarshalJSON(data []byte) error