utils

Documentation

Index

• func SafeExecuteBatch(b *storage.TableBatch) error
• func SafeExecuteEntityGet(entity *storage.Entity, timeout uint, ml storage.MetadataLevel, ...) error
• func SafeExecuteNextResult(lastResult *storage.EntityQueryResult, options *storage.TableOptions) (*storage.EntityQueryResult, error)
• func SafeExecuteQuery(t *storage.Table, timeout uint, ml storage.MetadataLevel, ...) (*storage.EntityQueryResult, error)

Functions

func SafeExecuteBatch

func SafeExecuteBatch(b *storage.TableBatch) error

executes a table batch with retry

func SafeExecuteEntityGet

func SafeExecuteEntityGet(entity *storage.Entity, timeout uint, ml storage.MetadataLevel, options *storage.GetEntityOptions) error

executes Entity.Get() with retry

func SafeExecuteNextResult

func SafeExecuteNextResult(lastResult *storage.EntityQueryResult, options *storage.TableOptions) (*storage.EntityQueryResult, error)

executes NextResult() with retry

func SafeExecuteQuery

func SafeExecuteQuery(t *storage.Table,
	timeout uint,
	ml storage.MetadataLevel,
	options *storage.QueryOptions) (*storage.EntityQueryResult, error)

executes a table query with retry