command

Documentation

Index

• Constants
• func Playback(ip string, index int, playlist []string, delays []float64)
• type ACK
  • func Send(cmd *Command, ip string, responseBuffer []byte) *ACK
• type Command
  • func (cmd *Command) String() string
• type QueueWorker
  • func NewQueueWorker(tcpAddress string) *QueueWorker

Constants

const RemoteComponentName = "zug_ins_nirgendwo_2019"

Functions

func Playback

func Playback(ip string, index int, playlist []string, delays []float64)

Playback sends the provided index and playlist to an attached media_player

Types

type ACK

type ACK struct {
	Command *Command `json:"command"`
	Success bool     `json:"success"`
	Value   string   `json:"value"`
}

ACK is used as simple ACK for received commands

func Send

func Send(cmd *Command, ip string, responseBuffer []byte) *ACK

Send will send the provided command via tcp to the provided ip-address. return: an ACK for the Command

type Command

type Command struct {
	CommandID int           `json:"id"`
	Command   string        `json:"cmd"`
	Arguments []interface{} `json:"arg"`
}

Command realizes a simple RPC interface

func (*Command) String

func (cmd *Command) String() string

type QueueWorker

type QueueWorker struct {
	TCPAddress string
	Commands   chan *Command
	Results    chan *ACK
}

QueueWorker pulls commands from a channel, sends them via tcp and pushes results back to the results channel

func NewQueueWorker

func NewQueueWorker(tcpAddress string) *QueueWorker

NewQueueWorker creates a new instance