utils

Documentation

Index

• func HexEncodePublicKey(key *ecdsa.PublicKey) string
• func HexEncodePublicKeys(keys []*ecdsa.PublicKey) []string
• func ParseHexPublicKey(keyStr string) (*ecdsa.PublicKey, error)
• func ParseHexPublicKeys(hexKeys []string) ([]*ecdsa.PublicKey, error)
• func Retry(ctx context.Context, retryCount int, ...) (interface{}, error)
• func Sleep(parentContext context.Context, timeout time.Duration)
• type TaskQueue
  • func NewTaskQueue(name string, capacity uint, ...) *TaskQueue
  • func (queue *TaskQueue) EnqueueTask(ctx context.Context, op func(context.Context) error)
  • func (queue *TaskQueue) Run(ctx context.Context)

Functions

func HexEncodePublicKey

func HexEncodePublicKey(key *ecdsa.PublicKey) string

func HexEncodePublicKeys

func HexEncodePublicKeys(keys []*ecdsa.PublicKey) []string

func ParseHexPublicKey

func ParseHexPublicKey(keyStr string) (*ecdsa.PublicKey, error)

func ParseHexPublicKeys

func ParseHexPublicKeys(hexKeys []string) ([]*ecdsa.PublicKey, error)

func Retry

func Retry(
	ctx context.Context,
	retryCount int,
	delayForAttempt func(attempt int) time.Duration,
	isRecoverableError func(error) bool,
	logger log.Logger,
	opName string,
	op func(context.Context) (interface{}, error),
) (interface{}, error)

func Sleep

func Sleep(parentContext context.Context, timeout time.Duration)

Types

type TaskQueue

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

func NewTaskQueue

func NewTaskQueue(
	name string,
	capacity uint,
	logFuncProvider func(err error) func(msg string, ctx ...interface{}),
) *TaskQueue

func (*TaskQueue) EnqueueTask

func (queue *TaskQueue) EnqueueTask(ctx context.Context, op func(context.Context) error)

func (*TaskQueue) Run

func (queue *TaskQueue) Run(ctx context.Context)