interfaces

type DB interface {
	Model(model ...interface{}) *orm.Query
	Select(model interface{}) error
	Insert(model ...interface{}) error
	Update(model interface{}) error
	Delete(model interface{}) error

	Exec(query interface{}, params ...interface{}) (*types.Result, error)
	ExecOne(query interface{}, params ...interface{}) (*types.Result, error)
	Query(coll, query interface{}, params ...interface{}) (*types.Result, error)
	QueryOne(coll, query interface{}, params ...interface{}) (*types.Result, error)
	Begin() (*pg.Tx, error)
	Close() error
}

type KafkaConsumerClient interface {
	SubscribeTopics([]string, kafka.RebalanceCb) error
	Events() chan kafka.Event
	Assign([]kafka.TopicPartition) error
	Unassign() error
	Close() error
}

type PushProducer interface {
	SendAPNSPush(topic, deviceToken string, payload, messageMetadata map[string]interface{}, pushMetadata map[string]interface{}, pushExpiry int64, templateName string) error
	SendGCMPush(topic, deviceToken string, payload, messageMetadata map[string]interface{}, pushMetadata map[string]interface{}, pushExpiry int64, templateName string) error
}

type Queue interface {
	MessagesChannel() *chan []byte
	ConsumeLoop() error
	StopConsuming()
	PendingMessagesWaitGroup() *sync.WaitGroup
}

type S3 interface {
	InitMultipartUpload(path string) (*s3.CreateMultipartUploadOutput, error)
	PutObject(path string, body *[]byte) (*s3.PutObjectOutput, error)
	GetObject(path string) ([]byte, error)
	UploadPart(input *bytes.Buffer, multipartUpload *s3.CreateMultipartUploadOutput,
		partNumber int64) (*s3.UploadPartOutput, error)
	PutObjectRequest(path string) (string, error)
	CompleteMultipartUpload(multipartUpload *s3.CreateMultipartUploadOutput, parts []*s3.CompletedPart) error
	DownloadChunk(start, size int64, path string) (int, *bytes.Buffer, error)
}