Documentation
¶
Index ¶
- func ClientResourceOptions(options ...func(*Resource)) func(*Client)
- func ResourcePartitionLimit(limit int) func(*Resource)
- type Client
- type Document
- type Resource
- func (r *Resource) Create(_ context.Context, res *flare.Resource) error
- func (r *Resource) Delete(ctx 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, uri url.URL) (*flare.Resource, error)
- func (r *Resource) Partitions(ctx context.Context, id string) ([]string, 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, resourceID string) ([]flare.Subscription, *flare.Pagination, error)
- func (s *Subscription) FindByID(ctx 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) HasSubscription(_ context.Context, resourceId string) (bool, error)
- func (s *Subscription) Trigger(ctx context.Context, action string, rawDocument *flare.Document, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ClientResourceOptions ¶
ClientResourceOptions set the options to initialize the resource repository.
func ResourcePartitionLimit ¶
ResourcePartitionLimit set the max quantity of subscriptions per partition.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client 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.
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, resourceID string, ) ([]flare.Subscription, *flare.Pagination, error)
Find returns a list of subscriptions.
func (*Subscription) FindByID ¶
func (s *Subscription) FindByID( ctx 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) HasSubscription ¶
HasSubscription check if a resource has subscriptions.
Source Files