util

Documentation

Index

• type ClientInitializer
  • func NewClientInitializer(name string, initializer func() error, ping func() error, ...) ClientInitializer

Types

type ClientInitializer

type ClientInitializer interface {
	// Done returns true iff client has been initialized successfully.
	Done() bool
}

ClientInitializer manages client initialization for sinks.

func NewClientInitializer

func NewClientInitializer(name string, initializer func() error, ping func() error, frequency time.Duration) ClientInitializer

NewClientInitializer returns a ClientInitializer object that will attempt to initialize sink client periodically based on frequency, until successful.