service

Documentation

Overview

package service implements the core of configurator

package service implements the core of configurator

Index

• func SaveConfigs(cfgJson []byte) error
• type Configurator
  • func NewConfigurator(updateCompletionChan chan interface{}) *Configurator
  • func (c *Configurator) GetExtraArgs() *any.Any
  • func (c *Configurator) GetName() string
  • func (c *Configurator) ReportError(e error) error
  • func (c *Configurator) Start() error
  • func (c *Configurator) Update(ub *protos.DataUpdateBatch) bool
• type UpdateCompletion

Functions

func SaveConfigs

func SaveConfigs(cfgJson []byte) error

SaveConfig saves new gateway.configs and returns old configuration if any

Types

type Configurator

type Configurator struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Configurator - magma configurator implementation

func NewConfigurator

func NewConfigurator(updateCompletionChan chan interface{}) *Configurator

NewConfigurator returns a new Configuration & attempts to feel in its configs from magmad.yml

func (*Configurator) GetExtraArgs

func (c *Configurator) GetExtraArgs() *any.Any

func (*Configurator) GetName

func (c *Configurator) GetName() string

Gateway Streamer Listener Interface Implementation

func (*Configurator) ReportError

func (c *Configurator) ReportError(e error) error

func (*Configurator) Start

func (c *Configurator) Start() error

Start registers mconfig listener and starts streaming It'll only return on error & will block in the streaming loop otherwise

func (*Configurator) Update

func (c *Configurator) Update(ub *protos.DataUpdateBatch) bool

type UpdateCompletion

type UpdateCompletion []string

UpdateCompletion is a type sent to update channel with every successful mconfig update it includes a list of service names of services with changed configs