mongodb

Documentation

Index

• Constants
• func MakeQueryBSON(params audit.QueryParams) bson.M
• type InsertDoc
  • func MakeInsertDoc(event audit.EventBase) (doc InsertDoc)
• type Repo
  • func MakeMongoRepo(mongoUri string) *Repo
  • func (r *Repo) Close()
  • func (r *Repo) FindEvents(ctx context.Context, params audit.QueryParams) ([]audit.Event, error)
  • func (r *Repo) InsertEvent(ctx context.Context, event audit.EventBase) (audit.ID, error)

Constants

const COLL = "events"

const DB = "dbevent"

Functions

func MakeQueryBSON

func MakeQueryBSON(params audit.QueryParams) bson.M

Types

type InsertDoc

type InsertDoc struct {
	Type      string                 `bson:"type"`
	Consumer  string                 `bson:"consumer"`
	Payload   map[string]interface{} `bson:"payload,inline,omitempty"`
	CreatedAt time.Time              `bson:"created_at"`
}

func MakeInsertDoc

func MakeInsertDoc(event audit.EventBase) (doc InsertDoc)

type Repo

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

func MakeMongoRepo

func MakeMongoRepo(mongoUri string) *Repo

func (*Repo) Close

func (r *Repo) Close()

func (*Repo) FindEvents

func (r *Repo) FindEvents(ctx context.Context, params audit.QueryParams) ([]audit.Event, error)

func (*Repo) InsertEvent

func (r *Repo) InsertEvent(ctx context.Context, event audit.EventBase) (audit.ID, error)