agollo

README

Example

package agollo

import (
	"context"

	"github.com/air-go/rpc/library/apollo/listener"
	"github.com/air-go/rpc/library/apollo/listener/structlistener"
)

type Conf struct {
	Key string
}

func TestNew(t *testing.T) {
	conf := &Conf{}
	listeners := []listener.CustomListener{
		{
			NamespaceStruct: map[string]interface{}{
				"test.json": conf,
			},
			CustomListener: &structlistener.StructChangeListener{},
		},
	}
	New(context.Background(), "test", []string{"test.json"}, WithCustomListeners(listeners))
}

Documentation

Index

• func New(ctx context.Context, appID, ip, cluster string, namespaces []string, ...) (err error)
• func SetBackupFileHandler(f file.FileHandler)
• func SetCacheFactory(f agcache.CacheFactory)
• func SetLoadBalance(l cluster.LoadBalance)
• func SetLogger(l log.LoggerInterface)
• func SetSignature(a auth.HTTPAuth)
• type ApolloClient
• type Option
  • func WithBackupConfigPath(backupPath string) Option
  • func WithCustomListeners(listeners []listener.Listener) Option
  • func WithIsBackupConfig(isBackup bool) Option
  • func WithSecret(secret string) Option
  • func WithSyncServerTimeout(syncServerTimeout int) Option

Functions

func New

func New(ctx context.Context, appID, ip, cluster string, namespaces []string, opts ...Option) (err error)

func SetBackupFileHandler

func SetBackupFileHandler(f file.FileHandler)

SetBackupFileHandler set custom backup file handler

func SetCacheFactory

func SetCacheFactory(f agcache.CacheFactory)

SetCache set custom cache factory

func SetLoadBalance

func SetLoadBalance(l cluster.LoadBalance)

SetLoadBalance set custom load balance

func SetLogger

func SetLogger(l log.LoggerInterface)

SetLogger set custom logger

func SetSignature

func SetSignature(a auth.HTTPAuth)

SetSignature set custom http auth

Types

type ApolloClient

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

type Option

type Option func(*ApolloClient)

func WithBackupConfigPath

func WithBackupConfigPath(backupPath string) Option

func WithCustomListeners

func WithCustomListeners(listeners []listener.Listener) Option

func WithIsBackupConfig

func WithIsBackupConfig(isBackup bool) Option

func WithSecret

func WithSecret(secret string) Option

func WithSyncServerTimeout

func WithSyncServerTimeout(syncServerTimeout int) Option