type Chain interface { Publish(interface{}) error Subscribe(mq.MQHandler) Unsubscribe() io.Closer }
func NewChain(cfg config.Config, ami ami.AMI, data map[string]string) (Chain, error)