concurrency

Documentation

Index

• func ForEachUser(ctx context.Context, userIDs []string, concurrency int, ...) error
• type SyncBuffer
  • func (sb *SyncBuffer) String() string
  • func (sb *SyncBuffer) Write(p []byte) (n int, err error)

Functions

func ForEachUser

func ForEachUser(ctx context.Context, userIDs []string, concurrency int, userFunc func(ctx context.Context, userID string) error) error

ForEachUser runs the provided userFunc for each userIDs up to concurrency concurrent workers. In case userFunc returns error, it will continue to process remaining users but returns an error with all errors userFunc has returned.

Types

type SyncBuffer

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

func (*SyncBuffer) String

func (sb *SyncBuffer) String() string

func (*SyncBuffer) Write

func (sb *SyncBuffer) Write(p []byte) (n int, err error)