repository

Documentation

Index

• func ClientConnection(base *mongodb.Client) func(*Client)
• func ClientResourceOptions(options ...func(*Resource)) func(*Client)
• func ResourcePartitionLimit(partition int) func(*Resource)
• type Client
  • func NewClient(options ...func(*Client)) (*Client, error)
  • func (c *Client) Document() flare.DocumentRepositorier
  • func (c *Client) Resource() flare.ResourceRepositorier
  • func (c *Client) Setup(_ context.Context) error
  • func (c *Client) Stop() error
  • func (c *Client) Subscription() flare.SubscriptionRepositorier
• type Document
  • func (d *Document) Delete(_ context.Context, id url.URL) error
  • func (d *Document) FindByID(ctx context.Context, id url.URL) (*flare.Document, error)
  • func (d *Document) Update(_ context.Context, document *flare.Document) error
• type Resource
  • func (r *Resource) Create(_ context.Context, res *flare.Resource) error
  • func (r *Resource) Delete(_ context.Context, id string) error
  • func (r *Resource) Find(_ context.Context, pagination *flare.Pagination) ([]flare.Resource, *flare.Pagination, error)
  • func (r *Resource) FindByID(ctx context.Context, id string) (*flare.Resource, error)
  • func (r *Resource) FindByURI(_ context.Context, address url.URL) (*flare.Resource, error)
  • func (r *Resource) Partitions(ctx context.Context, id string) ([]string, error)
  • func (r *Resource) SetSubscriptionRepository(repo flare.SubscriptionRepositorier) error
• type Subscription
  • func (s *Subscription) Create(ctx context.Context, subscription *flare.Subscription) error
  • func (s *Subscription) Delete(ctx context.Context, resourceId, id string) error
  • func (s *Subscription) Find(_ context.Context, pagination *flare.Pagination, id string) ([]flare.Subscription, *flare.Pagination, error)
  • func (s *Subscription) FindByID(_ context.Context, resourceId, id string) (*flare.Subscription, error)
  • func (s *Subscription) FindByPartition(_ context.Context, resourceID, partition string) (<-chan flare.Subscription, <-chan error, error)
  • func (s *Subscription) Trigger(ctx context.Context, kind string, doc *flare.Document, sub *flare.Subscription, ...) error

Functions

func ClientConnection

func ClientConnection(base *mongodb.Client) func(*Client)

ClientConnection set the MongoDB client.

func ClientResourceOptions

func ClientResourceOptions(options ...func(*Resource)) func(*Client)

ClientResourceOptions set the resource options.

func ResourcePartitionLimit

func ResourcePartitionLimit(partition int) func(*Resource)

ResourcePartitionLimit set the max quantity of entries per partition.

Types

type Client

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

Client that implements the repository interface.

func NewClient

func NewClient(options ...func(*Client)) (*Client, error)

NewClient return a configured client to access the repositories.

func (*Client) Document

func (c *Client) Document() flare.DocumentRepositorier

Document return a document repository.

func (*Client) Resource

func (c *Client) Resource() flare.ResourceRepositorier

Resource return a resource repository.

func (*Client) Setup

func (c *Client) Setup(_ context.Context) error

Setup initialize the repository.

func (*Client) Stop

func (c *Client) Stop() error

Stop the repository.

func (*Client) Subscription

func (c *Client) Subscription() flare.SubscriptionRepositorier

Subscription return a subscription repository.

type Document

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

Document implements the data layer for the document service.

func (*Document) Delete

func (d *Document) Delete(_ context.Context, id url.URL) error

Delete a given document.

func (*Document) FindByID

func (d *Document) FindByID(ctx context.Context, id url.URL) (*flare.Document, error)

FindByID return the document that match the id.

func (*Document) Update

func (d *Document) Update(_ context.Context, document *flare.Document) error

Update a given document.

type Resource

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

Resource implements the data layer for the resource service.

func (*Resource) Create

func (r *Resource) Create(_ context.Context, res *flare.Resource) error

Create a resource.

func (*Resource) Delete

func (r *Resource) Delete(_ context.Context, id string) error

Delete a given resource.

func (*Resource) Find

func (r *Resource) Find(
	_ context.Context, pagination *flare.Pagination,
) ([]flare.Resource, *flare.Pagination, error)

Find returns a list of resources.

func (*Resource) FindByID

func (r *Resource) FindByID(ctx context.Context, id string) (*flare.Resource, error)

FindByID return the resource that match the id.

func (*Resource) FindByURI

func (r *Resource) FindByURI(_ context.Context, address url.URL) (*flare.Resource, error)

FindByURI take a URI and find the resource that match.

func (*Resource) Partitions

func (r *Resource) Partitions(ctx context.Context, id string) ([]string, error)

Partitions return the list of partitions of a resource.

func (*Resource) SetSubscriptionRepository

func (r *Resource) SetSubscriptionRepository(repo flare.SubscriptionRepositorier) error

SetSubscriptionRepository set the subscription repository.

type Subscription

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

Subscription implements the data layer for the subscription service.

func (*Subscription) Create

func (s *Subscription) Create(ctx context.Context, subscription *flare.Subscription) error

Create a subscription.

func (*Subscription) Delete

func (s *Subscription) Delete(ctx context.Context, resourceId, id string) error

Delete a given subscription.

func (*Subscription) Find

func (s *Subscription) Find(
	_ context.Context, pagination *flare.Pagination, id string,
) ([]flare.Subscription, *flare.Pagination, error)

Find returns a list of subscriptions.

func (*Subscription) FindByID

func (s *Subscription) FindByID(
	_ context.Context, resourceId, id string,
) (*flare.Subscription, error)

FindByID return the Subscription that match the id.

func (*Subscription) FindByPartition

func (s *Subscription) FindByPartition(
	_ context.Context, resourceID, partition string,
) (<-chan flare.Subscription, <-chan error, error)

FindByPartition find all subscriptions that belongs to a given partition.

func (*Subscription) Trigger

func (s *Subscription) Trigger(
	ctx context.Context,
	kind string,
	doc *flare.Document,
	sub *flare.Subscription,
	fn func(context.Context, *flare.Document, *flare.Subscription, string) error,
) error

Trigger process the update on a document.