server

package
v0.10.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 9, 2018 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConfigUpdateData 

type ConfigUpdateData struct {
	ConfigUrl string
	Items     []ConfigUpdateItem
}

type ConfigUpdateItem 

type ConfigUpdateItem struct {
	Name             string
	RequestedVersion int
}

type GlobalReloadFunc 

type GlobalReloadFunc func()

type MetadataController 

type MetadataController struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewMetadataController 

func NewMetadataController(subscribe bool, answersFileNamePrefix string, reloadInterval int64) *MetadataController

func (*MetadataController) GetVersions 

func (mc *MetadataController) GetVersions() config.Versions

func (*MetadataController) LoadVersionsFromFile 

func (mc *MetadataController) LoadVersionsFromFile() error

func (*MetadataController) LookupAnswer 

func (mc *MetadataController) LookupAnswer(wait bool, oldValue, version string, ip string, path []string, maxWait time.Duration) (interface{}, bool)

func (*MetadataController) RegisterMetaDataServer 

func (mc *MetadataController) RegisterMetaDataServer(url string, accessKey string, secretKey string, local bool, subscribe bool) error

func (*MetadataController) Start 

func (mc *MetadataController) Start() error

func (*MetadataController) UnregisterMetaDataServer 

func (mc *MetadataController) UnregisterMetaDataServer(UUID string)

type MetadataServer 

type MetadataServer struct {
	URL string
	// contains filtered or unexported fields
}

func NewMetaDataServer 

func NewMetaDataServer(URL string, accessKey string, secretKey string,
	local bool, answersFilePathPrefix string, reloadInterval int64, globalReload GlobalReloadFunc) *MetadataServer

func (*MetadataServer) GetExternalCredentials 

func (ms *MetadataServer) GetExternalCredentials() []config.Credential

func (*MetadataServer) GetVersions 

func (ms *MetadataServer) GetVersions() config.Versions

func (*MetadataServer) Start 

func (ms *MetadataServer) Start() error

func (*MetadataServer) Stop 

func (ms *MetadataServer) Stop()

type ReloadFunc 

type ReloadFunc func(versions config.Versions, creds []config.Credential, version string)

type Subscriber 

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

func NewSubscriber 

func NewSubscriber(url string, accessKey string, secretKey string, generator *config.Generator, reloadInterval int64, reload ReloadFunc) *Subscriber

func (*Subscriber) GetRequestedVersion 

func (s *Subscriber) GetRequestedVersion() string

func (*Subscriber) SetRequestedVersion 

func (s *Subscriber) SetRequestedVersion(version string)

func (*Subscriber) Subscribe 

func (s *Subscriber) Subscribe() error

func (*Subscriber) Unsubscribe 

func (s *Subscriber) Unsubscribe()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.