storage

Documentation

Index

• type Storage
  • func New(db *gorm.DB, logger log.Logger) *Storage
  • func (s *Storage) AllWebhooks() (webhooks []*model.Webhook, err error)
  • func (s *Storage) CountRows(webhookId uint32) (uint, error)
  • func (s *Storage) Fetch(webhookHash string, target io.Writer) (webhook *model.Webhook, err error)
  • func (s *Storage) FlushData(webhookHash string) (result string, err error)
  • func (s *Storage) Get(hashStr string) (*model.Webhook, error)
  • func (s *Storage) MigrateDb() error
  • func (s *Storage) RegisterWebhook(token model.Token, tableId string, conditions model.Conditions) (*model.Webhook, error)
  • func (s *Storage) UpdateWebhook(webhookHash string, conditions model.Conditions) (webhook *model.Webhook, err error)
  • func (s *Storage) WriteRow(webhookHash string, headers, body string) (webhook *model.Webhook, count uint, err error)

Types

type Storage

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

func New

func New(db *gorm.DB, logger log.Logger) *Storage

func (*Storage) AllWebhooks

func (s *Storage) AllWebhooks() (webhooks []*model.Webhook, err error)

func (*Storage) CountRows

func (s *Storage) CountRows(webhookId uint32) (uint, error)

func (*Storage) Fetch

func (s *Storage) Fetch(webhookHash string, target io.Writer) (webhook *model.Webhook, err error)

func (*Storage) FlushData

func (s *Storage) FlushData(webhookHash string) (result string, err error)

func (*Storage) Get

func (s *Storage) Get(hashStr string) (*model.Webhook, error)

func (*Storage) MigrateDb

func (s *Storage) MigrateDb() error

func (*Storage) RegisterWebhook

func (s *Storage) RegisterWebhook(token model.Token, tableId string, conditions model.Conditions) (*model.Webhook, error)

func (*Storage) UpdateWebhook

func (s *Storage) UpdateWebhook(webhookHash string, conditions model.Conditions) (webhook *model.Webhook, err error)

func (*Storage) WriteRow

func (s *Storage) WriteRow(webhookHash string, headers, body string) (webhook *model.Webhook, count uint, err error)