core

Documentation

Index

• func NewCore(ctx context.Context, options Options) (adapter.Core, log.Logger, error)
• type Core
  • func (c *Core) Close() error
  • func (c *Core) GetListener(tag string) adapter.Listener
  • func (c *Core) GetListeners() []adapter.Listener
  • func (c *Core) GetPluginExecutor(tag string) adapter.PluginExecutor
  • func (c *Core) GetPluginExecutors() []adapter.PluginExecutor
  • func (c *Core) GetPluginMatcher(tag string) adapter.PluginMatcher
  • func (c *Core) GetPluginMatchers() []adapter.PluginMatcher
  • func (c *Core) GetTimeFunc() func() time.Time
  • func (c *Core) GetUpstream(tag string) adapter.Upstream
  • func (c *Core) GetUpstreams() []adapter.Upstream
  • func (c *Core) GetWorkflow(tag string) adapter.Workflow
  • func (c *Core) GetWorkflows() []adapter.Workflow
  • func (c *Core) RootLogger() log.Logger
  • func (c *Core) Run() error
• type LogOptions
• type Options

Functions

func NewCore

func NewCore(ctx context.Context, options Options) (adapter.Core, log.Logger, error)

Types

type Core

type Core struct {
	// contains filtered or unexported fields
}

func (*Core) Close

func (c *Core) Close() error

func (*Core) GetListener

func (c *Core) GetListener(tag string) adapter.Listener

func (*Core) GetListeners

func (c *Core) GetListeners() []adapter.Listener

func (*Core) GetPluginExecutor

func (c *Core) GetPluginExecutor(tag string) adapter.PluginExecutor

func (*Core) GetPluginExecutors

func (c *Core) GetPluginExecutors() []adapter.PluginExecutor

func (*Core) GetPluginMatcher

func (c *Core) GetPluginMatcher(tag string) adapter.PluginMatcher

func (*Core) GetPluginMatchers

func (c *Core) GetPluginMatchers() []adapter.PluginMatcher

func (*Core) GetTimeFunc

func (c *Core) GetTimeFunc() func() time.Time

func (*Core) GetUpstream

func (c *Core) GetUpstream(tag string) adapter.Upstream

func (*Core) GetUpstreams

func (c *Core) GetUpstreams() []adapter.Upstream

func (*Core) GetWorkflow

func (c *Core) GetWorkflow(tag string) adapter.Workflow

func (*Core) GetWorkflows

func (c *Core) GetWorkflows() []adapter.Workflow

func (*Core) RootLogger

func (c *Core) RootLogger() log.Logger

func (*Core) Run

func (c *Core) Run() error

type LogOptions

type LogOptions struct {
	Disabled         bool   `yaml:"disabled,omitempty"`
	Level            string `yaml:"level,omitempty"`
	Output           string `yaml:"output,omitempty"`
	DisableTimestamp bool   `yaml:"disable-timestamp,omitempty"`
	DisableColor     bool   `yaml:"disable-color,omitempty"`
}

type Options

type Options struct {
	Log             LogOptions                     `yaml:"log,omitempty"`
	API             *api.Options                   `yaml:"api,omitempty"`
	Upstreams       []upstream.Options             `yaml:"upstreams,omitempty"`
	Workflows       []workflow.WorkflowOptions     `yaml:"workflows,omitempty"`
	Listeners       []listener.Options             `yaml:"listeners,omitempty"`
	PluginMatchers  []plugin.PluginMatcherOptions  `yaml:"plugin-matchers,omitempty"`
	PluginExecutors []plugin.PluginExecutorOptions `yaml:"plugin-executors,omitempty"`
	NTP             *ntp.NTPOptions                `yaml:"ntp,omitempty"`
}