apollo

README

apollo

Package apollo implements GoFrame gcfg.Adapter using apollo service.

Installation

go get -u github.com/joy12825/gf/contrib/config/apollo/v2

Usage

Create a custom boot package

If you wish using configuration from apollo globally, it is strongly recommended creating a custom boot package in very top import, which sets the Adapter of default configuration instance before any other package boots.

package boot

import (
	"github.com/joy12825/gf/contrib/config/apollo/v2"
	"github.com/joy12825/gf/v2/frame/g"
	"github.com/joy12825/gf/v2/os/gctx"
)

func init() {
	var (
		ctx     = gctx.GetInitCtx()
		appId   = "SampleApp"
		cluster = "default"
		ip      = "http://localhost:8080"
	)
	// Create apollo Client that implements gcfg.Adapter.
	adapter, err := apollo.New(ctx, apollo.Config{
		AppID:   appId,
		IP:      ip,
		Cluster: cluster,
	})
	if err != nil {
		g.Log().Fatalf(ctx, `%+v`, err)
	}
	// Change the adapter of default configuration instance.
	g.Cfg().SetAdapter(adapter)
}

Import boot package in top of main

It is strongly recommended import your boot package in top of your main.go.

Note the top import: _ "github.com/joy12825/gf/example/config/apollo/boot" .

package main

import (
	_ "github.com/joy12825/gf/example/config/apollo/boot"

	"github.com/joy12825/gf/v2/frame/g"
	"github.com/joy12825/gf/v2/os/gctx"
)

func main() {
	var ctx = gctx.GetInitCtx()

	// Available checks.
	g.Dump(g.Cfg().Available(ctx))

	// All key-value configurations.
	g.Dump(g.Cfg().Data(ctx))

	// Retrieve certain value by key.
	g.Dump(g.Cfg().MustGet(ctx, "server.address"))
}

License

GoFrame apollo is licensed under the MIT License, 100% free and open-source, forever.

Documentation

Overview

Package apollo implements gcfg.Adapter using apollo service.

Index

• func New(ctx context.Context, config Config) (adapter gcfg.Adapter, err error)
• type Client
  • func (c *Client) Available(ctx context.Context, resource ...string) (ok bool)
  • func (c *Client) Data(ctx context.Context) (data map[string]interface{}, err error)
  • func (c *Client) Get(ctx context.Context, pattern string) (value interface{}, err error)
  • func (c *Client) OnChange(event *storage.ChangeEvent)
  • func (c *Client) OnNewestChange(event *storage.FullChangeEvent)
• type Config

Functions

func New

func New(ctx context.Context, config Config) (adapter gcfg.Adapter, err error)

New creates and returns gcfg.Adapter implementing using apollo service.

Types

type Client

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

Client implements gcfg.Adapter implementing using apollo service.

func (*Client) Available

func (c *Client) Available(ctx context.Context, resource ...string) (ok bool)

Available checks and returns the backend configuration service is available. The optional parameter `resource` specifies certain configuration resource.

Note that this function does not return error as it just does simply check for backend configuration service.

func (*Client) Data

func (c *Client) Data(ctx context.Context) (data map[string]interface{}, err error)

Data retrieves and returns all configuration data in current resource as map. Note that this function may lead lots of memory usage if configuration data is too large, you can implement this function if necessary.

func (*Client) Get

func (c *Client) Get(ctx context.Context, pattern string) (value interface{}, err error)

Get retrieves and returns value by specified `pattern` in current resource. Pattern like: "x.y.z" for map item. "x.0.y" for slice item.

func (*Client) OnChange

func (c *Client) OnChange(event *storage.ChangeEvent)

OnChange is called when config changes.

func (*Client) OnNewestChange

func (c *Client) OnNewestChange(event *storage.FullChangeEvent)

OnNewestChange is called when any config changes.

type Config

type Config struct {
	AppID             string `v:"required"` // See apolloConfig.Config.
	IP                string `v:"required"` // See apolloConfig.Config.
	Cluster           string `v:"required"` // See apolloConfig.Config.
	NamespaceName     string // See apolloConfig.Config.
	IsBackupConfig    bool   // See apolloConfig.Config.
	BackupConfigPath  string // See apolloConfig.Config.
	Secret            string // See apolloConfig.Config.
	SyncServerTimeout int    // See apolloConfig.Config.
	MustStart         bool   // See apolloConfig.Config.
	Watch             bool   // Watch watches remote configuration updates, which updates local configuration in memory immediately when remote configuration changes.
}

Config is the configuration object for apollo client.