consul

Documentation

Index

• type Provider
  • func NewProvider(cfg *api.Config, srvNameInConsul string) (*Provider, error)
  • func (c *Provider) Get(srv string, allowNew bool) (tapi.Transcriber, string, error)
  • func (c *Provider) StartRegistryLoop(ctx context.Context, checkInterval time.Duration) (<-chan struct{}, error)

Types

type Provider

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

func NewProvider

func NewProvider(cfg *api.Config, srvNameInConsul string) (*Provider, error)

NewProvider creates consul service registrator

func (*Provider) Get

func (c *Provider) Get(srv string, allowNew bool) (tapi.Transcriber, string, error)

func (*Provider) StartRegistryLoop

func (c *Provider) StartRegistryLoop(ctx context.Context, checkInterval time.Duration) (<-chan struct{}, error)