orchestrator

Documentation

Index

• type Orchestrator
  • func New(rpc *cosmos.RPC, ep *publisher.EventPublisher, logger tmlog.Logger) *Orchestrator
  • func (s *Orchestrator) Start() error
  • func (s *Orchestrator) Stop()

Types

type Orchestrator

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

Orchestrator manages the executions based on the definition of the processes

func New

func New(rpc *cosmos.RPC, ep *publisher.EventPublisher, logger tmlog.Logger) *Orchestrator

New creates a new Process instance

func (*Orchestrator) Start

func (s *Orchestrator) Start() error

Start the process engine

func (*Orchestrator) Stop

func (s *Orchestrator) Stop()

Stop stops the orchestrator engine