Documentation
¶
Index ¶
- Constants
- type FilterStore
- func (s *FilterStore) AddEventToFilterOutput(ctx context.Context, filterOutputID string, event *models.Event) error
- func (s *FilterStore) AddFilter(ctx context.Context, filter *models.Filter) (*models.Filter, error)
- func (s *FilterStore) AddFilterDimension(ctx context.Context, filterID, name string, options []string, ...) (string, error)
- func (s *FilterStore) AddFilterDimensionOption(ctx context.Context, filterID, name, option string, ...) (string, error)
- func (s *FilterStore) AddFilterDimensionOptions(ctx context.Context, filterID, name string, options []string, ...) (string, error)
- func (s *FilterStore) Checker(ctx context.Context, state *healthcheck.CheckState) error
- func (s *FilterStore) Close(ctx context.Context) error
- func (s *FilterStore) CreateFilterOutput(ctx context.Context, filter *models.Filter) error
- func (s *FilterStore) GetFilter(ctx context.Context, filterID, eTagSelector string) (*models.Filter, error)
- func (s *FilterStore) GetFilterDimension(ctx context.Context, filterID string, name, eTagSelector string) (*models.Dimension, error)
- func (s *FilterStore) GetFilterOutput(ctx context.Context, filterID string) (*models.Filter, error)
- func (s *FilterStore) RemoveFilterDimension(ctx context.Context, filterID, name string, timestamp primitive.Timestamp, ...) (string, error)
- func (s *FilterStore) RemoveFilterDimensionOption(ctx context.Context, filterID string, name string, option string, ...) (string, error)
- func (s *FilterStore) RemoveFilterDimensionOptions(ctx context.Context, filterID string, name string, options []string, ...) (string, error)
- func (s *FilterStore) RunTransaction(ctx context.Context, retry bool, fn mongodriver.TransactionFunc) (interface{}, error)
- func (s *FilterStore) UpdateFilter(ctx context.Context, updatedFilter *models.Filter, ...) (string, error)
- func (s *FilterStore) UpdateFilterOutput(ctx context.Context, filter *models.Filter, timestamp primitive.Timestamp) error
Constants ¶
View Source
const AnyETag = "*"
AnyETag represents the wildchar that corresponds to not check the ETag value for update requests
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FilterStore ¶
type FilterStore struct {
mongodriver.MongoDriverConfig
Connection *mongodriver.MongoConnection
URI string
// contains filtered or unexported fields
}
FilterStore containing all filter jobs stored in mongodb
func CreateFilterStore ¶
func CreateFilterStore(cfg config.MongoConfig, host string) (*FilterStore, error)
CreateFilterStore which can store, update and fetch filter jobs
func (*FilterStore) AddEventToFilterOutput ¶
func (s *FilterStore) AddEventToFilterOutput(ctx context.Context, filterOutputID string, event *models.Event) error
AddEventToFilterOutput adds the given event to the filter output of the given ID
func (*FilterStore) AddFilterDimension ¶
func (s *FilterStore) AddFilterDimension(ctx context.Context, filterID, name string, options []string, dimensions []models.Dimension, timestamp primitive.Timestamp, eTagSelector string, currentFilter *models.Filter) (string, error)
AddFilterDimension to a filter
func (*FilterStore) AddFilterDimensionOption ¶
func (s *FilterStore) AddFilterDimensionOption(ctx context.Context, filterID, name, option string, timestamp primitive.Timestamp, eTagSelector string, currentFilter *models.Filter) (string, error)
AddFilterDimensionOption to a filter.
func (*FilterStore) AddFilterDimensionOptions ¶
func (s *FilterStore) AddFilterDimensionOptions(ctx context.Context, filterID, name string, options []string, timestamp primitive.Timestamp, eTagSelector string, currentFilter *models.Filter) (string, error)
AddFilterDimensionOptions adds the provided options to a filter. The number of successfully added options is returned, along with an error.
func (*FilterStore) Checker ¶
func (s *FilterStore) Checker(ctx context.Context, state *healthcheck.CheckState) error
Checker calls the mongoDB healthcheck client Checker
func (*FilterStore) Close ¶
func (s *FilterStore) Close(ctx context.Context) error
Close closes the mongoDB session
func (*FilterStore) CreateFilterOutput ¶
CreateFilterOutput creates a filter output resource
func (*FilterStore) GetFilter ¶
func (s *FilterStore) GetFilter(ctx context.Context, filterID, eTagSelector string) (*models.Filter, error)
GetFilter returns a single filter, if not found return an error. An optional eTag can be provided to assure that a filter has not been modified since the hash was generated
func (*FilterStore) GetFilterDimension ¶
func (s *FilterStore) GetFilterDimension(ctx context.Context, filterID string, name, eTagSelector string) (*models.Dimension, error)
GetFilterDimension return a single dimension, along with the filter eTag hash
func (*FilterStore) GetFilterOutput ¶
GetFilterOutput returns a filter output resource
func (*FilterStore) RemoveFilterDimension ¶
func (s *FilterStore) RemoveFilterDimension(ctx context.Context, filterID, name string, timestamp primitive.Timestamp, eTagSelector string, currentFilter *models.Filter) (string, error)
RemoveFilterDimension from a filter
func (*FilterStore) RemoveFilterDimensionOption ¶
func (s *FilterStore) RemoveFilterDimensionOption(ctx context.Context, filterID string, name string, option string, timestamp primitive.Timestamp, eTagSelector string, currentFilter *models.Filter) (string, error)
RemoveFilterDimensionOption from a filter
func (*FilterStore) RemoveFilterDimensionOptions ¶
func (s *FilterStore) RemoveFilterDimensionOptions(ctx context.Context, filterID string, name string, options []string, timestamp primitive.Timestamp, eTagSelector string, currentFilter *models.Filter) (string, error)
RemoveFilterDimensionOptions removes the provided options from a filter. If an error happens, it is returned.
func (*FilterStore) RunTransaction ¶
func (s *FilterStore) RunTransaction(ctx context.Context, retry bool, fn mongodriver.TransactionFunc) (interface{}, error)
func (*FilterStore) UpdateFilter ¶
func (s *FilterStore) UpdateFilter(ctx context.Context, updatedFilter *models.Filter, timestamp primitive.Timestamp, eTagSelector string, currentFilter *models.Filter) (string, error)
UpdateFilter replaces the stored filter properties.
func (*FilterStore) UpdateFilterOutput ¶
func (s *FilterStore) UpdateFilterOutput(ctx context.Context, filter *models.Filter, timestamp primitive.Timestamp) error
UpdateFilterOutput updates a filter output resource
Source Files
Click to show internal directories.
Click to hide internal directories.