package stargate

import (
	"github.com/Shopify/sarama"
	"github.com/pingcap/wormhole/pkg/whpb"
)

type sqlJob struct {
	sql  string
	args []interface{}
	pos  *whpb.Position
	msg  *sarama.ConsumerMessage
	tp   string
}

func (m *MysqlStargate) newJob(sql string, args []interface{}, pos *whpb.Position, msg *sarama.ConsumerMessage, tp string) *sqlJob {
	return &sqlJob{sql: sql, args: args, pos: pos, msg: msg, tp: tp}
}