concurrency

Documentation

Index

• func FuncCallWithTimeout(callBackFunc func() <-chan bool, timeoutFunc func(), ...) error
• type Channel
  • func NewChannel(capacity int) *Channel
  • func (c *Channel) IsClosed() bool
  • func (c *Channel) SafeClose()
  • func (c *Channel) SafeSend(data interface{})
• type Runner
  • func GetAsyncRunner(customFunc func(), execInterval time.Duration, isOnetimeJob bool) *Runner
  • func (r *Runner) Close()
  • func (r *Runner) Start() error
  • func (r *Runner) StartAsync()
• type SafeBool
  • func (sb *SafeBool) IsSet() bool
  • func (sb *SafeBool) Reset()
  • func (sb *SafeBool) Set()
• type Store
  • func NewStore() *Store
  • func (s *Store) Add(key string, value interface{})
  • func (s *Store) Get(key string) interface{}
  • func (s *Store) IsAvailable(key string) bool
  • func (s *Store) Keys() []string
  • func (s *Store) Remove(key string)

Functions

func FuncCallWithTimeout

func FuncCallWithTimeout(callBackFunc func() <-chan bool, timeoutFunc func(), timeoutDuration time.Duration) error

FuncCallWithTimeout calls a given func and exists if the operation not completed in time

Types

type Channel

type Channel struct {
	CH chan interface{}
	// contains filtered or unexported fields
}

Channel struct

func NewChannel

func NewChannel(capacity int) *Channel

NewChannel returns new instance

func (*Channel) IsClosed

func (c *Channel) IsClosed() bool

IsClosed returns status

func (*Channel) SafeClose

func (c *Channel) SafeClose()

SafeClose closes only once

func (*Channel) SafeSend

func (c *Channel) SafeSend(data interface{})

SafeSend sends data safely

type Runner

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

Runner struct

func GetAsyncRunner

func GetAsyncRunner(customFunc func(), execInterval time.Duration, isOnetimeJob bool) *Runner

GetAsyncRunner func executes the given func on the specified interval

func (*Runner) Close

func (r *Runner) Close()

Close func

func (*Runner) Start

func (r *Runner) Start() error

Start triggers the execution

func (*Runner) StartAsync

func (r *Runner) StartAsync()

type SafeBool

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

SafeBool is safe to use in concurrently.

func (*SafeBool) IsSet

func (sb *SafeBool) IsSet() bool

IsSet returns state

func (*SafeBool) Reset

func (sb *SafeBool) Reset()

Reset updates the state to false

func (*SafeBool) Set

func (sb *SafeBool) Set()

Set updates the state to true

type Store

type Store struct {
	Name string
	// contains filtered or unexported fields
}

Store struct

func NewStore

func NewStore() *Store

NewStore returns brandnew store

func (*Store) Add

func (s *Store) Add(key string, value interface{})

Add a value to the store

func (*Store) Get

func (s *Store) Get(key string) interface{}

Get a value from the store

func (*Store) IsAvailable

func (s *Store) IsAvailable(key string) bool

IsAvailable returns the availability

func (*Store) Keys

func (s *Store) Keys() []string

Keys returns the available keys

func (*Store) Remove

func (s *Store) Remove(key string)

Remove a value to the store