service

Documentation

Index

• type Config
• type Service
  • func NewService(serviceConfig *Config) (*Service, error)
  • func (s *Service) Bundles() map[string]*bundle.Bundle
  • func (s *Service) Config() *config.Config
  • func (s *Service) HandleBundle(name string, w http.ResponseWriter, r *http.Request)
  • func (s *Service) HandleCallback(name, typ string, matcher func(b *bundle.Bundle) bool) func()
  • func (s *Service) HandleWebhook(name string, w http.ResponseWriter, r *http.Request)
  • func (s *Service) LoadBundles(ctx context.Context) error
  • func (s *Service) LoadDeployers(ctx context.Context) error
  • func (s *Service) LoadPublishers(ctx context.Context) error
  • func (s *Service) LoadStores(ctx context.Context) error
  • func (s *Service) LoadSubscribers(ctx context.Context) error
  • func (s *Service) LoadWebhooks(ctx context.Context) error
  • func (s *Service) Lock(ctx context.Context) error
  • func (s *Service) Logger() logger.Logger
  • func (s *Service) ReloadConfig(ctx context.Context) error

Types

type Config

type Config struct {
	Watch     bool
	File      string
	LogLevel  string
	LogFormat string
}

type Service

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

Service implements service

func NewService

func NewService(serviceConfig *Config) (*Service, error)

NewService creates a new service

func (*Service) Bundles

func (s *Service) Bundles() map[string]*bundle.Bundle

func (*Service) Config

func (s *Service) Config() *config.Config

func (*Service) HandleBundle

func (s *Service) HandleBundle(name string, w http.ResponseWriter, r *http.Request)

HandleBundle handles bundle requests

func (*Service) HandleCallback

func (s *Service) HandleCallback(name, typ string, matcher func(b *bundle.Bundle) bool) func()

func (*Service) HandleWebhook

func (s *Service) HandleWebhook(name string, w http.ResponseWriter, r *http.Request)

HandleWebhook handles webhooks

func (*Service) LoadBundles

func (s *Service) LoadBundles(ctx context.Context) error

LoadBundles loads bundles

func (*Service) LoadDeployers

func (s *Service) LoadDeployers(ctx context.Context) error

LoadDeployers loads and connects deployers

func (*Service) LoadPublishers

func (s *Service) LoadPublishers(ctx context.Context) error

LoadPublishers loads and connects publishers

func (*Service) LoadStores

func (s *Service) LoadStores(ctx context.Context) error

LoadStores loads and connects to stores

func (*Service) LoadSubscribers

func (s *Service) LoadSubscribers(ctx context.Context) error

LoadSubscribers loads and connects subscribers

func (*Service) LoadWebhooks

func (s *Service) LoadWebhooks(ctx context.Context) error

LoadWebhooks loads webhooks

func (*Service) Lock

func (s *Service) Lock(ctx context.Context) error

func (*Service) Logger

func (s *Service) Logger() logger.Logger

func (*Service) ReloadConfig

func (s *Service) ReloadConfig(ctx context.Context) error

RelodConfig reloads the configuration file