machinery

Documentation

Index

• type HTTPServer
  • func NewHTTPServer() *HTTPServer
  • func (s *HTTPServer) HandlePlaylist(playlist *pkg.Playlist)
  • func (s *HTTPServer) Start(ctx context.Context) error
• type Machine
  • func NewMachine() (*Machine, error)
  • func (r *Machine) Publish(topic string, messages ...*message.Message) error

Types

type HTTPServer

type HTTPServer struct {
	Playlist *pkg.Playlist
	// contains filtered or unexported fields
}

func NewHTTPServer

func NewHTTPServer() *HTTPServer

func (*HTTPServer) HandlePlaylist

func (s *HTTPServer) HandlePlaylist(playlist *pkg.Playlist)

func (*HTTPServer) Start

func (s *HTTPServer) Start(ctx context.Context) error

type Machine

type Machine struct {
	Router *message.Router
	PubSub *gochannel.GoChannel
}

func NewMachine

func NewMachine() (*Machine, error)

func (*Machine) Publish

func (r *Machine) Publish(topic string, messages ...*message.Message) error