app

Documentation

Index

• func Run(ctx context.Context, cancel context.CancelFunc, op *options.ServerOption) error
• type EventServer
  • func NewEventServer(ctx context.Context, op *options.ServerOption) (*EventServer, error)
  • func (es *EventServer) DB() dal.RDB
  • func (es *EventServer) Engine() *backbone.Engine
  • func (es *EventServer) OnHostConfigUpdate(prev, curr cc.ProcessConfig)
  • func (es *EventServer) RedisCli() *redis.Client
  • func (es *EventServer) Run() error
  • func (es *EventServer) Service() *svc.Service

Functions

func Run

func Run(ctx context.Context, cancel context.CancelFunc, op *options.ServerOption) error

Run setups a new EventServer app with a context and options and runs it as server instance.

Types

type EventServer

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

EventServer is event server.

func NewEventServer

func NewEventServer(ctx context.Context, op *options.ServerOption) (*EventServer, error)

NewEventServer creates a new EventServer object.

func (*EventServer) DB

func (es *EventServer) DB() dal.RDB

DB returns cc database client of the EventServer instance.

func (*EventServer) Engine

func (es *EventServer) Engine() *backbone.Engine

Engine returns engine of the EventServer instance.

func (*EventServer) OnHostConfigUpdate

func (es *EventServer) OnHostConfigUpdate(prev, curr cc.ProcessConfig)

OnHostConfigUpdate is callback for updating configs.

func (*EventServer) RedisCli

func (es *EventServer) RedisCli() *redis.Client

RedisCli returns cc redis client of the EventServer instance.

func (*EventServer) Run

func (es *EventServer) Run() error

Run runs a new EventServer.

func (*EventServer) Service

func (es *EventServer) Service() *svc.Service

Service returns main service of the EventServer instance.