Documentation ¶
Index ¶
- func ClientConnection(base *mongodb.Client) func(*Client)
- func ClientResourceOptions(options ...func(*Resource)) func(*Client)
- func ResourcePartitionLimit(partition int) func(*Resource)
- type Client
- type Document
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ClientConnection ¶
ClientConnection set the MongoDB client.
func ClientResourceOptions ¶
ClientResourceOptions set the resource options.
func ResourcePartitionLimit ¶
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 (*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) 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.
type Resource ¶
type Resource struct {
// contains filtered or unexported fields
}
Resource implements the data layer for the resource service.
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) Partitions ¶
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.