events

Documentation

Index

• func EventType(e Event) reflect.Type
• type Error
  • func NewError(err error) *Error
  • func (e *Error) Error() string
• type Event
• type EventList
• type Interrupt
  • func NewInterrupt(data any) *Interrupt
  • func (i *Interrupt) Data() any
  • func (i *Interrupt) String() string
• type Message
  • func NewMessage(cmd int, data any) *Message
  • func (e *Message) Command() int
  • func (e *Message) Data() any
  • func (e *Message) Index() uint64
  • func (e *Message) String() string
• type Queue
  • func NewQueue() *Queue
  • func (e *Queue) Capacity() int
  • func (e *Queue) Events() int
  • func (e *Queue) Pop() Event
  • func (e *Queue) Push(evt Event)
• type Response
  • func NewResponse(msg *Message, rsp any) *Response
  • func (e *Response) Command() int
  • func (e *Response) Index() uint64
  • func (e *Response) Received() time.Time
  • func (e *Response) Response() any
  • func (e *Response) String() string
• type Signal
  • func NewSignal(sig os.Signal) *Signal
  • func (e *Signal) Signal() os.Signal
  • func (e *Signal) String() string
• type Time
  • func NewTime() *Time
  • func (e *Time) SetNow()
  • func (e *Time) SetWhen(val time.Time)
  • func (e *Time) String() string
  • func (e *Time) When() time.Time

Functions

func EventType

func EventType(e Event) reflect.Type

Types

type Error

type Error struct {
	Time
	// contains filtered or unexported fields
}

func NewError

func NewError(err error) *Error

func (*Error) Error

func (e *Error) Error() string

type Event

type Event interface {
	When() time.Time
	String() string
}

type EventList

type EventList []Event

type Interrupt

type Interrupt struct {
	Time
	// contains filtered or unexported fields
}

func NewInterrupt

func NewInterrupt(data any) *Interrupt

func (*Interrupt) Data

func (i *Interrupt) Data() any

func (*Interrupt) String

func (i *Interrupt) String() string

type Message

type Message struct {
	Time
	// contains filtered or unexported fields
}

func NewMessage

func NewMessage(cmd int, data any) *Message

func (*Message) Command

func (e *Message) Command() int

func (*Message) Data

func (e *Message) Data() any

func (*Message) Index

func (e *Message) Index() uint64

func (*Message) String

func (e *Message) String() string

type Queue

type Queue struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue() *Queue

func (*Queue) Capacity

func (e *Queue) Capacity() int

func (*Queue) Events

func (e *Queue) Events() int

func (*Queue) Pop

func (e *Queue) Pop() Event

func (*Queue) Push

func (e *Queue) Push(evt Event)

type Response

type Response struct {
	Time
	// contains filtered or unexported fields
}

func NewResponse

func NewResponse(msg *Message, rsp any) *Response

func (*Response) Command

func (e *Response) Command() int

func (*Response) Index

func (e *Response) Index() uint64

func (*Response) Received

func (e *Response) Received() time.Time

func (*Response) Response

func (e *Response) Response() any

func (*Response) String

func (e *Response) String() string

type Signal

type Signal struct {
	Time
	// contains filtered or unexported fields
}

func NewSignal

func NewSignal(sig os.Signal) *Signal

func (*Signal) Signal

func (e *Signal) Signal() os.Signal

func (*Signal) String

func (e *Signal) String() string

type Time

type Time struct {
	TStamp time.Time
}

func NewTime

func NewTime() *Time

func (*Time) SetNow

func (e *Time) SetNow()

func (*Time) SetWhen

func (e *Time) SetWhen(val time.Time)

func (*Time) String

func (e *Time) String() string

func (*Time) When

func (e *Time) When() time.Time