base

Documentation

Index

• func NewQueue() *queue
• type App
  • func (this *App) Bus() gopi.Bus
  • func (this *App) Close() error
  • func (this *App) Display() gopi.Display
  • func (this *App) Emit(e gopi.Event)
  • func (this *App) Flags() gopi.Flags
  • func (this *App) Fonts() gopi.FontManager
  • func (this *App) GPIO() gopi.GPIO
  • func (this *App) I2C() gopi.I2C
  • func (this *App) Init(name string, units []string) error
  • func (this *App) Input() gopi.InputManager
  • func (this *App) LIRC() gopi.LIRC
  • func (this *App) Log() gopi.Logger
  • func (this *App) Platform() gopi.Platform
  • func (this *App) Run() int
  • func (this *App) SPI() gopi.SPI
  • func (this *App) Start(app gopi.App, args []string) error
  • func (this *App) String() string
  • func (this *App) Surfaces() gopi.SurfaceManager
  • func (this *App) Timer() gopi.Timer
  • func (this *App) UnitInstance(name string) gopi.Unit
  • func (this *App) UnitInstancesByName(name string) []gopi.Unit
  • func (this *App) WaitForSignal(ctx context.Context, signals ...os.Signal) error
• type Logger
  • func (this *Logger) Clone(name string) gopi.Logger
  • func (this *Logger) Debug(args ...interface{})
  • func (this *Logger) Error(err error) error
  • func (this *Logger) Info(args ...interface{})
  • func (this *Logger) Init(writer io.Writer, name string, debug bool) error
  • func (this *Logger) IsDebug() bool
  • func (this *Logger) Name() string
  • func (this *Logger) String() string
  • func (this *Logger) Warn(args ...interface{})
• type PubSub
  • func (this *PubSub) Close() error
  • func (this *PubSub) Emit(value interface{})
  • func (this *PubSub) String() string
  • func (this *PubSub) Subscribe() <-chan interface{}
  • func (this *PubSub) Unsubscribe(subscriber <-chan interface{})
• type Publisher
  • func (this *Publisher) Close()
  • func (this *Publisher) Emit(num uint, value interface{})
  • func (this *Publisher) Init(num uint) *queue
  • func (this *Publisher) NextToken() gopi.Channel
  • func (this *Publisher) Subscribe(num uint, callback func(value interface{})) gopi.Channel
  • func (this *Publisher) Unsubscribe(token gopi.Channel)
• type Unit
  • func (this *Unit) Close() error
  • func (this *Unit) Init(log gopi.Logger) error
  • func (this *Unit) String() string

Functions

func NewQueue

func NewQueue() *queue

Types

type App

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

func (*App) Bus

func (this *App) Bus() gopi.Bus

func (*App) Close

func (this *App) Close() error

func (*App) Display

func (this *App) Display() gopi.Display

func (*App) Emit

func (this *App) Emit(e gopi.Event)

func (*App) Flags

func (this *App) Flags() gopi.Flags

func (*App) Fonts

func (this *App) Fonts() gopi.FontManager

func (*App) GPIO

func (this *App) GPIO() gopi.GPIO

func (*App) I2C

func (this *App) I2C() gopi.I2C

func (*App) Init

func (this *App) Init(name string, units []string) error

func (*App) Input

func (this *App) Input() gopi.InputManager

func (*App) LIRC

func (this *App) LIRC() gopi.LIRC

func (*App) Log

func (this *App) Log() gopi.Logger

func (*App) Platform

func (this *App) Platform() gopi.Platform

func (*App) Run

func (this *App) Run() int

func (*App) SPI

func (this *App) SPI() gopi.SPI

func (*App) Start

func (this *App) Start(app gopi.App, args []string) error

func (*App) String

func (this *App) String() string

func (*App) Surfaces

func (this *App) Surfaces() gopi.SurfaceManager

func (*App) Timer

func (this *App) Timer() gopi.Timer

func (*App) UnitInstance

func (this *App) UnitInstance(name string) gopi.Unit

func (*App) UnitInstancesByName

func (this *App) UnitInstancesByName(name string) []gopi.Unit

func (*App) WaitForSignal

func (this *App) WaitForSignal(ctx context.Context, signals ...os.Signal) error

type Logger

type Logger struct {
	Unit
	// contains filtered or unexported fields
}

Logger is the base struct for any logger

func (*Logger) Clone

func (this *Logger) Clone(name string) gopi.Logger

func (*Logger) Debug

func (this *Logger) Debug(args ...interface{})

func (*Logger) Error

func (this *Logger) Error(err error) error

func (*Logger) Info

func (this *Logger) Info(args ...interface{})

func (*Logger) Init

func (this *Logger) Init(writer io.Writer, name string, debug bool) error

func (*Logger) IsDebug

func (this *Logger) IsDebug() bool

func (*Logger) Name

func (this *Logger) Name() string

func (*Logger) String

func (this *Logger) String() string

func (*Logger) Warn

func (this *Logger) Warn(args ...interface{})

type PubSub

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

func (*PubSub) Close

func (this *PubSub) Close() error

Close will unsubscribe all remaining channels

func (*PubSub) Emit

func (this *PubSub) Emit(value interface{})

Emit an event onto all subscriber channels, this method will block until all subscribers receive the value

func (*PubSub) String

func (this *PubSub) String() string

func (*PubSub) Subscribe

func (this *PubSub) Subscribe() <-chan interface{}

Subscribe returns a new channel on which emitting events can occur

func (*PubSub) Unsubscribe

func (this *PubSub) Unsubscribe(subscriber <-chan interface{})

Unsubscribe closes a channel and removes it from the list of channels which emitting can happen on

type Publisher

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

func (*Publisher) Close

func (this *Publisher) Close()

func (*Publisher) Emit

func (this *Publisher) Emit(num uint, value interface{})

func (*Publisher) Init

func (this *Publisher) Init(num uint) *queue

func (*Publisher) NextToken

func (this *Publisher) NextToken() gopi.Channel

func (*Publisher) Subscribe

func (this *Publisher) Subscribe(num uint, callback func(value interface{})) gopi.Channel

func (*Publisher) Unsubscribe

func (this *Publisher) Unsubscribe(token gopi.Channel)

type Unit

type Unit struct {
	Log    gopi.Logger
	Closed bool
}

Unit is the base struct for any unit

func (*Unit) Close

func (this *Unit) Close() error

func (*Unit) Init

func (this *Unit) Init(log gopi.Logger) error

func (*Unit) String

func (this *Unit) String() string