persist

Documentation

Index

• Variables
• type CleanupService
  • func NewCleanupService(store Store) *CleanupService
  • func (c *CleanupService) Start(ctx context.Context)
• type MemoryStore
  • func (m *MemoryStore) DeleteExpired(ctx context.Context, before time.Time) error
  • func (m *MemoryStore) GetLastUpdated(ctx context.Context, identifier string) (*Webhook, error)
  • func (m *MemoryStore) Remove(ctx context.Context, pubkey, url string) error
  • func (m *MemoryStore) Set(ctx context.Context, webhook Webhook) (*Webhook, error)
• type PgStore
  • func NewPgStore(databaseUrl string) (*PgStore, error)
  • func (s *PgStore) DeleteExpired(ctx context.Context, before time.Time) error
  • func (s *PgStore) GetLastUpdated(ctx context.Context, identifier string) (*Webhook, error)
  • func (s *PgStore) Remove(ctx context.Context, pubkey, url string) error
  • func (s *PgStore) Set(ctx context.Context, webhook Webhook) (*Webhook, error)
• type PubkeyUsername
• type Store
• type Webhook
  • func (w Webhook) Compare(identifier string) bool

Variables

var CleanupInterval time.Duration = time.Hour

The interval to clean expired webhook urls.

var ExpiryDuration time.Duration = time.Hour * 24 * 30

The expiry duration is the time until a non-refreshed webhook url expires. Currently set to 30 days.

Types

type CleanupService

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

func NewCleanupService

func NewCleanupService(store Store) *CleanupService

func (*CleanupService) Start

func (c *CleanupService) Start(ctx context.Context)

Periodically cleans up expired webhook urls.

type MemoryStore

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

func (*MemoryStore) DeleteExpired

func (m *MemoryStore) DeleteExpired(ctx context.Context, before time.Time) error

func (*MemoryStore) GetLastUpdated

func (m *MemoryStore) GetLastUpdated(ctx context.Context, identifier string) (*Webhook, error)

func (*MemoryStore) Remove

func (m *MemoryStore) Remove(ctx context.Context, pubkey, url string) error

func (*MemoryStore) Set

func (m *MemoryStore) Set(ctx context.Context, webhook Webhook) (*Webhook, error)

type PgStore

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

func NewPgStore

func NewPgStore(databaseUrl string) (*PgStore, error)

func (*PgStore) DeleteExpired

func (s *PgStore) DeleteExpired(
	ctx context.Context,
	before time.Time,
) error

func (*PgStore) GetLastUpdated

func (s *PgStore) GetLastUpdated(ctx context.Context, identifier string) (*Webhook, error)

func (*PgStore) Remove

func (s *PgStore) Remove(ctx context.Context, pubkey, url string) error

func (*PgStore) Set

func (s *PgStore) Set(ctx context.Context, webhook Webhook) (*Webhook, error)

type PubkeyUsername

type PubkeyUsername struct {
	Pubkey   string `json:"pubkey" db:"pubkey"`
	Username string `json:"username" db:"username"`
}

type Store

type Store interface {
	Set(ctx context.Context, webhook Webhook) (*Webhook, error)
	GetLastUpdated(ctx context.Context, identifier string) (*Webhook, error)
	Remove(ctx context.Context, pubkey, url string) error
	DeleteExpired(ctx context.Context, before time.Time) error
}

type Webhook

type Webhook struct {
	Pubkey   string  `json:"pubkey" db:"pubkey"`
	Username *string `json:"username" db:"username"`
	Url      string  `json:"url" db:"url"`
}

func (Webhook) Compare

func (w Webhook) Compare(identifier string) bool