bootstrap

Documentation

Index

• type Bootstrapper
  • func New() Bootstrapper
• type OptionService
  • func NewGokaConsumerGroup(params consumer.GokaConsumerGroupOpt) OptionService
  • func NewGokaProducer(params producer.GokaProducerOpt) OptionService
  • func NewGokaViewTable(params viewtable.GokaViewTableOpt) OptionService
  • func NewServiceRest(param rest.Options) OptionService

Types

type Bootstrapper

type Bootstrapper interface {
	Initialize(cfgFile string)
	AddServices(services ...OptionService)
	Close()
	GetTopicManagerConfig() *goka.TopicManagerConfig
	GetRegistryRest() *restRegistry.ServiceRegistry
	GetRegistryConsumer() *consumerRegistry.ServiceRegistry
	GetRest() interfaces.Rest
	RunServices()
}

func New

func New() Bootstrapper

type OptionService

type OptionService func(b *bootstrap)

func NewGokaConsumerGroup

func NewGokaConsumerGroup(params consumer.GokaConsumerGroupOpt) OptionService

func NewGokaProducer

func NewGokaProducer(params producer.GokaProducerOpt) OptionService

func NewGokaViewTable

func NewGokaViewTable(params viewtable.GokaViewTableOpt) OptionService

func NewServiceRest

func NewServiceRest(param rest.Options) OptionService