app

Documentation

Index

• Variables
• func NewApplication(config *config.Config, opts ...Option) contracts.ApplicationInterface
• type Application
  • func (app *Application) AddServer(server contracts.Server)
  • func (app *Application) Auth() contracts.AuthInterface
  • func (app *Application) BeforeServerRunHooks(cb contracts.Callback)
  • func (app *Application) Bootstrap() error
  • func (app *Application) Cache() contracts.CacheInterface
  • func (app *Application) CacheLock() contracts.Locker
  • func (app *Application) Config() *config.Config
  • func (app *Application) CronManager() contracts.CronManager
  • func (app *Application) DB() *gorm.DB
  • func (app *Application) DBManager() contracts.DBManager
  • func (app *Application) Done() <-chan struct{}
  • func (app *Application) EventDispatcher() contracts.DispatcherInterface
  • func (app *Application) GetPluginByName(name string) contracts.PluginInterface
  • func (app *Application) GetPlugins() map[string]contracts.PluginInterface
  • func (app *Application) GetTracer() trace.Tracer
  • func (app *Application) IsDebug() bool
  • func (app *Application) K8sClient() *contracts.K8sClient
  • func (app *Application) LocalUploader() contracts.Uploader
  • func (app *Application) Oidc() contracts.OidcConfig
  • func (app *Application) RegisterAfterShutdownFunc(fn contracts.Callback)
  • func (app *Application) RegisterBeforeShutdownFunc(fn contracts.Callback)
  • func (app *Application) Run() context.Context
  • func (app *Application) RunServerHooks(hook Hook)
  • func (app *Application) SetAuth(auth contracts.AuthInterface)
  • func (app *Application) SetCache(c contracts.CacheInterface)
  • func (app *Application) SetCacheLock(l contracts.Locker)
  • func (app *Application) SetCronManager(m contracts.CronManager)
  • func (app *Application) SetEventDispatcher(dispatcher contracts.DispatcherInterface)
  • func (app *Application) SetK8sClient(client *contracts.K8sClient)
  • func (app *Application) SetLocalUploader(uploader contracts.Uploader)
  • func (app *Application) SetOidc(provider contracts.OidcConfig)
  • func (app *Application) SetPlugins(plugins map[string]contracts.PluginInterface)
  • func (app *Application) SetTracer(t trace.Tracer)
  • func (app *Application) SetUploader(uploader contracts.Uploader)
  • func (app *Application) Shutdown()
  • func (app *Application) Singleflight() *singleflight.Group
  • func (app *Application) Uploader() contracts.Uploader
• type Hook
• type Option
  • func WithBootstrappers(bootstrappers ...contracts.Bootstrapper) Option
  • func WithExcludeTags(tags ...string) Option
  • func WithMustBootedBootstrappers(bootstrappers ...contracts.Bootstrapper) Option

Variables

var MustBooted = []contracts.Bootstrapper{
	&bootstrappers.LogBootstrapper{},
}

Functions

func NewApplication

func NewApplication(config *config.Config, opts ...Option) contracts.ApplicationInterface

Types

type Application

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

func (*Application) AddServer

func (app *Application) AddServer(server contracts.Server)

func (*Application) Auth

func (app *Application) Auth() contracts.AuthInterface

func (*Application) BeforeServerRunHooks

func (app *Application) BeforeServerRunHooks(cb contracts.Callback)

func (*Application) Bootstrap

func (app *Application) Bootstrap() error

func (*Application) Cache

func (app *Application) Cache() contracts.CacheInterface

func (*Application) CacheLock

func (app *Application) CacheLock() contracts.Locker

func (*Application) Config

func (app *Application) Config() *config.Config

func (*Application) CronManager

func (app *Application) CronManager() contracts.CronManager

func (*Application) DB

func (app *Application) DB() *gorm.DB

func (*Application) DBManager

func (app *Application) DBManager() contracts.DBManager

func (*Application) Done

func (app *Application) Done() <-chan struct{}

func (*Application) EventDispatcher

func (app *Application) EventDispatcher() contracts.DispatcherInterface

func (*Application) GetPluginByName

func (app *Application) GetPluginByName(name string) contracts.PluginInterface

func (*Application) GetPlugins

func (app *Application) GetPlugins() map[string]contracts.PluginInterface

func (*Application) GetTracer

func (app *Application) GetTracer() trace.Tracer

func (*Application) IsDebug

func (app *Application) IsDebug() bool

func (*Application) K8sClient

func (app *Application) K8sClient() *contracts.K8sClient

func (*Application) LocalUploader

func (app *Application) LocalUploader() contracts.Uploader

func (*Application) Oidc

func (app *Application) Oidc() contracts.OidcConfig

func (*Application) RegisterAfterShutdownFunc

func (app *Application) RegisterAfterShutdownFunc(fn contracts.Callback)

func (*Application) RegisterBeforeShutdownFunc

func (app *Application) RegisterBeforeShutdownFunc(fn contracts.Callback)

func (*Application) Run

func (app *Application) Run() context.Context

func (*Application) RunServerHooks

func (app *Application) RunServerHooks(hook Hook)

func (*Application) SetAuth

func (app *Application) SetAuth(auth contracts.AuthInterface)

func (*Application) SetCache

func (app *Application) SetCache(c contracts.CacheInterface)

func (*Application) SetCacheLock

func (app *Application) SetCacheLock(l contracts.Locker)

func (*Application) SetCronManager

func (app *Application) SetCronManager(m contracts.CronManager)

func (*Application) SetEventDispatcher

func (app *Application) SetEventDispatcher(dispatcher contracts.DispatcherInterface)

func (*Application) SetK8sClient

func (app *Application) SetK8sClient(client *contracts.K8sClient)

func (*Application) SetLocalUploader

func (app *Application) SetLocalUploader(uploader contracts.Uploader)

func (*Application) SetOidc

func (app *Application) SetOidc(provider contracts.OidcConfig)

func (*Application) SetPlugins

func (app *Application) SetPlugins(plugins map[string]contracts.PluginInterface)

func (*Application) SetTracer

func (app *Application) SetTracer(t trace.Tracer)

func (*Application) SetUploader

func (app *Application) SetUploader(uploader contracts.Uploader)

func (*Application) Shutdown

func (app *Application) Shutdown()

func (*Application) Singleflight

func (app *Application) Singleflight() *singleflight.Group

func (*Application) Uploader

func (app *Application) Uploader() contracts.Uploader

type Hook

type Hook string

const (
	BeforeRunHook  Hook = "before_run"
	BeforeDownHook Hook = "before_down"
	AfterDownHook  Hook = "after_down"
)

type Option

type Option func(*Application)

func WithBootstrappers

func WithBootstrappers(bootstrappers ...contracts.Bootstrapper) Option

func WithExcludeTags

func WithExcludeTags(tags ...string) Option

func WithMustBootedBootstrappers

func WithMustBootedBootstrappers(bootstrappers ...contracts.Bootstrapper) Option