gcppubsubadapters

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 SubscriberConfig struct {
	SearchSubscriptionID      string
	BatchUpdateSubscriptionID string
}