conf

Documentation

Index

• Variables
• func LoadEnv(cli *cli.Context) error
• func NewEnvExpandedReader(origin io.Reader) io.Reader
• type Config
  • func LoadConfig() (*Config, error)
• type Consumer
  • func (c *Consumer) UnmarshalYAML(value *yaml.Node) error
• type EventBus
  • func (e *EventBus) UnmarshalYAML(value *yaml.Node) error
• type Health
• type Instance
  • func (i *Instance) URL() string
• type JWT
  • func (cfg *JWT) UnmarshalYAML(value *yaml.Node) error
• type LoadBalancing
• type Persistence
  • func (p *Persistence) UnmarshalYAML(value *yaml.Node) error
• type PersistenceDriver
  • func ParsePersistenceDriver(driver string) (PersistenceDriver, error)
  • func (driver PersistenceDriver) String() string
• type Providers
• type RegisterHTTP
  • func (r *RegisterHTTP) UnmarshalYAML(value *yaml.Node) error
• type RegisterNATS
• type Stream
  • func (s *Stream) UnmarshalYAML(value *yaml.Node) error
• type Test
• type TransportProvider
  • func ParseTransportProvider(provider string) (TransportProvider, error)
  • func (p TransportProvider) String() string
• type Transports
• type Users

Variables

var (
	Path string
	Port int
)

Functions

func LoadEnv

func LoadEnv(cli *cli.Context) error

func NewEnvExpandedReader

func NewEnvExpandedReader(origin io.Reader) io.Reader

Types

type Config

type Config struct {
	Name        string      `yaml:"name"`
	BaseURL     string      `yaml:"baseUrl"`
	JWT         JWT         `yaml:"jwt"`
	Transports  Transports  `yaml:"transports"`
	Persistence Persistence `yaml:"persistence"`
	EventBus    EventBus    `yaml:"eventBus"`
	Providers   Providers   `yaml:"providers"`
	Test        Test        `yaml:"test"`
}

func LoadConfig

func LoadConfig() (*Config, error)

type Consumer

type Consumer struct {
	Name   string
	Stream string
	Config json.RawMessage
}

func (*Consumer) UnmarshalYAML

func (c *Consumer) UnmarshalYAML(value *yaml.Node) error

type EventBus

type EventBus struct {
	Provider TransportProvider
	Users    Users
}

func (*EventBus) UnmarshalYAML

func (e *EventBus) UnmarshalYAML(value *yaml.Node) error

type Health

type Health struct {
	Enabled bool   `yaml:"enabled"`
	Path    string `yaml:"path"`
}

type Instance

type Instance struct {
	Scheme string `yaml:"scheme"`
	Host   string `yaml:"host"`
	Port   int    `yaml:"port"`
	Health Health `yaml:"health"`
}

func (*Instance) URL

func (i *Instance) URL() string

type JWT

type JWT struct {
	Secret  string
	Timeout time.Duration
	Refresh struct {
		Enabled bool
		Maximum time.Duration
	}
}

func (*JWT) UnmarshalYAML

func (cfg *JWT) UnmarshalYAML(value *yaml.Node) error

type LoadBalancing

type LoadBalancing struct {
	Enabled bool `yaml:"enabled"`
}

type Persistence

type Persistence struct {
	Driver   PersistenceDriver
	Name     string
	Host     string
	Port     int
	Username string
	Password string
	InMem    bool
}

func (*Persistence) UnmarshalYAML

func (p *Persistence) UnmarshalYAML(value *yaml.Node) error

type PersistenceDriver

type PersistenceDriver int

const (
	SQLite PersistenceDriver = iota
	BadgerDB
	InMem
)

func ParsePersistenceDriver

func ParsePersistenceDriver(driver string) (PersistenceDriver, error)

func (PersistenceDriver) String

func (driver PersistenceDriver) String() string

type Providers

type Providers struct {
	Google struct {
		Client struct {
			ID     string
			Secret string
		}
	}
}

type RegisterHTTP

type RegisterHTTP struct {
	Enabled  bool
	Internal Instance
	External *Instance
}

func (*RegisterHTTP) UnmarshalYAML

func (r *RegisterHTTP) UnmarshalYAML(value *yaml.Node) error

type RegisterNATS

type RegisterNATS struct {
	Enabled   bool      `yaml:"enabled"`
	Internal  Instance  `yaml:"internal"`
	External  *Instance `yaml:"external"`
	ReqPrefix string    `yaml:"reqPrefix"`
}

type Stream

type Stream struct {
	Name   string
	Config json.RawMessage
}

func (*Stream) UnmarshalYAML

func (s *Stream) UnmarshalYAML(value *yaml.Node) error

type Test

type Test struct {
	Token string
}

type TransportProvider

type TransportProvider int

const NATS TransportProvider = iota

func ParseTransportProvider

func ParseTransportProvider(provider string) (TransportProvider, error)

func (TransportProvider) String

func (p TransportProvider) String() string

type Transports

type Transports struct {
	HTTP          RegisterHTTP  `yaml:"http"`
	NATS          RegisterNATS  `yaml:"nats"`
	LoadBalancing LoadBalancing `yaml:"loadBalancing"`
}

type Users

type Users struct {
	Stream   Stream
	Consumer Consumer
}