sync

Documentation

Index

• func TestAccPreCheckSyncronize(t *testing.T, semaphore Semaphore, resource string)
• type Semaphore
  • func InitializeSemaphore(envvar string, defaultLimit int) Semaphore
  • func (s Semaphore) Notify()
  • func (s Semaphore) Wait()

Functions

func TestAccPreCheckSyncronize

func TestAccPreCheckSyncronize(t *testing.T, semaphore Semaphore, resource string)

TestAccPreCheckSyncronized waits for a semaphore and skips the test if there is no capacity NOTE: this is currently an experimental feature and is likely to change. DO NOT USE.

Types

type Semaphore

type Semaphore chan struct{}

Semaphore can be used to limit concurrent executions. This can be used to work with resources with low quotas

func InitializeSemaphore

func InitializeSemaphore(envvar string, defaultLimit int) Semaphore

InitializeSemaphore initializes a semaphore with a default capacity or overrides it using an environment variable NOTE: this is currently an experimental feature and is likely to change. DO NOT USE.

func (Semaphore) Notify

func (s Semaphore) Notify()

Notify releases a semaphore NOTE: this is currently an experimental feature and is likely to change. DO NOT USE.

func (Semaphore) Wait

func (s Semaphore) Wait()

Wait waits for a semaphore before continuing NOTE: this is currently an experimental feature and is likely to change. DO NOT USE.