package pubsub

import (
	"context"
)

type Publisher interface {
	Send(ctx context.Context, topicID string, message []byte, attributes map[string]string) error
}