concurrency

package

v2.0.0 Latest Latest Go to latest Published: Jun 18, 2023 License: Apache-2.0 Imports: 6 Imported by: 2

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/mycontroller-org/server

Links

Open Source Insights

Documentation ¶

Index ¶

func FuncCallWithTimeout(callBackFunc func() <-chan bool, timeoutFunc func(), ...) error
type Channel
- func NewChannel(capacity int) *Channel
type Runner
- func GetAsyncRunner(customFunc func(), execInterval time.Duration, isOnetimeJob bool) *Runner
type SafeBool
type Store
- func NewStore() *Store

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL