persistenceutils

Documentation

Index

• func GetBeginNodeID(bi types.HistoryBranch) int64
• func GetBranchesMaxReferredNodeIDs(branches []*types.HistoryBranch) map[string]int64
• func PaginateHistory(ctx context.Context, historyV2Mgr persistence.HistoryManager, byBatch bool, ...) ([]*types.HistoryEvent, []*types.History, []byte, int, error)
• func ReadFullPageV2Events(ctx context.Context, historyV2Mgr persistence.HistoryManager, ...) ([]*types.HistoryEvent, int, []byte, error)
• func ReadFullPageV2EventsByBatch(ctx context.Context, historyV2Mgr persistence.HistoryManager, ...) ([]*types.History, int, []byte, error)

Functions

func GetBeginNodeID

func GetBeginNodeID(bi types.HistoryBranch) int64

GetBeginNodeID gets node id from last ancestor

func GetBranchesMaxReferredNodeIDs

func GetBranchesMaxReferredNodeIDs(branches []*types.HistoryBranch) map[string]int64

Get the maximum referenced node id of each branch

func PaginateHistory

func PaginateHistory(
	ctx context.Context,
	historyV2Mgr persistence.HistoryManager,
	byBatch bool,
	branchToken []byte,
	firstEventID int64,
	nextEventID int64,
	tokenIn []byte,
	pageSize int,
	shardID *int,
	domainID string,
	domainCache cache.DomainCache,
) ([]*types.HistoryEvent, []*types.History, []byte, int, error)

PaginateHistory return paged history

func ReadFullPageV2Events

func ReadFullPageV2Events(
	ctx context.Context,
	historyV2Mgr persistence.HistoryManager,
	req *persistence.ReadHistoryBranchRequest,
) ([]*types.HistoryEvent, int, []byte, error)

ReadFullPageV2Events reads a full page of history events from HistoryManager. Due to storage format of V2 History it is not guaranteed that pageSize amount of data is returned. Function returns the list of history events, the size of data read, the next page token, and an error if present.

func ReadFullPageV2EventsByBatch

func ReadFullPageV2EventsByBatch(
	ctx context.Context,
	historyV2Mgr persistence.HistoryManager,
	req *persistence.ReadHistoryBranchRequest,
) ([]*types.History, int, []byte, error)

ReadFullPageV2EventsByBatch reads a full page of history events by batch from HistoryManager. Due to storage format of V2 History it is not guaranteed that pageSize amount of data is returned. Function returns the list of history batches, the size of data read, the next page token, and an error if present.