v1

Documentation

Index

• Constants
• func Generator() lib.Node
• func NewNode() lib.Node
• type Config
  • func NewConfig() *Config
• type Node
  • func (n *Node) ExportConfig() ([]byte, error)
  • func (n *Node) HaltSignal() chan bool
  • func (n *Node) ImportConfig(raw []byte) error
  • func (n *Node) Initialize() error
  • func (n *Node) IoC() lib.IoC
  • func (n *Node) IsHalted() bool
  • func (n *Node) Log() *log.Logger
  • func (n *Node) ModuleName() string
  • func (n *Node) SetIoC(ioc lib.IoC)
  • func (n *Node) SetIsHalted(isHalted bool)
  • func (n *Node) Start() error
  • func (n *Node) Stop() error
  • func (n *Node) WaitGroup() *sync.WaitGroup

Constants

const (
	MODULE_NAME = "node/croncache/v1"
)

Functions

func Generator

func Generator() lib.Node

func NewNode

func NewNode() lib.Node

Types

type Config

type Config struct {
	LogFilePath string
	TaskManager *json.RawMessage
}

func NewConfig

func NewConfig() *Config

type Node

type Node struct {
	lib.Node
	// contains filtered or unexported fields
}

func (*Node) ExportConfig

func (n *Node) ExportConfig() ([]byte, error)

func (*Node) HaltSignal

func (n *Node) HaltSignal() chan bool

func (*Node) ImportConfig

func (n *Node) ImportConfig(raw []byte) error

func (*Node) Initialize

func (n *Node) Initialize() error

func (*Node) IoC

func (n *Node) IoC() lib.IoC

func (*Node) IsHalted

func (n *Node) IsHalted() bool

func (*Node) Log

func (n *Node) Log() *log.Logger

func (*Node) ModuleName

func (n *Node) ModuleName() string

func (*Node) SetIoC

func (n *Node) SetIoC(ioc lib.IoC)

func (*Node) SetIsHalted

func (n *Node) SetIsHalted(isHalted bool)

func (*Node) Start

func (n *Node) Start() error

func (*Node) Stop

func (n *Node) Stop() error

func (*Node) WaitGroup

func (n *Node) WaitGroup() *sync.WaitGroup