consul

Documentation

Index

• Variables
• func SetLogLevel(level log.Level)
• type MemberListUpdated
• type Option
  • func WithRefreshTTL(refreshTTL time.Duration) Option
  • func WithTTL(ttl time.Duration) Option
• type Provider
  • func New(opts ...Option) (*Provider, error)
  • func NewWithConfig(consulConfig *api.Config, opts ...Option) (*Provider, error)
  • func (p *Provider) DeregisterMember() error
  • func (p *Provider) Shutdown(graceful bool) error
  • func (p *Provider) StartClient(c *cluster.Cluster) error
  • func (p *Provider) StartMember(c *cluster.Cluster) error
  • func (p *Provider) UpdateClusterState(state cluster.ClusterState) error
• type RegisterService
• type UpdateTTL

Variables

var (
	ProviderShuttingDownError = fmt.Errorf("consul cluster provider is shutting down")
)

Functions

func SetLogLevel

func SetLogLevel(level log.Level)

SetLogLevel sets the log level for the logger SetLogLevel is safe to be called concurrently

Types

type MemberListUpdated

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

type Option

type Option func(p *Provider)

func WithRefreshTTL

func WithRefreshTTL(refreshTTL time.Duration) Option

func WithTTL

func WithTTL(ttl time.Duration) Option

type Provider

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

func New

func New(opts ...Option) (*Provider, error)

func NewWithConfig

func NewWithConfig(consulConfig *api.Config, opts ...Option) (*Provider, error)

func (*Provider) DeregisterMember

func (p *Provider) DeregisterMember() error

func (*Provider) Shutdown

func (p *Provider) Shutdown(graceful bool) error

func (*Provider) StartClient

func (p *Provider) StartClient(c *cluster.Cluster) error

func (*Provider) StartMember

func (p *Provider) StartMember(c *cluster.Cluster) error

func (*Provider) UpdateClusterState

func (p *Provider) UpdateClusterState(state cluster.ClusterState) error

type RegisterService

type RegisterService struct{}

type UpdateTTL

type UpdateTTL struct{}