deadline

Documentation

Index

• func WithClose(f func()) func(*opts)
• func WithReadClose(f func()) func(*opts)
• func WithWriteClose(f func()) func(*opts)
• type Deadline
  • func New(os ...func(*opts)) *Deadline
  • func (x *Deadline) Close() error
  • func (x *Deadline) Context() context.Context
  • func (x *Deadline) SetDeadline(t time.Time)
• type PipeDeadline
  • func NewPipe(os ...func(*opts)) *PipeDeadline
  • func (x *PipeDeadline) Close() error
  • func (x *PipeDeadline) ReadContext() context.Context
  • func (x *PipeDeadline) SetDeadline(t time.Time)
  • func (x *PipeDeadline) SetReadDeadline(t time.Time)
  • func (x *PipeDeadline) SetWriteDeadline(t time.Time)
  • func (x *PipeDeadline) WriteContext() context.Context

Functions

func WithClose

func WithClose(f func()) func(*opts)

func WithReadClose

func WithReadClose(f func()) func(*opts)

func WithWriteClose

func WithWriteClose(f func()) func(*opts)

Types

type Deadline

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

func New

func New(os ...func(*opts)) *Deadline

func (*Deadline) Close

func (x *Deadline) Close() error

func (*Deadline) Context

func (x *Deadline) Context() context.Context

func (*Deadline) SetDeadline

func (x *Deadline) SetDeadline(t time.Time)

type PipeDeadline

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

func NewPipe

func NewPipe(os ...func(*opts)) *PipeDeadline

func (*PipeDeadline) Close

func (x *PipeDeadline) Close() error

func (*PipeDeadline) ReadContext

func (x *PipeDeadline) ReadContext() context.Context

func (*PipeDeadline) SetDeadline

func (x *PipeDeadline) SetDeadline(t time.Time)

func (*PipeDeadline) SetReadDeadline

func (x *PipeDeadline) SetReadDeadline(t time.Time)

func (*PipeDeadline) SetWriteDeadline

func (x *PipeDeadline) SetWriteDeadline(t time.Time)

func (*PipeDeadline) WriteContext

func (x *PipeDeadline) WriteContext() context.Context