streamer

type BuildStreamableServer struct {
	pb.Build_BuildInfoServer
}

type Loggy interface {
	Debug(args ...interface{})
	Error(args ...interface{})
	Info(args ...interface{})
}

type StreamArray interface {
	GetData() [][]byte
	CheckDone() bool
	Append(line []byte)
	sync.Locker
}

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

type StreamPack struct {
	Consul    *consul.Consulet
	Store     storage.OcelotStorage
	BuildInfo map[string]*buildDatum
}

type Streamable interface {
	SendIt(data []byte) error
	SendError(errorDesc []byte)
	Finish(chan int)
}