mobserver

Documentation

Index

• type Change
• type ChangeEvent
• type ChangeEventSource
• type ChangeType
  • func (c ChangeType) String() string
• type ConfigObserver
  • func NewConfigObserver(applyChangeEvent EventHandFunc) *ConfigObserver
  • func (ob *ConfigObserver) HandleChangeEvent(event *ChangeEvent)
  • func (ob *ConfigObserver) StartWatch(ctx context.Context)
• type EventHandFunc

Types

type Change

type Change struct {
	OldValue   string
	NewValue   string
	ChangeType ChangeType
}

Change ...

type ChangeEvent

type ChangeEvent struct {
	Source    ChangeEventSource
	Namespace string
	Changes   map[string]*Change
}

ChangeEvent ...

type ChangeEventSource

type ChangeEventSource int

ChangeEventSource ...

const (
	// Apollo change event source:apollo
	Apollo ChangeEventSource = iota
)

type ChangeType

type ChangeType int

ChangeType ...

const (
	// ADD change type:add
	ADD ChangeType = iota
	// MODIFY change type:modify
	MODIFY
	// DELETE change type:delete
	DELETE
)

func (ChangeType) String

func (c ChangeType) String() string

String ...

type ConfigObserver

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

ConfigObserver listen config change event

func NewConfigObserver

func NewConfigObserver(applyChangeEvent EventHandFunc) *ConfigObserver

NewConfigObserver ...

func (*ConfigObserver) HandleChangeEvent

func (ob *ConfigObserver) HandleChangeEvent(event *ChangeEvent)

HandleChangeEvent send event to listen chan

func (*ConfigObserver) StartWatch

func (ob *ConfigObserver) StartWatch(ctx context.Context)

StartWatch watch change event

type EventHandFunc

type EventHandFunc func(context.Context, *ChangeEvent)

EventHandFunc handle event change