aq

type AQMessage []byte

type JSONMarshaler struct{}

type Marshaler interface {
	// Marshal transforms a watermill message into NATS wire format.
	Marshal(msg *message.Message) (AQMessage, error)
}

type MarshalerUnmarshaler interface {
	Marshaler
	Unmarshaler
}

type Message struct {
	MsgID    string
	Data     []byte
	Metadata map[string]string
}

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

type PublisherConfig struct {
	QueueConsumer  string // Name of the queue subscriber/consumer
	Payload        string // Payload type
	Transformation string // Payload oracle transformation name

	Marshaler Marshaler
}

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

type SubscriberConfig struct {
	QueueConsumer  string        // Name of the queue subscriber/consumer
	Payload        string        // Payload type
	Transformation string        // Payload oracle transformation name
	QueueWaitTime  time.Duration // Wait time for the queue to return data
	BatchSize      int           // Number of messages to fetch in a single call

	Timeout time.Duration // Timeout for the sql query operation

	Unmarshaler Unmarshaler
}

type Transactor interface {
	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
	Close() error
}

type Unmarshaler interface {
	// Unmarshal produces a watermill message from NATS wire format.
	Unmarshal(AQMessage) (*message.Message, error)
}