change

Documentation

Index

• Variables
• func RegisterPrivateChangeDetect(o id.Identifiable, update chan interface{}) error
• func RegisterPublicChangeDetect(o id.Identifiable) error
• func StartDetectChanges()
• func Test()
• func UnregisterChangeDetect(o id.Identifiable)
• type ChangeField
• type ChangeNotify
  • func (cn *ChangeNotify) GetId() string
  • func (cn *ChangeNotify) GetType() string
• type SubscribeUpdate

Variables

var (
	PublicSubscribeChange = duplicator.MakeDuplicator("subscribe-outputs")
)

Functions

func RegisterPrivateChangeDetect

func RegisterPrivateChangeDetect(o id.Identifiable, update chan interface{}) error

func RegisterPublicChangeDetect

func RegisterPublicChangeDetect(o id.Identifiable) error

func StartDetectChanges

func StartDetectChanges()

func Test

func Test()

func UnregisterChangeDetect

func UnregisterChangeDetect(o id.Identifiable)

Types

type ChangeField

type ChangeField struct {
	Field string      `json:"field"`
	Value interface{} `json:"value"`
}

type ChangeNotify

type ChangeNotify struct {
	Type    string          `json:"type"`
	Id      string          `json:"uuid"`
	Changes []*ChangeField  `json:"changes"`
	Object  id.Identifiable `json:"-"`
}

func (*ChangeNotify) GetId

func (cn *ChangeNotify) GetId() string

func (*ChangeNotify) GetType

func (cn *ChangeNotify) GetType() string

type SubscribeUpdate

type SubscribeUpdate struct {
	Type string
	Id   string

	TargetOutput chan interface{} `json:"-"`
	// contains filtered or unexported fields
}