configserver

Documentation

Index

• Variables
• type ConfigureOptions
  • func (c *ConfigureOptions) GetMaxWaitTimeForUpdate() time.Duration
• type ConfigureServer
  • func NewConfigureServer(opt ConfigureOptions) *ConfigureServer
  • func (c *ConfigureServer) Shutdown() error
  • func (c *ConfigureServer) Startup() error
• type DefaultVersionComparator
  • func (d DefaultVersionComparator) HasUpdate(requestVersion, dataVersion string) bool
• type NotifyChannel
• type NotifyEvent

Variables

var (
	ErrHasUnknownConfiguration = errors.New("has unknown configuration")
)

Types

type ConfigureOptions

type ConfigureOptions struct {
	Addr      string
	TLSConfig struct {
		Addr string
		Cert string
		Key  string
	}
	WriteApi struct {
		DataWriter configapi.DataWriter
		Addr       string
		TLSConfig  struct {
			Addr string
			Cert string
			Key  string
		}
	}

	MaxWaitTimeForUpdate int // in seconds

	DataPump          configapi.DataPump
	VersionComparator configapi.VersionComparator
}

func (*ConfigureOptions) GetMaxWaitTimeForUpdate

func (c *ConfigureOptions) GetMaxWaitTimeForUpdate() time.Duration

type ConfigureServer

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

func NewConfigureServer

func NewConfigureServer(opt ConfigureOptions) *ConfigureServer

func (*ConfigureServer) Shutdown

func (c *ConfigureServer) Shutdown() error

func (*ConfigureServer) Startup

func (c *ConfigureServer) Startup() error

type DefaultVersionComparator

type DefaultVersionComparator struct {
}

func (DefaultVersionComparator) HasUpdate

func (d DefaultVersionComparator) HasUpdate(requestVersion, dataVersion string) bool

type NotifyChannel

type NotifyChannel chan NotifyEvent

type NotifyEvent

type NotifyEvent struct {
	Configuration *configapi.Configuration
}