es

Documentation

Index

• type ESService
  • func NewESService(ctx context.Context) (*ESService, error)
  • func (es *ESService) IsRunning() bool
  • func (es *ESService) Raise(evt interface{}) error
  • func (es *ESService) Send(cmd interface{}) error
  • func (es *ESService) Start() error
  • func (es *ESService) Stop() error

Types

type ESService

type ESService struct {
	CommandBus handler.FpCommandBus
	EventBus   command.FpEventBus

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

func NewESService

func NewESService(ctx context.Context) (*ESService, error)

func (*ESService) IsRunning

func (es *ESService) IsRunning() bool

func (*ESService) Raise

func (es *ESService) Raise(evt interface{}) error

func (*ESService) Send

func (es *ESService) Send(cmd interface{}) error

func (*ESService) Start

func (es *ESService) Start() error

func (*ESService) Stop

func (es *ESService) Stop() error