bus

Documentation

Overview

Package implements an internal mechanism to communicate with an impress terminal.

Index

• type ClientPipes
  • func NewClient(suffix string) (*ClientPipes, error)
  • func (p *ClientPipes) Close() error
  • func (p *ClientPipes) NewEventPipe() *rpc.Pipe
  • func (p *ClientPipes) NewStreamPipe() *rpc.Pipe
  • func (p *ClientPipes) NewSyncPipe() *rpc.Pipe
  • func (p *ClientPipes) RequestFile() *os.File
  • func (p *ClientPipes) StreamFile() *os.File
• type Runner
• type ServerPipes
  • func NewServer(runner Runner) (*ServerPipes, error)
  • func (p *ServerPipes) Close() error
  • func (p *ServerPipes) NewEventPipe() *rpc.Pipe
  • func (p *ServerPipes) NewStreamPipe() *rpc.Pipe
  • func (p *ServerPipes) NewSyncPipe() *rpc.Pipe

Types

type ClientPipes

type ClientPipes files

func NewClient

func NewClient(suffix string) (*ClientPipes, error)

func (*ClientPipes) Close

func (p *ClientPipes) Close() error

func (*ClientPipes) NewEventPipe

func (p *ClientPipes) NewEventPipe() *rpc.Pipe

func (*ClientPipes) NewStreamPipe

func (p *ClientPipes) NewStreamPipe() *rpc.Pipe

func (*ClientPipes) NewSyncPipe

func (p *ClientPipes) NewSyncPipe() *rpc.Pipe

func (*ClientPipes) RequestFile

func (p *ClientPipes) RequestFile() *os.File

func (*ClientPipes) StreamFile

func (p *ClientPipes) StreamFile() *os.File

type Runner

type Runner interface {
	Run(suffix string) error
	Wait() error
}

type ServerPipes

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

func NewServer

func NewServer(runner Runner) (*ServerPipes, error)

func (*ServerPipes) Close

func (p *ServerPipes) Close() error

func (*ServerPipes) NewEventPipe

func (p *ServerPipes) NewEventPipe() *rpc.Pipe

func (*ServerPipes) NewStreamPipe

func (p *ServerPipes) NewStreamPipe() *rpc.Pipe

func (*ServerPipes) NewSyncPipe

func (p *ServerPipes) NewSyncPipe() *rpc.Pipe