service

Documentation

Index

• type ChfApp
  • func NewApp(ctx context.Context, cfg *factory.Config, tlsKeyLogPath string) (*ChfApp, error)
  • func (a *ChfApp) CallServerStop()
  • func (a *ChfApp) CancelContext() context.Context
  • func (a *ChfApp) Config() *factory.Config
  • func (a *ChfApp) Consumer() *consumer.Consumer
  • func (a *ChfApp) Context() *chf_context.CHFContext
  • func (a *ChfApp) Processor() *processor.Processor
  • func (c *ChfApp) SetLogEnable(enable bool)
  • func (c *ChfApp) SetLogLevel(level string)
  • func (c *ChfApp) SetReportCaller(reportCaller bool)
  • func (a *ChfApp) Start()
  • func (c *ChfApp) Terminate()
  • func (a *ChfApp) WaitRoutineStopped()

Types

type ChfApp

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

var CHF *ChfApp

func NewApp

func NewApp(ctx context.Context, cfg *factory.Config, tlsKeyLogPath string) (*ChfApp, error)

func (*ChfApp) CallServerStop

func (a *ChfApp) CallServerStop()

func (*ChfApp) CancelContext

func (a *ChfApp) CancelContext() context.Context

func (*ChfApp) Config

func (a *ChfApp) Config() *factory.Config

func (*ChfApp) Consumer

func (a *ChfApp) Consumer() *consumer.Consumer

func (*ChfApp) Context

func (a *ChfApp) Context() *chf_context.CHFContext

func (*ChfApp) Processor

func (a *ChfApp) Processor() *processor.Processor

func (*ChfApp) SetLogEnable

func (c *ChfApp) SetLogEnable(enable bool)

func (*ChfApp) SetLogLevel

func (c *ChfApp) SetLogLevel(level string)

func (*ChfApp) SetReportCaller

func (c *ChfApp) SetReportCaller(reportCaller bool)

func (*ChfApp) Start

func (a *ChfApp) Start()

func (*ChfApp) Terminate

func (c *ChfApp) Terminate()

func (*ChfApp) WaitRoutineStopped

func (a *ChfApp) WaitRoutineStopped()