gcppubsubadapters

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

type EmailWorkerMessageHandler interface {
	ProcessMessage(ctx context.Context, job workertypes.IncomingEmailDeliveryJob) error
}

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

type EventProducerBatchUpdateHandler interface {
	ProcessBatchUpdate(ctx context.Context, triggerID string, frequency workertypes.JobFrequency) error
}

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

type EventProducerSearchMessageHandler interface {
	ProcessSearch(ctx context.Context, searchID string, query string,
		frequency workertypes.JobFrequency, triggerID string) error
}

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

type EventPublisher interface {
	Publish(ctx context.Context, topicID string, data []byte) (string, error)
}

type EventSubscriber interface {
	Subscribe(ctx context.Context, subID string,
		handler func(ctx context.Context, msgID string, data []byte) error) error
}

type PushDeliveryMessageHandler interface {
	ProcessEvent(ctx context.Context, metadata workertypes.DispatchEventMetadata, summary []byte) error
}

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

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

type SubscriberConfig struct {
	SearchSubscriptionID      string
	BatchUpdateSubscriptionID string
}