connection

Documentation

Index

• Variables
• func GetCommunicationChannels() (*Out, *In)
• func InitializeThreads() error
• func Reader(out *Out, in *In)
• func Writer(out *Out, in *In)
• type In
  • func GetInputChannels() *In
• type Out
  • func GetOutputChannels() *Out

Variables

var StdIn io.WriteCloser

Single Connection var conn net.Conn

var StdOut io.ReadCloser

Functions

func GetCommunicationChannels

func GetCommunicationChannels() (*Out, *In)

func InitializeThreads

func InitializeThreads() error

Initializes threads with Channel Structs Opens Connection

func Reader

func Reader(out *Out, in *In)

func Writer

func Writer(out *Out, in *In)

Types

type In

type In struct {
	Commands chan *commands.Command
	Quit     chan int
}

func GetInputChannels

func GetInputChannels() *In

type Out

type Out struct {
	CommandResponses chan commands.CommandResponse
	Errors           chan error
}

func GetOutputChannels

func GetOutputChannels() *Out