mock

Documentation

Index

• type Control
  • func NewControl(ctx context.Context, errs chan error, reqs, cmds chan string, ...) *Control
  • func (c *Control) BuildCommand(cmd string) (*command.Command, error)
  • func (c *Control) Cleanup()
  • func (c *Control) CreateBuffer(name, doctype string) error
  • func (c *Control) DeleteBuffer(name, doctype string) error
  • func (c *Control) Errorwriter() (*writer.WriteCloser, error)
  • func (c *Control) Event(ev string) error
  • func (c *Control) FileWriter(buffer, doctype string) (*writer.WriteCloser, error)
  • func (c *Control) HasBuffer(name, doctype string) bool
  • func (c *Control) ImageWriter(buffer, resource string) (*writer.WriteCloser, error)
  • func (c *Control) Listen() error
  • func (c *Control) Notification(string, string, string) error
  • func (c *Control) Remove(name, doctype string) error
  • func (c *Control) SetCommands(cmd ...*command.Command) error
  • func (c *Control) Start() (context.Context, error)
• type Input
  • func NewInput(reqs chan string) *Input
  • func (i *Input) AddErr(format string, args ...interface{})
  • func (i *Input) Close() error
  • func (i *Input) Errs() []error
  • func (i *Input) Read(b []byte) (n int, err error)
  • func (i *Input) Stop(ctx context.Context)

Types

type Control

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

func NewControl

func NewControl(ctx context.Context, errs chan error, reqs, cmds chan string, done chan struct{}) *Control

func (*Control) BuildCommand

func (c *Control) BuildCommand(cmd string) (*command.Command, error)

func (*Control) Cleanup

func (c *Control) Cleanup()

func (*Control) CreateBuffer

func (c *Control) CreateBuffer(name, doctype string) error

func (*Control) DeleteBuffer

func (c *Control) DeleteBuffer(name, doctype string) error

func (*Control) Errorwriter

func (c *Control) Errorwriter() (*writer.WriteCloser, error)

func (*Control) Event

func (c *Control) Event(ev string) error

func (*Control) FileWriter

func (c *Control) FileWriter(buffer, doctype string) (*writer.WriteCloser, error)

func (*Control) HasBuffer

func (c *Control) HasBuffer(name, doctype string) bool

func (*Control) ImageWriter

func (c *Control) ImageWriter(buffer, resource string) (*writer.WriteCloser, error)

func (*Control) Listen

func (c *Control) Listen() error

func (*Control) Notification

func (c *Control) Notification(string, string, string) error

func (*Control) Remove

func (c *Control) Remove(name, doctype string) error

func (*Control) SetCommands

func (c *Control) SetCommands(cmd ...*command.Command) error

func (*Control) Start

func (c *Control) Start() (context.Context, error)

type Input

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

func NewInput

func NewInput(reqs chan string) *Input

func (*Input) AddErr

func (i *Input) AddErr(format string, args ...interface{})

func (*Input) Close

func (i *Input) Close() error

func (*Input) Errs

func (i *Input) Errs() []error

func (*Input) Read

func (i *Input) Read(b []byte) (n int, err error)

func (*Input) Stop

func (i *Input) Stop(ctx context.Context)