events

type Cache interface {
	GetEvent(ctx context.Context, key EventKey, firstEventID int64, branchToken []byte) (*historypb.HistoryEvent, error)
	PutEvent(key EventKey, event *historypb.HistoryEvent)
	DeleteEvent(key EventKey)
}

type CacheImpl struct {
	cache.Cache
	// contains filtered or unexported fields
}

type EventKey struct {
	NamespaceID namespace.ID
	WorkflowID  string
	RunID       string
	EventID     int64
	Version     int64
}

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

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

type Notification struct {
	ID                     definition.WorkflowKey
	LastFirstEventID       int64
	LastFirstEventTxnID    int64
	NextEventID            int64
	PreviousStartedEventID int64
	Timestamp              time.Time
	WorkflowState          enumsspb.WorkflowExecutionState
	WorkflowStatus         enumspb.WorkflowExecutionStatus
	VersionHistories       *historyspb.VersionHistories
}

type Notifier interface {
	NotifyNewHistoryEvent(event *Notification)
	WatchHistoryEvent(identifier definition.WorkflowKey) (string, chan *Notification, error)
	UnwatchHistoryEvent(identifier definition.WorkflowKey, subscriberID string) error
	Start()
	Stop()
}

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