server

Documentation

Index

• type BaseConsumer
  • func NewBaseConsumer[T NamedElement](name string, handler InitializableHandler, maxConcurrency int) *BaseConsumer[T]
  • func (c *BaseConsumer[T]) Close()
  • func (c *BaseConsumer[T]) Init(setter GlobalSetter) error
  • func (c *BaseConsumer[T]) PostInit(getter GlobalGetter) error
  • func (c *BaseConsumer[T]) Producer() Producer
  • func (c *BaseConsumer[T]) Run()
  • func (c *BaseConsumer[T]) Send(msg NamedElement)
  • func (c *BaseConsumer[T]) Shutdown(ctx context.Context)
• type BaseServer
  • func (s *BaseServer) Get(key string) interface{}
  • func (s *BaseServer) Init() error
  • func (s *BaseServer) Run()
  • func (s *BaseServer) Set(key string, value interface{})
  • func (s *BaseServer) Shutdown()
• type Consumer
• type CronElement
  • func (e *CronElement) GetName() string
• type CronHandleFunc
• type CronServer
  • func NewCronServer() *CronServer
  • func (s *CronServer) Init(setter GlobalSetter) error
  • func (s *CronServer) PostInit(getter GlobalGetter) error
  • func (s *CronServer) Producer() Producer
  • func (s *CronServer) Run()
  • func (s *CronServer) Send(msg NamedElement)
  • func (s *CronServer) Shutdown(ctx context.Context)
• type FileChangedHandler
• type FileMonitor
  • func NewFileMonitor(name string, handler FileChangedHandler) *FileMonitor
  • func (m *FileMonitor) Init(setter GlobalSetter) error
  • func (m *FileMonitor) PostInit(getter GlobalGetter) error
  • func (m *FileMonitor) Run()
  • func (m *FileMonitor) Shutdown(ctx context.Context)
• type GlobalGetter
• type GlobalSetter
• type Handler
• type InitializableHandler
• type Initialize
• type NamedElement
• type NamedFileEvent
  • func (e *NamedFileEvent) GetName() string
• type Producer
• type Runner
• type Server
• type Shutdowner
• type SignalServer
  • func NewSignalServer() *SignalServer
  • func (s *SignalServer) Init(setter GlobalSetter) error
  • func (s *SignalServer) PostInit(getter GlobalGetter) error
  • func (s *SignalServer) Run()
  • func (s *SignalServer) Shutdown(ctx context.Context)

Types

type BaseConsumer

type BaseConsumer[T NamedElement] struct {
	Name string

	Elements chan T
	Handler  InitializableHandler

	MaxConcurrency int
	// contains filtered or unexported fields
}

func NewBaseConsumer

func NewBaseConsumer[T NamedElement](name string, handler InitializableHandler, maxConcurrency int) *BaseConsumer[T]

func (*BaseConsumer[T]) Close

func (c *BaseConsumer[T]) Close()

func (*BaseConsumer[T]) Init

func (c *BaseConsumer[T]) Init(setter GlobalSetter) error

func (*BaseConsumer[T]) PostInit

func (c *BaseConsumer[T]) PostInit(getter GlobalGetter) error

func (*BaseConsumer[T]) Producer

func (c *BaseConsumer[T]) Producer() Producer

func (*BaseConsumer[T]) Run

func (c *BaseConsumer[T]) Run()

func (*BaseConsumer[T]) Send

func (c *BaseConsumer[T]) Send(msg NamedElement)

func (*BaseConsumer[T]) Shutdown

func (c *BaseConsumer[T]) Shutdown(ctx context.Context)

type BaseServer

type BaseServer struct {
	Name    string
	Servers []Server

	QuitCtx context.Context
	Quit    context.CancelFunc
	// contains filtered or unexported fields
}

func (*BaseServer) Get

func (s *BaseServer) Get(key string) interface{}

func (*BaseServer) Init

func (s *BaseServer) Init() error

func (*BaseServer) Run

func (s *BaseServer) Run()

func (*BaseServer) Set

func (s *BaseServer) Set(key string, value interface{})

func (*BaseServer) Shutdown

func (s *BaseServer) Shutdown()

type Consumer

type Consumer interface {
	Producer() Producer
	Server
}

type CronElement

type CronElement struct {
	TriggerAt  time.Time
	HandleFunc CronHandleFunc
}

func (*CronElement) GetName

func (e *CronElement) GetName() string

type CronHandleFunc

type CronHandleFunc func(triggerAt time.Time)

type CronServer

type CronServer struct {
	Elements []*CronElement
	// contains filtered or unexported fields
}

func NewCronServer

func NewCronServer() *CronServer

func (*CronServer) Init

func (s *CronServer) Init(setter GlobalSetter) error

func (*CronServer) PostInit

func (s *CronServer) PostInit(getter GlobalGetter) error

func (*CronServer) Producer

func (s *CronServer) Producer() Producer

func (*CronServer) Run

func (s *CronServer) Run()

func (*CronServer) Send

func (s *CronServer) Send(msg NamedElement)

func (*CronServer) Shutdown

func (s *CronServer) Shutdown(ctx context.Context)

type FileChangedHandler

type FileChangedHandler interface {
	InitializableHandler

	FilesToWatch() []string
	OnWatchError(error)
}

type FileMonitor

type FileMonitor struct {
	Name    string
	Handler FileChangedHandler
	// contains filtered or unexported fields
}

func NewFileMonitor

func NewFileMonitor(name string, handler FileChangedHandler) *FileMonitor

func (*FileMonitor) Init

func (m *FileMonitor) Init(setter GlobalSetter) error

func (*FileMonitor) PostInit

func (m *FileMonitor) PostInit(getter GlobalGetter) error

func (*FileMonitor) Run

func (m *FileMonitor) Run()

func (*FileMonitor) Shutdown

func (m *FileMonitor) Shutdown(ctx context.Context)

type GlobalGetter

type GlobalGetter interface {
	Get(key string) interface{}
}

type GlobalSetter

type GlobalSetter interface {
	Set(key string, value interface{})
}

type Handler

type Handler interface {
	Handle(msg NamedElement) error
}

type InitializableHandler

type InitializableHandler interface {
	Handler
	Initialize
}

type Initialize

type Initialize interface {
	Init(setter GlobalSetter) error
	PostInit(getter GlobalGetter) error
}

type NamedElement

type NamedElement interface {
	GetName() string
}

type NamedFileEvent

type NamedFileEvent struct{ fsnotify.Event }

func (*NamedFileEvent) GetName

func (e *NamedFileEvent) GetName() string

type Producer

type Producer interface {
	Send(msg NamedElement)
}

type Runner

type Runner interface {
	Run()
}

type Server

type Server interface {
	Initialize
	Runner
	Shutdowner
}

type Shutdowner

type Shutdowner interface {
	Shutdown(ctx context.Context)
}

type SignalServer

type SignalServer struct {
	Quit    context.CancelFunc
	QuitCtx context.Context
}

func NewSignalServer

func NewSignalServer() *SignalServer

func (*SignalServer) Init

func (s *SignalServer) Init(setter GlobalSetter) error

func (*SignalServer) PostInit

func (s *SignalServer) PostInit(getter GlobalGetter) error

func (*SignalServer) Run

func (s *SignalServer) Run()

func (*SignalServer) Shutdown

func (s *SignalServer) Shutdown(ctx context.Context)