worker

package
v0.48.0-dev2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 24, 2025 License: BSD-3-Clause Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AtomicWorkerStatus

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

AtomicWorkerStatus is a thread-safe wrapper for worker status

func NewAtomicStatus

func NewAtomicStatus() *AtomicWorkerStatus

func (*AtomicWorkerStatus) Get

func (acs *AtomicWorkerStatus) Get() Status

Get returns the current connection status

func (*AtomicWorkerStatus) SetConnected

func (acs *AtomicWorkerStatus) SetConnected()

func (*AtomicWorkerStatus) SetDisconnected

func (acs *AtomicWorkerStatus) SetDisconnected()

func (*AtomicWorkerStatus) String

func (acs *AtomicWorkerStatus) String() string

String returns the string representation of the current status

type Status

type Status int32
const (
	StatusDisconnected Status = iota
	StatusConnected
)

func (Status) String

func (s Status) String() string

Jump to

Keyboard shortcuts

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