connection

type Connection interface {
	// Publish single message over a specific topic/channel
	Publish(ctx context.Context, data interface{}, topic string) error

	// Close connections
	CloseConnection() error

	// Update connection
	UpdateConnection(ctx context.Context, data interface{}) error
}