refreshable

Documentation

Index

• type Bool
  • func NewBool(in Refreshable) Bool
• type DefaultRefreshable
  • func NewDefaultRefreshable(val interface{}) *DefaultRefreshable
  • func (d *DefaultRefreshable) Current() interface{}
  • func (d *DefaultRefreshable) Map(mapFn func(interface{}) interface{}) Refreshable
  • func (d *DefaultRefreshable) Subscribe(consumer func(interface{})) (unsubscribe func())
  • func (d *DefaultRefreshable) Update(val interface{}) error
• type Duration
  • func NewDuration(in Refreshable) Duration
• type Int
  • func NewInt(in Refreshable) Int
• type Refreshable
  • func NewFileRefreshable(ctx context.Context, filePath string) (r Refreshable, rErr error)
• type String
  • func NewString(in Refreshable) String

Types

type Bool

type Bool interface {
	Refreshable
	CurrentBool() bool
}

func NewBool

func NewBool(in Refreshable) Bool

type DefaultRefreshable

type DefaultRefreshable struct {
	sync.Mutex // protects subscribers
	// contains filtered or unexported fields
}

func NewDefaultRefreshable

func NewDefaultRefreshable(val interface{}) *DefaultRefreshable

func (*DefaultRefreshable) Current

func (d *DefaultRefreshable) Current() interface{}

func (*DefaultRefreshable) Map

func (d *DefaultRefreshable) Map(mapFn func(interface{}) interface{}) Refreshable

func (*DefaultRefreshable) Subscribe

func (d *DefaultRefreshable) Subscribe(consumer func(interface{})) (unsubscribe func())

func (*DefaultRefreshable) Update

func (d *DefaultRefreshable) Update(val interface{}) error

type Duration

type Duration interface {
	Refreshable
	CurrentDuration() time.Duration
}

Duration is a Refreshable that can return the current time.Duration.

func NewDuration

func NewDuration(in Refreshable) Duration

type Int

type Int interface {
	Refreshable
	CurrentInt() int
}

func NewInt

func NewInt(in Refreshable) Int

type Refreshable

type Refreshable interface {
	// Current returns the most recent value of this Refreshable.
	Current() interface{}

	// Subscribe subscribes to changes of this Refreshable. The provided function is called with the value of Current()
	// whenever the value changes.
	Subscribe(consumer func(interface{})) (unsubscribe func())

	// Map returns a new Refreshable based on the current one that handles updates based on the current Refreshable.
	Map(func(interface{}) interface{}) Refreshable
}

func NewFileRefreshable

func NewFileRefreshable(ctx context.Context, filePath string) (r Refreshable, rErr error)

NewFileRefreshable returns a new Refreshable whose current value is the bytes of the file at the provided path. Calling this function also starts a goroutine which updates the value of the refreshable whenever the specified file is changed. The goroutine will terminate when the provided context is done or when the returned cancel function is called.

type String

type String interface {
	Refreshable
	CurrentString() string
}

func NewString

func NewString(in Refreshable) String