event

package

Go to main page

Versions in this module

v0

v0.10.0

May 7, 2021

Changes in this version

+ const ETDatasetSaveCompleted

+ const ETDatasetSaveProgress

+ const ETDatasetSaveStarted

+ const ETTransformDatasetPreview

+ const ETTransformError

+ const ETTransformPrint

+ const ETTransformStart

+ const ETTransformStepSkip

+ const ETTransformStepStart

+ const ETTransformStepStop

+ const ETTransformStop

+ const TransformMsgLvlDebug

+ const TransformMsgLvlError

+ const TransformMsgLvlInfo

+ const TransformMsgLvlNone

+ const TransformMsgLvlWarn

+ var NowFunc = time.Now

type Bus

+ PublishID func(ctx context.Context, typ Type, sessionID string, data interface{}) error

+ SubscribeAll func(handler Handler)

+ SubscribeID func(handler Handler, sessionID string)

+ SubscribeTypes func(handler Handler, eventTypes ...Type)

+ type DsSaveEvent struct

+ Completion float64

+ Error error

+ Message string

+ Name string

+ Path string

+ Username string

type Event

+ SessionID string

+ Timestamp int64

+ Type Type

type Publisher

+ PublishID func(ctx context.Context, typ Type, sessionID string, payload interface{}) error

type RemoteEvent

+ Error error

+ type TransformLifecycle struct

+ Status string

+ StepCount int

+ type TransformMessage struct

+ Lvl TransformMsgLvl

+ Msg string

+ type TransformMsgLvl string

+ type TransformStepLifecycle struct

+ Category string

+ Name string

+ Status string

v0.9.13

Oct 12, 2020

v0.9.12

Sep 10, 2020

v0.9.11

Aug 10, 2020

v0.9.10

Jul 30, 2020

Changes in this version

+ const ETCreatedNewFile

+ const ETDatasetCommitChange

+ const ETDatasetCreateLink

+ const ETDatasetDeleteAll

+ const ETDatasetNameInit

+ const ETDatasetRename

+ const ETDeletedFile

+ const ETModifiedFile

+ const ETRemoteClientPullDatasetCompleted

+ const ETRemoteClientPullVersionCompleted

+ const ETRemoteClientPullVersionProgress

+ const ETRemoteClientPushDatasetCompleted

+ const ETRemoteClientPushVersionCompleted

+ const ETRemoteClientPushVersionProgress

+ const ETRemoteClientRemoveDatasetCompleted

+ const ETRemovedFolder

+ const ETRenamedFolder

+ var ETInstanceConstructed = Type("lib:InstanceConstructed")

+ var ETP2PGoneOffline = Type("p2p:GoneOffline")

+ var ETP2PGoneOnline = Type("p2p:GoneOnline")

+ var ETP2PMessageReceived = Type("p2p:MessageReceived")

+ var ETP2PPeerConnected = Type("p2p:PeerConnected")

+ var ETP2PPeerDisconnected = Type("p2p:PeerDisconnected")

+ var ETP2PQriPeerConnected = Type("p2p:QriPeerConnected")

+ var ETP2PQriPeerDisconnected = Type("p2p:QriPeerDisconnected")

+ var ErrBusClosed = fmt.Errorf("event bus is closed")

+ var NilBus = nilBus

+ type DsChange struct

+ Dir string

+ HeadRef string

+ Info *dsref.VersionInfo

+ InitID string

+ PrettyName string

+ ProfileID string

+ TopIndex int

+ Username string

+ type Handler func(ctx context.Context, t Type, payload interface{}) error

+ type RemoteEvent struct

+ Progress dag.Completion

+ Ref dsref.Ref

+ RemoteAddr string

+ type Type string

+ type WatchfsChange struct

+ Destination string

+ Dsname string

+ Source string

+ Time time.Time

+ Username string

v0.9.9

Jul 1, 2020

v0.9.8

Apr 20, 2020

v0.9.7

Apr 7, 2020

v0.9.6

Mar 5, 2020

Changes in this version

type Bus

+ NumSubscribers func() int

+ Unsubscribe func(<-chan Event)

+ type NilPublisher struct

+ func (n *NilPublisher) Publish(t Topic, data interface{})

+ type Publisher interface

+ Publish func(t Topic, data interface{})

v0.9.5

Feb 27, 2020

Changes in this version

+ var ETFSICreateLinkEvent = Topic("fsi:createLinkEvent")

+ type Bus interface

+ Publish func(t Topic, data interface{})

+ Subscribe func(topics ...Topic) <-chan Event

+ SubscribeOnce func(types ...Topic) <-chan Event

+ func NewBus(ctx context.Context) Bus

+ type Event struct

+ Payload interface{}

+ type FSICreateLinkEvent struct

+ Dsname string

+ FSIPath string

+ Username string

+ type Topic string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL