persistenceutils

Documentation

Index

• func GetBeginNodeID(bi types.HistoryBranch) 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 PaginateHistory

func PaginateHistory(
	ctx context.Context,
	historyV2Mgr persistence.HistoryManager,
	byBatch bool,
	branchToken []byte,
	firstEventID int64,
	nextEventID int64,
	tokenIn []byte,
	pageSize int,
	shardID *int,
) ([]*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.