pgsql

Documentation

Index

• type HookStorePostgres
  • func NewHookStorePostgres(pgConnString string) (*HookStorePostgres, error)
  • func (hookStore *HookStorePostgres) BeginTx(ctx context.Context) error
  • func (hookStore *HookStorePostgres) CommitTx(ctx context.Context) error
  • func (hookStore *HookStorePostgres) CreateHookRecord(ctx context.Context, hookRecord *storage.HookRecord, ...) error
  • func (hookStore *HookStorePostgres) DeleteHookRecord(ctx context.Context, hookRecordId string) error
  • func (hookStore *HookStorePostgres) FindHookRecordsForDataRecord(ctx context.Context, dataRecordId string) (map[*storage.HookRecord]*storage.HookConfigurationEntry, error)
  • func (hookStore *HookStorePostgres) FindHookRecordsForSchemaAndProtocol(ctx context.Context, schemaUri string, protocol string, protocolVersion string) (map[*storage.HookRecord]*storage.HookConfigurationEntry, error)
  • func (hookStore *HookStorePostgres) GetHookRecord(ctx context.Context, hookRecordId string) (*storage.HookRecord, *storage.HookConfigurationEntry, error)
  • func (hookStore *HookStorePostgres) GetHookRecordConfigurationEntries(ctx context.Context, hookRecordId string) (*storage.HookRecord, []*storage.HookConfigurationEntry, error)
  • func (hookStore *HookStorePostgres) RollbackTx(ctx context.Context) error
  • func (hookStore *HookStorePostgres) UpdateHookRecord(ctx context.Context, hookRecordId string, ...) error
• type RecordStorePostgres
  • func NewRecordStorePostgres(pgConnString string) (*RecordStorePostgres, error)
  • func (recordStore *RecordStorePostgres) AddMessageEntry(ctx context.Context, entry *storage.MessageEntry) error
  • func (recordStore *RecordStorePostgres) BeginTx(ctx context.Context) error
  • func (recordStore *RecordStorePostgres) CommitTx(ctx context.Context) error
  • func (recordStore *RecordStorePostgres) CreateRecord(ctx context.Context, record *storage.Record, ...) error
  • func (recordStore *RecordStorePostgres) DeleteMessageEntry(ctx context.Context, entry *storage.MessageEntry) error
  • func (recordStore *RecordStorePostgres) DeleteMessageEntryByID(ctx context.Context, messageEntryId string) error
  • func (recordStore *RecordStorePostgres) GetMessageEntryByID(ctx context.Context, messageEntryID string) *storage.MessageEntry
  • func (recordStore *RecordStorePostgres) GetRecord(ctx context.Context, dwnRecordId string) *storage.Record
  • func (recordStore *RecordStorePostgres) RollbackTx(ctx context.Context) error
  • func (recordStore *RecordStorePostgres) SaveRecord(ctx context.Context, record *storage.Record) error

Types

type HookStorePostgres

type HookStorePostgres struct {
	DB       *bun.DB
	ActiveTx *bun.Tx
}

func NewHookStorePostgres

func NewHookStorePostgres(pgConnString string) (*HookStorePostgres, error)

func (*HookStorePostgres) BeginTx

func (hookStore *HookStorePostgres) BeginTx(ctx context.Context) error

func (*HookStorePostgres) CommitTx

func (hookStore *HookStorePostgres) CommitTx(ctx context.Context) error

func (*HookStorePostgres) CreateHookRecord

func (hookStore *HookStorePostgres) CreateHookRecord(ctx context.Context, hookRecord *storage.HookRecord, initialConfiguration *storage.HookConfigurationEntry) error

func (*HookStorePostgres) DeleteHookRecord

func (hookStore *HookStorePostgres) DeleteHookRecord(ctx context.Context, hookRecordId string) error

func (*HookStorePostgres) FindHookRecordsForDataRecord

func (hookStore *HookStorePostgres) FindHookRecordsForDataRecord(ctx context.Context, dataRecordId string) (map[*storage.HookRecord]*storage.HookConfigurationEntry, error)

func (*HookStorePostgres) FindHookRecordsForSchemaAndProtocol

func (hookStore *HookStorePostgres) FindHookRecordsForSchemaAndProtocol(ctx context.Context, schemaUri string, protocol string, protocolVersion string) (map[*storage.HookRecord]*storage.HookConfigurationEntry, error)

func (*HookStorePostgres) GetHookRecord

func (hookStore *HookStorePostgres) GetHookRecord(ctx context.Context, hookRecordId string) (*storage.HookRecord, *storage.HookConfigurationEntry, error)

func (*HookStorePostgres) GetHookRecordConfigurationEntries

func (hookStore *HookStorePostgres) GetHookRecordConfigurationEntries(ctx context.Context, hookRecordId string) (*storage.HookRecord, []*storage.HookConfigurationEntry, error)

func (*HookStorePostgres) RollbackTx

func (hookStore *HookStorePostgres) RollbackTx(ctx context.Context) error

func (*HookStorePostgres) UpdateHookRecord

func (hookStore *HookStorePostgres) UpdateHookRecord(ctx context.Context, hookRecordId string, updatedConfiguration *storage.HookConfigurationEntry) error

type RecordStorePostgres

type RecordStorePostgres struct {
	DB       *bun.DB
	ActiveTx *bun.Tx
}

func NewRecordStorePostgres

func NewRecordStorePostgres(pgConnString string) (*RecordStorePostgres, error)

func (*RecordStorePostgres) AddMessageEntry

func (recordStore *RecordStorePostgres) AddMessageEntry(ctx context.Context, entry *storage.MessageEntry) error

func (*RecordStorePostgres) BeginTx

func (recordStore *RecordStorePostgres) BeginTx(ctx context.Context) error

func (*RecordStorePostgres) CommitTx

func (recordStore *RecordStorePostgres) CommitTx(ctx context.Context) error

func (*RecordStorePostgres) CreateRecord

func (recordStore *RecordStorePostgres) CreateRecord(ctx context.Context, record *storage.Record, initialEntry *storage.MessageEntry) error

func (*RecordStorePostgres) DeleteMessageEntry

func (recordStore *RecordStorePostgres) DeleteMessageEntry(ctx context.Context, entry *storage.MessageEntry) error

func (*RecordStorePostgres) DeleteMessageEntryByID

func (recordStore *RecordStorePostgres) DeleteMessageEntryByID(ctx context.Context, messageEntryId string) error

func (*RecordStorePostgres) GetMessageEntryByID

func (recordStore *RecordStorePostgres) GetMessageEntryByID(ctx context.Context, messageEntryID string) *storage.MessageEntry

func (*RecordStorePostgres) GetRecord

func (recordStore *RecordStorePostgres) GetRecord(ctx context.Context, dwnRecordId string) *storage.Record

func (*RecordStorePostgres) RollbackTx

func (recordStore *RecordStorePostgres) RollbackTx(ctx context.Context) error

func (*RecordStorePostgres) SaveRecord

func (recordStore *RecordStorePostgres) SaveRecord(ctx context.Context, record *storage.Record) error