pubsub

type Doer interface {
	// Do executes a pipe entry.
	Do(context.Context, chan any, chan error) chan any
}

type Getter interface {
	Get(ctx context.Context) (serverID string, err error)
}

type PubSubClient[T ToByteser] struct {
	// contains filtered or unexported fields
}

type PublishInput[T ToByteser] struct {
	Data       T
	Attributes map[string]string
}

type Publisher interface {
	Publish(ctx context.Context, msg *pubsub.Message) Getter
}

type SubscriberPipeline interface {
	// Run executes the pipeline, connecting each registered step in a ordered way.
	Run(ctx context.Context) chan any

	// Map registers a new Mapper step into pipeline, which is modifies the data that passes
	// through the pipeline. It panics if any required dependency is not properly given.
	Map(mapFn func(any) (any, error)) SubscriberPipeline

	// Reduce registers a new Reducer step into pipeline.
	// It panics if any required dependency is not properly given.
	Reduce(reduceFn func(state interface{}, item interface{}, idx int) (newState interface{}, err error), initialState func() interface{}) SubscriberPipeline

	// Batch registers a new Batcher step into pipeline.
	// It panics if any required dependency is not properly given.
	Batch(itemType reflect.Type, batchSize int, timeout time.Duration) SubscriberPipeline

	// Errors exposes all errors that happens during pipeline processing.
	Errors() chan error
}

type SubscriberPipelineParams struct {
	PubsubSubscription steps.Receiver
	// contains filtered or unexported fields
}

type ToByteser interface {
	ToBytes() ([]byte, error)
}

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