storm

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

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

type BoltInput struct {
	//TupleMessage - the tuple and it's metadata
	TupleMessage

	//Component - The id of the creating component
	Component string `json:"comp"`
}

type BoltOutput struct {

	//TupleMessage - the tuple and it's metadata
	TupleMessage

	//Anchors - The ids of the tuples these output tuples should be anchored to
	Anchors []string `json:"anchors"`

	//Command - ack, fail, emit, log
	Command string `json:"command"`

	//Message - for log only
	Message string `json:"message",omitempty`
}

type BoltProcessor interface {
	Process(tuple *TupleMessage) (*TupleMessage, error)
	TrackIndirectEmit(taskIds []int)
}

type ComponentDef struct {
	ShellCommand string //to execute
	OutputFields []string
	Direct       bool
	Parallelism  int32
}

type ConnectInfo struct {
	Conf    *json.RawMessage `json:"conf"`
	Context *json.RawMessage `json:"context"`
	PidDir  string           `json:"pidDir"`
}

type DistributeHow string

type EmiterName interface {
	Name() string
}

type ProcessId struct {
	Pid string `json:"pid"`
}

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

type SpoutMessage struct {

	//TupleMessage - the tuple and it's metadata
	TupleMessage

	// Command - next, ack, fail, emit, log, sync
	Command string `json:"command"`

	//Message - for log only
	Message string `json:"message",omitempty`
}

type Spouter interface {
	Emit() *TupleMessage
	Ack(id string)
	Fail(id string)
	AssociateTasks(id string, taskIds []int)
}

type Storm struct {
	Input  chan []byte
	Output chan interface{}

	ExtIn  io.Reader
	ExtOut io.Writer
	// contains filtered or unexported fields
}

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

type TupleMessage struct {

	//Id - To identifiy this tuple, for messaging guarantees
	Id string `json:"id",omitempty`

	//Stream - Id of the stream this tuple is emmited to. Blank==default stream
	Stream string `json:"stream",omitempty`

	//Task - For direct emit
	Task *int32 `json:"task",omitempty`

	//Tuple - A 'row' of data
	Tuple []interface{} `json:"tuple"`
}