envelopestore

Documentation

Overview

Package envelopestore provides common implementation used by repositories that persist outbound envelopes.

Index

• Constants
• func Delete(ctx context.Context, tx *sql.Tx, table string, env endpoint.OutboundEnvelope) error
• func Insert(ctx context.Context, tx *sql.Tx, table string, env endpoint.OutboundEnvelope) error
• func Scan(s Scanner) (endpoint.OutboundEnvelope, error)
• type Scanner

Constants

const Columns = `` /* 137-byte string literal not displayed */

Columns is the ordered set of columns that must be SELECTed for use with Scan().

Functions

func Delete

func Delete(
	ctx context.Context,
	tx *sql.Tx,
	table string,
	env endpoint.OutboundEnvelope,
) error

Delete removes a message from the store.

func Insert

func Insert(
	ctx context.Context,
	tx *sql.Tx,
	table string,
	env endpoint.OutboundEnvelope,
) error

Insert adds a message to the store.

func Scan

func Scan(s Scanner) (endpoint.OutboundEnvelope, error)

Scan constructs an outbound envelope by scanning values using s.

Types

type Scanner

type Scanner interface {
	Scan(v ...interface{}) error
}

Scanner is an interface for scanning values from a row or rows.