context

Documentation

Index

• type RootContext
  • func NewRootContext(config *config.Config, logger *log.Logger) *RootContext
  • func (c *RootContext) Reset()
  • func (c *RootContext) Start()
  • func (c *RootContext) Stop()

Types

type RootContext

type RootContext struct {
	// Config and instance of the configuration object
	Config *config.Config
	// Replicas instance of the ReplicaStore which contains information of all the replicas
	Replicas *types.ReplicaStore
	// LogStore which stores the log messages sent by the replicas
	LogStore *types.ReplicaLogStore
	// MessageQueue stores the messages that are _intercepted_ as a queue
	MessageQueue *types.MessageQueue
	// MessageStore stores the messages that are _intercepted_ as a map
	MessageStore *types.MessageStore
	// EventQueue stores the events sent by the replicas as a queue
	EventQueue *types.EventQueue
	// LogQueue stores the log messages sent by the replicas as a queue
	LogQueue *types.ReplicaLogQueue
	// TimeoutStore stores the timeouts that are dispatched by the replica and contains the strategy
	TimeoutStore *types.TimeoutStore
	// Counter is a thread safe monotonic integer counter
	Counter *util.Counter
	// Logger for logging purposes
	Logger *log.Logger
}

RootContext stores the context of the scheduler

func NewRootContext

func NewRootContext(config *config.Config, logger *log.Logger) *RootContext

NewRootContext creates an instance of the RootContext from the configuration

func (*RootContext) Reset

func (c *RootContext) Reset()

Reset implements Service

func (*RootContext) Start

func (c *RootContext) Start()

Start implements Service and initializes the queues

func (*RootContext) Stop

func (c *RootContext) Stop()

Stop implements Service and terminates the queues