events

type Cache interface {
	GetEvent(
		ctx context.Context,
		shardID int,
		domainID string,
		workflowID string,
		runID string,
		firstEventID int64,
		eventID int64,
		branchToken []byte,
	) (*types.HistoryEvent, error)
	PutEvent(
		domainID string,
		workflowID string,
		runID string,
		eventID int64,
		event *types.HistoryEvent,
	)
}

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

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

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

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

type Notification struct {
	ID                     definition.WorkflowIdentifier
	LastFirstEventID       int64
	NextEventID            int64
	PreviousStartedEventID int64
	Timestamp              time.Time
	CurrentBranchToken     []byte
	WorkflowState          int
	WorkflowCloseState     int
}

type Notifier interface {
	common.Daemon
	NotifyNewHistoryEvent(event *Notification)
	WatchHistoryEvent(identifier definition.WorkflowIdentifier) (string, chan *Notification, error)
	UnwatchHistoryEvent(identifier definition.WorkflowIdentifier, subscriberID string) error
}

type PersistedBlob struct {
	persistence.DataBlob

	BranchToken  []byte
	FirstEventID int64
}

type PersistedBlobs []PersistedBlob