agollo

package module

Go to main page

Versions in this module

v1

v1.2.14

Jun 18, 2022

Changes in this version

+ const AUTHORIZATION_FORMAT

+ const DELIMITER

+ const ENV_APOLLO_ACCESS_KEY

+ const HTTP_HEADER_AUTHORIZATION

+ const HTTP_HEADER_TIMESTAMP

+ var ErrNoConfigServerAvailable = errors.New("no config server availbale")

+ func ToStringE(i interface{}) (string, error)

type ApolloClient

+ Apply func(opts ...ApolloClientOption)

+ GetConfigServers func(metaServerURL, appID string) (int, []ConfigServer, error)

type ApolloClientOption

+ func WithAccessKey(accessKey string) ApolloClientOption

+ func WithSignatureFunc(sf SignatureFunc) ApolloClientOption

type ApolloResponse

+ Changes Changes

+ type Balancer interface

+ Select func() (string, error)

+ Stop func()

+ func NewAutoFetchBalancer(configServerURL, appID string, getConfigServers GetConfigServersFunc, ...) (Balancer, error)

+ func NewRoundRobin(ss []string) Balancer

+ type Change struct

+ Key string

+ Type ChangeType

+ Value interface{}

+ type ChangeType string

+ const ChangeTypeAdd

+ const ChangeTypeDelete

+ const ChangeTypeUpdate

+ type Changes []Change

+ func (cs Changes) Len() int

+ func (cs Changes) Less(i, j int) bool

+ func (cs Changes) Swap(i, j int)

+ type ConfigServer struct

+ AppName string

+ HomePageURL string

+ InstanceID string

type Configurations

+ func (old Configurations) Different(new Configurations) Changes

+ type GetConfigServersFunc func(metaServerURL, appID string) (int, []ConfigServer, error)

+ type Header map[string]string

+ func DefaultSignatureFunc(ctx *SignatureContext) Header

type Option

+ func AccessKey(accessKey string) Option

+ func ConfigServerRefreshIntervalInSecond(refreshIntervalInSecond time.Duration) Option

+ func EnableHeartBeat(b bool) Option

+ func EnableSLB(b bool) Option

+ func HeartBeatInterval(i time.Duration) Option

+ func WithBalancer(b Balancer) Option

+ func WithClientOptions(opts ...ApolloClientOption) Option

type Options

+ Balancer Balancer

+ ClientOptions []ApolloClientOption

+ EnableHeartBeat bool

+ EnableSLB bool

+ HeartBeatInterval time.Duration

+ RefreshIntervalInSecond time.Duration

+ type SignatureContext struct

+ AccessKey string

+ AppID string

+ Cluster string

+ ConfigServerURL string

+ RequestURI string

+ type SignatureFunc func(ctx *SignatureContext) Header

v1.0.0

Oct 23, 2018

Changes in this version

+ func Get(key string, opts ...GetOption) string

+ func Init(configServerURL, appID string, opts ...Option) (err error)

+ func InitWithConfigFile(configFilePath string, opts ...Option) (err error)

+ func InitWithDefaultConfigFile(opts ...Option) error

+ func Start() <-chan *LongPollerError

+ func Stop()

+ func Watch() <-chan *ApolloResponse

+ func WatchNamespace(namespace string, stop chan bool) <-chan *ApolloResponse

+ type Agollo interface

+ Get func(key string, opts ...GetOption) string

+ GetNameSpace func(namespace string) Configurations

+ Options func() Options

+ Start func() <-chan *LongPollerError

+ Stop func()

+ Watch func() <-chan *ApolloResponse

+ WatchNamespace func(namespace string, stop chan bool) <-chan *ApolloResponse

+ func GetAgollo() Agollo

+ func New(configServerURL, appID string, opts ...Option) (Agollo, error)

+ func NewWithConfigFile(configFilePath string, opts ...Option) (Agollo, error)

+ type ApolloClient interface

+ GetConfigsFromCache func(configServerURL, appID, cluster, namespace string) (Configurations, error)

+ GetConfigsFromNonCache func(configServerURL, appID, cluster, namespace string, opts ...NotificationsOption) (int, *Config, error)

+ Notifications func(configServerURL, appID, clusterName string, notifications []Notification) (int, []Notification, error)

+ func NewApolloClient(opts ...ApolloClientOption) ApolloClient

+ type ApolloClientOption func(*apolloClient)

+ func WithConfigType(configType string) ApolloClientOption

+ func WithDoer(d Doer) ApolloClientOption

+ func WithIP(ip string) ApolloClientOption

+ type ApolloResponse struct

+ Error error

+ Namespace string

+ NewValue Configurations

+ OldValue Configurations

+ type Config struct

+ AppID string

+ Cluster string

+ Configurations Configurations

+ NamespaceName string

+ ReleaseKey string

+ type Configurations map[string]string

+ func GetNameSpace(namespace string) Configurations

+ type Doer interface

+ Do func(*http.Request) (*http.Response, error)

+ type GetOption func(*GetOptions)

+ func WithDefault(defVal string) GetOption

+ func WithNamespace(namespace string) GetOption

+ type GetOptions struct

+ DefaultValue string

+ Namespace string

+ type Logger interface

+ Log func(kvs ...interface{})

+ func NewLogger(opts ...LoggerOption) Logger

+ type LoggerOption func(*logger)

+ func LoggerWriter(w io.Writer) LoggerOption

+ type LongPollerError struct

+ AppID string

+ Cluster string

+ ConfigServerURL string

+ Err error

+ Namespace string

+ Notifications []Notification

+ type Notification struct

+ NamespaceName string

+ NotificationID int

+ type Notifications []Notification

+ func (n Notifications) String() string

+ type NotificationsOption func(*NotificationsOptions)

+ func ReleaseKey(releaseKey string) NotificationsOption

+ type NotificationsOptions struct

+ ReleaseKey string

+ type Option func(*Options)

+ func AutoFetchOnCacheMiss() Option

+ func BackupFile(backupFile string) Option

+ func Cluster(cluster string) Option

+ func DefaultNamespace(defaultNamespace string) Option

+ func FailTolerantOnBackupExists() Option

+ func LongPollerInterval(i time.Duration) Option

+ func PreloadNamespaces(namespaces ...string) Option

+ func WithApolloClient(c ApolloClient) Option

+ func WithLogger(l Logger) Option

+ type Options struct

+ ApolloClient ApolloClient

+ AppID string

+ AutoFetchOnCacheMiss bool

+ BackupFile string

+ Cluster string

+ ConfigServerURL string

+ DefaultNamespace string

+ FailTolerantOnBackupExists bool

+ Logger Logger

+ LongPollerInterval time.Duration

+ PreloadNamespaces []string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL