Versions in this module Expand all Collapse all v0 v0.1.0 Apr 8, 2024 Changes in this version + const EnvLogLevel + const ErrFailedToReceive + const ErrFailedToSend + var Logger = ...() + type Error string + func (e Error) Error() string + type Timed struct + func WithExpiration[T any](bufSize int) Timed[T] + func (c *Timed[T]) Channel() chan T + func (c *Timed[T]) Len() int + func (c *Timed[T]) NonBlockingReceive() (e T, err error) + func (c *Timed[T]) NonBlockingReceiveWithContext(ctx context.Context) (T, error) + func (c *Timed[T]) NonBlockingReceiveWithTimeout(t time.Duration) (e T, err error) + func (c *Timed[T]) NonBlockingSend(e T) error + func (c *Timed[T]) NonBlockingSendWithContext(ctx context.Context, e T) error + func (c *Timed[T]) NonBlockingSendWithTimeout(t time.Duration, e T) error + func (c *Timed[T]) Receive() T + func (c *Timed[T]) ReceiveWithContext(ctx context.Context) T + func (c *Timed[T]) ReceiveWithTimeout(t time.Duration) T + func (c *Timed[T]) Send(e T) + func (c *Timed[T]) SendWithContext(ctx context.Context, e T) + func (c *Timed[T]) SendWithTimeout(t time.Duration, e T)
Go to main page