command

Documentation

Index

• type Command
• type NoopReader
  • func (_ *NoopReader) Read(ctx context.Context, deviceId string) *Command
  • func (_ *NoopReader) Start() error
  • func (_ *NoopReader) Stop() error
• type OnDemandReader
  • func (r *OnDemandReader) Read(ctx context.Context, _ string) *Command
  • func (r *OnDemandReader) Start() error
  • func (r *OnDemandReader) Stop() error
• type PreFillReader
  • func (r *PreFillReader) Read(ctx context.Context, _ string) *Command
  • func (r *PreFillReader) Start() error
  • func (r *PreFillReader) Stop() error
• type Reader
  • func GetReader() Reader
• type StaticReader
  • func NewStatic(commandName string, encoder encoding.PayloadEncoder, payload string) (*StaticReader, error)
  • func (s *StaticReader) Read(_ context.Context, _ string) *Command
  • func (_ *StaticReader) Start() error
  • func (_ *StaticReader) Stop() error

Types

type Command

type Command struct {
	Command     string
	ContentType string
	Payload     *bytes.Buffer
}

type NoopReader

type NoopReader struct {
}

func (*NoopReader) Read

func (_ *NoopReader) Read(ctx context.Context, deviceId string) *Command

func (*NoopReader) Start

func (_ *NoopReader) Start() error

func (*NoopReader) Stop

func (_ *NoopReader) Stop() error

type OnDemandReader

type OnDemandReader struct {
	CommandName string
	Stream      io.Reader
	Prompt      io.Writer
	Encoder     encoding.PayloadEncoder
	// contains filtered or unexported fields
}

func (*OnDemandReader) Read

func (r *OnDemandReader) Read(ctx context.Context, _ string) *Command

func (*OnDemandReader) Start

func (r *OnDemandReader) Start() error

func (*OnDemandReader) Stop

func (r *OnDemandReader) Stop() error

type PreFillReader

type PreFillReader struct {
	CommandName string
	Stream      io.Reader
	Prompt      io.Writer
	Encoder     encoding.PayloadEncoder
	// contains filtered or unexported fields
}

func (*PreFillReader) Read

func (r *PreFillReader) Read(ctx context.Context, _ string) *Command

func (*PreFillReader) Start

func (r *PreFillReader) Start() error

func (*PreFillReader) Stop

func (r *PreFillReader) Stop() error

type Reader

type Reader interface {
	Start() error
	Stop() error

	Read(ctx context.Context, deviceId string) *Command
}

func GetReader

func GetReader() Reader

type StaticReader

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

func NewStatic

func NewStatic(commandName string, encoder encoding.PayloadEncoder, payload string) (*StaticReader, error)

func (*StaticReader) Read

func (s *StaticReader) Read(_ context.Context, _ string) *Command

func (*StaticReader) Start

func (_ *StaticReader) Start() error

func (*StaticReader) Stop

func (_ *StaticReader) Stop() error