interfaces

Documentation

Index

• type Application
• type Consumer
  • func (q *Consumer) IsBackground() bool
  • func (q *Consumer) Priority() int
  • func (q *Consumer) Run(ctx context.Context, servers []configs.Server)
• type Database
  • func (d *Database) IsBackground() bool
  • func (d *Database) Priority() int
  • func (d *Database) Run(ctx context.Context, servers []configs.Server)
• type Elasticsearch
  • func (e *Elasticsearch) IsBackground() bool
  • func (e *Elasticsearch) Priority() int
  • func (e *Elasticsearch) Run(ctx context.Context, servers []configs.Server)
• type Factory
  • func (f *Factory) Add(application Application)
  • func (f *Factory) Register(applications ...Application)
  • func (f *Factory) Run(servers []configs.Server)
• type GRpc
  • func (g *GRpc) IsBackground() bool
  • func (g *GRpc) Priority() int
  • func (g *GRpc) Run(ctx context.Context, servers []configs.Server)
• type Rest
  • func (r *Rest) IsBackground() bool
  • func (r *Rest) Priority() int
  • func (r *Rest) Run(ctx context.Context, servers []configs.Server)

Types

type Application

type Application interface {
	Run(ctx context.Context, servers []configs.Server)
	IsBackground() bool
	Priority() int
}

type Consumer

type Consumer struct {
	Messenger *messengers.Messenger
}

func (*Consumer) IsBackground

func (q *Consumer) IsBackground() bool

func (*Consumer) Priority

func (q *Consumer) Priority() int

func (*Consumer) Run

func (q *Consumer) Run(ctx context.Context, servers []configs.Server)

type Database

type Database struct {
}

func (*Database) IsBackground

func (d *Database) IsBackground() bool

func (*Database) Priority

func (d *Database) Priority() int

func (*Database) Run

func (d *Database) Run(ctx context.Context, servers []configs.Server)

type Elasticsearch

type Elasticsearch struct {
	Client *elastic.Client
}

func (*Elasticsearch) IsBackground

func (e *Elasticsearch) IsBackground() bool

func (*Elasticsearch) Priority

func (e *Elasticsearch) Priority() int

func (*Elasticsearch) Run

func (e *Elasticsearch) Run(ctx context.Context, servers []configs.Server)

type Factory

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

func (*Factory) Add

func (f *Factory) Add(application Application)

func (*Factory) Register

func (f *Factory) Register(applications ...Application)

func (*Factory) Run

func (f *Factory) Run(servers []configs.Server)

type GRpc

type GRpc struct {
	GRpcPort int
	Debug    bool
}

func (*GRpc) IsBackground

func (g *GRpc) IsBackground() bool

func (*GRpc) Priority

func (g *GRpc) Priority() int

func (*GRpc) Run

func (g *GRpc) Run(ctx context.Context, servers []configs.Server)

type Rest

type Rest struct {
	HttpPort   int
	Middleware *middlewares.Factory
	Router     *routers.Factory
	GRpcClient *grpc.ClientConn
}

func (*Rest) IsBackground

func (r *Rest) IsBackground() bool

func (*Rest) Priority

func (r *Rest) Priority() int

func (*Rest) Run

func (r *Rest) Run(ctx context.Context, servers []configs.Server)