pubsub

type GooglePubSub struct {
	ServiceAccount []byte `json:"service_account" valid:"required~service account is required"`
	SubscriptionID string `json:"subscription_id" valid:"required~subscription id is required"`
	ProjectID      string `json:"project_id" valid:"required~project id is required"`
}

type KafkaAuth struct {
	Type     string `json:"type" valid:"optional,in(plain|scram)~unsupported auth type"`
	Hash     string `json:"hash" valid:"optional,in(SHA256|SHA512)~unsupported hashing algorithm"`
	Username string `json:"username"`
	Password string `json:"password"`
	TLS      bool   `json:"tls"`
}

type KafkaPubSub struct {
	Brokers         []string   `json:"brokers" valid:"required~brokers list is required"`
	ConsumerGroupID string     `json:"consumer_group_id" valid:"required~consumer group ID is required"`
	TopicName       string     `json:"topic_name" valid:"required~topic name is required"`
	Auth            *KafkaAuth `json:"auth"`
}

type PS struct {
	Type    datastore.PubSubType `json:"type" valid:"required~type is required,supported_pub_sub~unsupported pub sub type"`
	Workers int                  `json:"workers" valid:"required"`
}

type PubSub interface {
	Start()
	Consume()
	Stop()
}

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

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

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

type SqsPubSub struct {
	AccessKeyID   string `json:"access_key_id" valid:"required"`
	SecretKey     string `json:"secret_key" valid:"required"`
	DefaultRegion string `json:"default_region" valid:"required"`
	QueueName     string `json:"queue_name" valid:"required"`
}