machine

Mar 22, 2023

Changes in this version

type Machine

+ func (m *Machine) SetSignerKey(pk string)

+ func (m *Machine) SignerKey() string

Sep 21, 2021

Changes in this version

+ type ActivationChecker func(*logrus.Entry) bool

type Machine

+ ActivationCheck ActivationChecker

+ func FromPlugin(p model.MachineConstructor, manager WatcherManager, log *logrus.Entry) (*Machine, error)

+ func (m *Machine) IsEmbedded() bool

+ func (m *Machine) IsStarted() bool

+ func (m *Machine) SetDirectory(dir string, manifest string) error

Aug 24, 2021

Changes in this version

type Machine

+ func (m *Machine) Data() map[string]interface{}

+ func (m *Machine) DataDelete(key string) error

+ func (m *Machine) DataGet(key string) (interface{}, bool)

+ func (m *Machine) DataPut(key string, val interface{}) error

+ func (m *Machine) Facts() json.RawMessage

+ func (m *Machine) JetStreamConnection() (*jsm.Manager, error)

+ func (m *Machine) MainCollective() string

+ func (m *Machine) PublishLifecycleEvent(t lifecycle.Type, opts ...lifecycle.Option)

+ func (m *Machine) SetConnection(conn choria.Connector) error

+ func (m *Machine) SetFactSource(facts func() json.RawMessage)

+ func (m *Machine) SetMainCollective(collective string)

Apr 22, 2021

Changes in this version

type Transition

+ Description string

Jan 13, 2021

Changes in this version

type Machine

+ func (m *Machine) ChoriaStatusFile() (string, int)

+ func (m *Machine) SetChoriaStatusFile(f string, freq int)

Sep 28, 2020

Changes in this version

type Machine

+ func (m *Machine) WatcherState(watcher string) (interface{}, bool)

type WatcherManager

+ WatcherState func(watcher string) (interface{}, bool)

Jul 18, 2020

Changes in this version

type Machine

+ func (m *Machine) GossFilePath() string

+ func (m *Machine) SetGossFile(f string)

Jul 1, 2020

Changes in this version

type Machine

+ func (m *Machine) Delete()

+ func (m *Machine) OverrideData() ([]byte, error)

+ func (m *Machine) SetOverridesFile(f string)

+ func (m *Machine) SetTextFileDirectory(d string)

+ func (m *Machine) TextFileDirectory() string

type WatcherManager

+ Delete func()

type WatcherStateNotification

+ SenderID func() string

Dec 7, 2019

Changes in this version

type TransitionNotification

+ func (t *TransitionNotification) CloudEvent() cloudevents.Event

type WatcherStateNotification

+ CloudEvent func() cloudevents.Event

Sep 9, 2019

Changes in this version

+ func ValidateDir(dir string) (validationErrors []string, err error)

+ type InfoSource interface

+ Identity func() string

+ InstanceID func() string

+ Name func() string

+ State func() string

+ Version func() string

+ type Machine struct

+ InitialState string

+ MachineName string

+ MachineVersion string

+ SplayStart int

+ Transitions []*Transition

+ WatcherDefs []*watchers.WatcherDef

+ func FromDir(dir string, manager WatcherManager) (m *Machine, err error)

+ func FromYAML(file string, manager WatcherManager) (m *Machine, err error)

+ func (m *Machine) AvailableTransitions() []string

+ func (m *Machine) Can(t string) bool

+ func (m *Machine) Debugf(watcher string, format string, args ...interface{})

+ func (m *Machine) Directory() string

+ func (m *Machine) Errorf(watcher string, format string, args ...interface{})

+ func (m *Machine) Graph() string

+ func (m *Machine) Hash() (string, error)

+ func (m *Machine) Identity() string

+ func (m *Machine) Infof(watcher string, format string, args ...interface{})

+ func (m *Machine) InstanceID() string

+ func (m *Machine) KnownStates() []string

+ func (m *Machine) KnownTransitions() []string

+ func (m *Machine) Name() string

+ func (m *Machine) NotifyWatcherState(watcher string, state interface{})

+ func (m *Machine) RegisterNotifier(services ...NotificationService)

+ func (m *Machine) SetIdentity(id string)

+ func (m *Machine) Setup() error

+ func (m *Machine) Start(ctx context.Context, wg *sync.WaitGroup) (started chan struct{})

+ func (m *Machine) StartTime() time.Time

+ func (m *Machine) State() string

+ func (m *Machine) Stop()

+ func (m *Machine) TimeStamp() time.Time

+ func (m *Machine) TimeStampSeconds() int64

+ func (m *Machine) Transition(t string, args ...interface{}) error

+ func (m *Machine) UniqueID() (id string)

+ func (m *Machine) Validate() error

+ func (m *Machine) Version() string

+ func (m *Machine) Warnf(watcher string, format string, args ...interface{})

+ func (m *Machine) Watchers() []*watchers.WatcherDef

+ type NotificationService interface

+ Debugf func(machine InfoSource, watcher string, format string, args ...interface{})

+ Errorf func(machine InfoSource, watcher string, format string, args ...interface{})

+ Infof func(machine InfoSource, watcher string, format string, args ...interface{})

+ NotifyPostTransition func(t *TransitionNotification) error

+ NotifyWatcherState func(watcher string, state WatcherStateNotification) error

+ Warnf func(machine InfoSource, watcher string, format string, args ...interface{})

+ type Transition struct

+ Destination string

+ From []string

+ Name string

+ type TransitionNotification struct

+ FromState string

+ ID string

+ Identity string

+ Info InfoSource

+ Machine string

+ Protocol string

+ Timestamp int64

+ ToState string

+ Transition string

+ Version string

+ func (t *TransitionNotification) String() string

+ type WatcherManager interface

+ NotifyStateChance func()

+ Run func(context.Context, *sync.WaitGroup) error

+ SetMachine func(interface{}) error

+ type WatcherStateNotification interface

+ JSON func() ([]byte, error)

+ String func() string

+ WatcherType func() string

+ func ParseWatcherState(state []byte) (n WatcherStateNotification, err error)