mongo

Documentation

Index

• Constants
• func New(cfg config.Configuration) (datastore.DatabaseClient, error)
• func NewApiKeyRepo(client *mongo.Database) datastore.APIKeyRepository
• func NewApplicationRepo(db *mongo.Database) datastore.ApplicationRepository
• func NewEventDeliveryRepository(db *mongo.Database) datastore.EventDeliveryRepository
• func NewEventRepository(db *mongo.Database) datastore.EventRepository
• func NewGroupRepo(db *mongo.Database) datastore.GroupRepository
• func NewSourceRepo(db *mongo.Database) datastore.SourceRepository
• type Client
  • func (c *Client) APIRepo() datastore.APIKeyRepository
  • func (c *Client) AppRepo() datastore.ApplicationRepository
  • func (c *Client) Client() interface{}
  • func (c *Client) Disconnect(ctx context.Context) error
  • func (c *Client) EventDeliveryRepo() datastore.EventDeliveryRepository
  • func (c *Client) EventRepo() datastore.EventRepository
  • func (c *Client) GetName() string
  • func (c *Client) GroupRepo() datastore.GroupRepository
  • func (c *Client) SourceRepo() datastore.SourceRepository

Constants

const (
	GroupCollection  = "groups"
	AppCollections   = "applications"
	EventCollection  = "events"
	SourceCollection = "sources"
)

const APIKeyCollection = "apiKeys"

const (
	EventDeliveryCollection = "eventdeliveries"
)

Functions

func New

func New(cfg config.Configuration) (datastore.DatabaseClient, error)

func NewApiKeyRepo

func NewApiKeyRepo(client *mongo.Database) datastore.APIKeyRepository

func NewApplicationRepo

func NewApplicationRepo(db *mongo.Database) datastore.ApplicationRepository

func NewEventDeliveryRepository

func NewEventDeliveryRepository(db *mongo.Database) datastore.EventDeliveryRepository

func NewEventRepository

func NewEventRepository(db *mongo.Database) datastore.EventRepository

func NewGroupRepo

func NewGroupRepo(db *mongo.Database) datastore.GroupRepository

func NewSourceRepo

func NewSourceRepo(db *mongo.Database) datastore.SourceRepository

Types

type Client

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

func (*Client) APIRepo

func (c *Client) APIRepo() datastore.APIKeyRepository

func (*Client) AppRepo

func (c *Client) AppRepo() datastore.ApplicationRepository

func (*Client) Client

func (c *Client) Client() interface{}

func (*Client) Disconnect

func (c *Client) Disconnect(ctx context.Context) error

func (*Client) EventDeliveryRepo

func (c *Client) EventDeliveryRepo() datastore.EventDeliveryRepository

func (*Client) EventRepo

func (c *Client) EventRepo() datastore.EventRepository

func (*Client) GetName

func (c *Client) GetName() string

func (*Client) GroupRepo

func (c *Client) GroupRepo() datastore.GroupRepository

func (*Client) SourceRepo

func (c *Client) SourceRepo() datastore.SourceRepository