mongodbimpl

Documentation

Index

• Constants
• type IndexDefinition
• type IndexField
• type Storage
  • func NewStorage(uri, dbname string) (*Storage, error)
  • func (m *Storage) AddWebhook(webhook *core.Webhook) error
  • func (m *Storage) DeleteRequest(id string) error
  • func (m *Storage) GetAllWebhooks() ([]*core.Webhook, error)
  • func (m *Storage) GetNewestRequests(count int) ([]*core.Request, error)
  • func (m *Storage) GetOldestRequests(count int) ([]*core.Request, error)
  • func (m *Storage) GetRequest(id string) (*core.Request, error)
  • func (m *Storage) GetWebhook(id string) (*core.Webhook, error)
  • func (m *Storage) RemoveWebhook(id string) error
  • func (m *Storage) StoreRequest(request *core.Request) error
  • func (m *Storage) UpdateWebhook(webhook *core.Webhook) error

Constants

const (
	OrderASC  int = 1
	OrderDESC int = -1
)

Types

type IndexDefinition

type IndexDefinition struct {
	Fields []IndexField
	// Name of the index, it is automatically suffixed with "Idx" so no need to add that
	Name string
}

type IndexField

type IndexField struct {
	Name  string
	Order int
}

type Storage

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

func NewStorage

func NewStorage(uri, dbname string) (*Storage, error)

func (*Storage) AddWebhook

func (m *Storage) AddWebhook(webhook *core.Webhook) error

func (*Storage) DeleteRequest

func (m *Storage) DeleteRequest(id string) error

func (*Storage) GetAllWebhooks

func (m *Storage) GetAllWebhooks() ([]*core.Webhook, error)

func (*Storage) GetNewestRequests

func (m *Storage) GetNewestRequests(count int) ([]*core.Request, error)

func (*Storage) GetOldestRequests

func (m *Storage) GetOldestRequests(count int) ([]*core.Request, error)

func (*Storage) GetRequest

func (m *Storage) GetRequest(id string) (*core.Request, error)

func (*Storage) GetWebhook

func (m *Storage) GetWebhook(id string) (*core.Webhook, error)

func (*Storage) RemoveWebhook

func (m *Storage) RemoveWebhook(id string) error

func (*Storage) StoreRequest

func (m *Storage) StoreRequest(request *core.Request) error

func (*Storage) UpdateWebhook

func (m *Storage) UpdateWebhook(webhook *core.Webhook) error