manager

Documentation

Index

• type Manager
  • func NewManager(ctx context.Context, opts ...ManagerOption) (*Manager, error)
  • func (m *Manager) CalculateTriggerUrl(trigger *modconfig.Trigger) (string, error)
  • func (m *Manager) Initialize() error
  • func (m *Manager) InterruptHandler()
  • func (m *Manager) ReloadPipelinesAndTriggers(pipelines map[string]*modconfig.Pipeline, ...) error
  • func (m *Manager) Start() error
  • func (m *Manager) Stop() error
• type ManagerOption
  • func WithHTTPAddress(addr string) ManagerOption
  • func WithRaftAddress(addr string) ManagerOption
  • func WithRaftBootstrap(bootstrap bool) ManagerOption
  • func WithRaftNodeID(nodeID string) ManagerOption

Types

type Manager

type Manager struct {
	RootMod *modconfig.Mod

	RaftNodeID    string `json:"raft_node_id,omitempty"`
	RaftBootstrap bool   `json:"raft_bootstrap"`
	RaftAddress   string `json:"raft_address,omitempty"`

	HTTPSAddress string `json:"https_address,omitempty"`

	Status    string     `json:"status"`
	StartedAt *time.Time `json:"started_at,omitempty"`
	StoppedAt *time.Time `json:"stopped_at,omitempty"`
	// contains filtered or unexported fields
}

Manager manages and represents the status of the service.

func NewManager

func NewManager(ctx context.Context, opts ...ManagerOption) (*Manager, error)

NewManager creates a new Manager.

func (*Manager) CalculateTriggerUrl

func (m *Manager) CalculateTriggerUrl(trigger *modconfig.Trigger) (string, error)

func (*Manager) Initialize

func (m *Manager) Initialize() error

TODO: is there any point to have a separate "Initialize" and "Start"?

func (*Manager) InterruptHandler

func (m *Manager) InterruptHandler()

func (*Manager) ReloadPipelinesAndTriggers

func (m *Manager) ReloadPipelinesAndTriggers(pipelines map[string]*modconfig.Pipeline, triggers map[string]*modconfig.Trigger) error

func (*Manager) Start

func (m *Manager) Start() error

Start starts services managed by the Manager.

func (*Manager) Stop

func (m *Manager) Stop() error

Stop stops services managed by the Manager.

type ManagerOption

type ManagerOption func(*Manager) error

ManagerOption defines a type of function to configures the Manager.

func WithHTTPAddress

func WithHTTPAddress(addr string) ManagerOption

func WithRaftAddress

func WithRaftAddress(addr string) ManagerOption

func WithRaftBootstrap

func WithRaftBootstrap(bootstrap bool) ManagerOption

func WithRaftNodeID

func WithRaftNodeID(nodeID string) ManagerOption