util

Documentation

Index

• func Span(name string) func()
• type Lifetime
  • func NewLifetime(ctx context.Context) Lifetime
  • func (s *Lifetime) Cancel()
  • func (s *Lifetime) Ctx() context.Context
  • func (s *Lifetime) IsDone() bool
  • func (s *Lifetime) Started() time.Time
• type Publisher
  • func NewPublisher[T any]() *Publisher[T]
  • func (p *Publisher[T]) Publish(value T)
  • func (t *Publisher[T]) Subscribe(ctx context.Context) *Subscriber[T]
• type Resizable
• type Subscriber
  • func (t *Subscriber[T]) Done()
  • func (t *Subscriber[T]) Recv() <-chan T
• type WaitBuffer
  • func NewWaitBuffer() *WaitBuffer
  • func (w *WaitBuffer) Read(p []byte) (n int, err error)
  • func (w *WaitBuffer) Write(p []byte) (n int, err error)

Functions

func Span

func Span(name string) func()

Types

type Lifetime

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

func NewLifetime

func NewLifetime(ctx context.Context) Lifetime

func (*Lifetime) Cancel

func (s *Lifetime) Cancel()

func (*Lifetime) Ctx

func (s *Lifetime) Ctx() context.Context

func (*Lifetime) IsDone

func (s *Lifetime) IsDone() bool

func (*Lifetime) Started

func (s *Lifetime) Started() time.Time

type Publisher

type Publisher[T any] struct {
	// contains filtered or unexported fields
}

func NewPublisher

func NewPublisher[T any]() *Publisher[T]

func (*Publisher[T]) Publish

func (p *Publisher[T]) Publish(value T)

func (*Publisher[T]) Subscribe

func (t *Publisher[T]) Subscribe(ctx context.Context) *Subscriber[T]

type Resizable

type Resizable interface {
	Resize(width, height int)
}

type Subscriber

type Subscriber[T any] struct {
	Lifetime
	// contains filtered or unexported fields
}

func (*Subscriber[T]) Done

func (t *Subscriber[T]) Done()

func (*Subscriber[T]) Recv

func (t *Subscriber[T]) Recv() <-chan T

type WaitBuffer

type WaitBuffer struct {
	deadlock.Mutex
	// contains filtered or unexported fields
}

A buffer where Read() blocks until the next Write().

func NewWaitBuffer

func NewWaitBuffer() *WaitBuffer

func (*WaitBuffer) Read

func (w *WaitBuffer) Read(p []byte) (n int, err error)

func (*WaitBuffer) Write

func (w *WaitBuffer) Write(p []byte) (n int, err error)