consul

package
v0.0.0-...-be88ffe Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 9, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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{}

Jump to

Keyboard shortcuts

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