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 NewConfigRepo(db *mongo.Database) datastore.ConfigurationRepository
• func NewEventDeliveryRepository(db *mongo.Database) datastore.EventDeliveryRepository
• func NewEventRepository(db *mongo.Database) datastore.EventRepository
• func NewGroupRepo(db *mongo.Database) datastore.GroupRepository
• func NewOrgInviteRepo(db *mongo.Database) datastore.OrganisationInviteRepository
• func NewOrgMemberRepo(db *mongo.Database) datastore.OrganisationMemberRepository
• func NewOrgRepo(db *mongo.Database) datastore.OrganisationRepository
• func NewSourceRepo(db *mongo.Database) datastore.SourceRepository
• func NewSubscriptionRepo(db *mongo.Database) datastore.SubscriptionRepository
• func NewUserRepo(db *mongo.Database) datastore.UserRepository
• type Client
  • func (c *Client) APIRepo() datastore.APIKeyRepository
  • func (c *Client) AppRepo() datastore.ApplicationRepository
  • func (c *Client) Client() interface{}
  • func (c *Client) ConfigurationRepo() datastore.ConfigurationRepository
  • 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) OrganisationInviteRepo() datastore.OrganisationInviteRepository
  • func (c *Client) OrganisationMemberRepo() datastore.OrganisationMemberRepository
  • func (c *Client) OrganisationRepo() datastore.OrganisationRepository
  • func (c *Client) SourceRepo() datastore.SourceRepository
  • func (c *Client) SubRepo() datastore.SubscriptionRepository
  • func (c *Client) UserRepo() datastore.UserRepository

Constants

const (
	ConfigCollection              = "configurations"
	GroupCollection               = "groups"
	OrganisationCollection        = "organisations"
	OrganisationInvitesCollection = "organisation_invites"
	OrganisationMembersCollection = "organisation_members"
	AppCollection                 = "applications"
	EventCollection               = "events"
	SourceCollection              = "sources"
	UserCollection                = "users"
	SubscriptionCollection        = "subscriptions"
)

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 NewConfigRepo

func NewConfigRepo(db *mongo.Database) datastore.ConfigurationRepository

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 NewOrgInviteRepo

func NewOrgInviteRepo(db *mongo.Database) datastore.OrganisationInviteRepository

func NewOrgMemberRepo

func NewOrgMemberRepo(db *mongo.Database) datastore.OrganisationMemberRepository

func NewOrgRepo

func NewOrgRepo(db *mongo.Database) datastore.OrganisationRepository

func NewSourceRepo

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

func NewSubscriptionRepo

func NewSubscriptionRepo(db *mongo.Database) datastore.SubscriptionRepository

func NewUserRepo

func NewUserRepo(db *mongo.Database) datastore.UserRepository

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) ConfigurationRepo

func (c *Client) ConfigurationRepo() datastore.ConfigurationRepository

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) OrganisationInviteRepo

func (c *Client) OrganisationInviteRepo() datastore.OrganisationInviteRepository

func (*Client) OrganisationMemberRepo

func (c *Client) OrganisationMemberRepo() datastore.OrganisationMemberRepository

func (*Client) OrganisationRepo

func (c *Client) OrganisationRepo() datastore.OrganisationRepository

func (*Client) SourceRepo

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

func (*Client) SubRepo

func (c *Client) SubRepo() datastore.SubscriptionRepository

func (*Client) UserRepo

func (c *Client) UserRepo() datastore.UserRepository