polaris

README

Polaris Config

import (
 "log"

 "github.com/polarismesh/polaris-go"
 "github.com/fengleng/mars/contrib/config/polaris"
)

func main() {

 configApi, err := polaris.NewConfigAPI()
 if err != nil {
  log.Fatalln(err)
 }

 source, err := New(&configApi, WithNamespace("default"), WithFileGroup("default"), WithFileName("default.yaml"))

 if err != nil {
  log.Fatalln(err)
 }
 source.Load()
}

Documentation

Index

• func New(client polaris.ConfigAPI, opts ...Option) (config.Source, error)
• type Option
  • func WithFileGroup(fileGroup string) Option
  • func WithFileName(fileName string) Option
  • func WithNamespace(namespace string) Option
• type Watcher
  • func (w *Watcher) Next() ([]*config.KeyValue, error)
  • func (w *Watcher) Stop() error

Functions

func New

func New(client polaris.ConfigAPI, opts ...Option) (config.Source, error)

Types

type Option

type Option func(o *options)

Option is polaris config option.

func WithFileGroup

func WithFileGroup(fileGroup string) Option

WithFileGroup with polaris config fileGroup

func WithFileName

func WithFileName(fileName string) Option

WithFileName with polaris config fileName

func WithNamespace

func WithNamespace(namespace string) Option

WithNamespace with polaris config namespace

type Watcher

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

func (*Watcher) Next

func (w *Watcher) Next() ([]*config.KeyValue, error)

func (*Watcher) Stop

func (w *Watcher) Stop() error