store

Documentation

Index

• func NewClient(collection string) (c *mongo.Collection)
• type EventStoreClient
  • func NewStoreEvent(collection string) (c *EventStoreClient)
  • func (c *EventStoreClient) Create(ctx context.Context, eventInsert *v1alpha1.Event) (result *v1alpha1.Event, err error)
  • func (c *EventStoreClient) Get(ctx context.Context, filter map[string]interface{}) (result *v1alpha1.Event, err error)
  • func (c *EventStoreClient) List(ctx context.Context) (results []*v1alpha1.Event, err error)
  • func (c *EventStoreClient) Search(ctx context.Context, filter map[string]interface{}) (results []*v1alpha1.Event, err error)
• type LockStoreClient
  • func NewStoreLock(collection string) (c *LockStoreClient)
  • func (c *LockStoreClient) Create(ctx context.Context, lockInsert *v1alpha1.Lock) (result *v1alpha1.Lock, err error)
  • func (c *LockStoreClient) Get(ctx context.Context, filter map[string]interface{}) (result *v1alpha1.Lock, err error)
  • func (c *LockStoreClient) List(ctx context.Context) (results []*v1alpha1.Lock, err error)
  • func (c *LockStoreClient) Unlock(ctx context.Context, filter map[string]interface{}) (count int64, err error)
• type MongoClient
  • func (c *MongoClient) Count(ctx context.Context) (count int64, err error)

Functions

func NewClient

func NewClient(collection string) (c *mongo.Collection)

Types

type EventStoreClient

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

func NewStoreEvent

func NewStoreEvent(collection string) (c *EventStoreClient)

func (*EventStoreClient) Create

func (c *EventStoreClient) Create(ctx context.Context, eventInsert *v1alpha1.Event) (result *v1alpha1.Event, err error)

Create takes the representation of an Event and creates it. Returns the server's representation of the Event, and an error, if there is any.

func (*EventStoreClient) Get

func (c *EventStoreClient) Get(ctx context.Context, filter map[string]interface{}) (result *v1alpha1.Event, err error)

Get an Event and creates it. Returns the server's representation of the Event, and an error, if there is any.

func (*EventStoreClient) List

func (c *EventStoreClient) List(ctx context.Context) (results []*v1alpha1.Event, err error)

List takes label and field selectors, and returns the list of Events that match those selectors.

func (*EventStoreClient) Search

func (c *EventStoreClient) Search(ctx context.Context, filter map[string]interface{}) (results []*v1alpha1.Event, err error)

Search and returns the list of Events that match those selectors.

type LockStoreClient

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

func NewStoreLock

func NewStoreLock(collection string) (c *LockStoreClient)

func (*LockStoreClient) Create

func (c *LockStoreClient) Create(ctx context.Context, lockInsert *v1alpha1.Lock) (result *v1alpha1.Lock, err error)

Create takes the representation of an Lock and creates it. Returns the server's representation of the Lock, and an error, if there is any.

func (*LockStoreClient) Get

func (c *LockStoreClient) Get(ctx context.Context, filter map[string]interface{}) (result *v1alpha1.Lock, err error)

Get an Lock and creates it. Returns the server's representation of the Lock, and an error, if there is any.

func (*LockStoreClient) List

func (c *LockStoreClient) List(ctx context.Context) (results []*v1alpha1.Lock, err error)

List takes label and field selectors, and returns the list of Locks that match those selectors.

func (*LockStoreClient) Unlock

func (c *LockStoreClient) Unlock(ctx context.Context, filter map[string]interface{}) (count int64, err error)

Search and returns the list of Locks that match those selectors.

type MongoClient

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

MongoClient is used to interact with features

func (*MongoClient) Count

func (c *MongoClient) Count(ctx context.Context) (count int64, err error)

Get an Event and creates it. Returns the server's representation of the Event, and an error, if there is any.