proto

type ProtoBuilder interface {
	// slave side
	// These functions are executed in the following order
	Init(context.Context, *pb.ExecuteTaskRequest) error
	PreRequest(*pb.ExecuteTaskRequest) (interface{}, interface{})
	Request(context.Context, interface{}, *pb.ExecuteTaskRequest) interface{}
	PostRequest(interface{}) error
	Destroy(interface{}) error
	Done(time.Duration) (interface{}, error)

	// master side
	Split(*pb.ExecuteTaskRequest, int) []*pb.ExecuteTaskRequest
	Merge([]string) (interface{}, error)

	// client side
	CreateTask(*config.ProtoConfigArgs) (string, error)
}

type ProtoBuilderBase struct {
	ProtoBuilder
	Template *string
	Stats    interface{}
}

type SqueezeResponse struct {
	Data  *SqueezeResult `json:"data"`
	Error string         `json:"error"`
}

type SqueezeResult struct {
	ID         uint32         `json:"id"`
	AgentStats []SqueezeStats `json:"agent_stats"`
	Result     interface{}    `json:"result"`
}

type SqueezeStats struct {
	Addr   string `json:"addr"`
	Status int32  `json:"status"`
	Error  string `json:"error"`
}