Versions in this module Expand all Collapse all v1 v1.0.0 Apr 9, 2019 Changes in this version + func GetCache() *redis.Client + func GetCelery() (*gocelery.RedisCeleryBroker, *gocelery.RedisCeleryBackend) + func GetDB() *gorm.DB + func GetElasticsearch() *elastic.Client + func Migrate() + func NewPattern(prefix, suffix string) (pattern string) + func SetCache() + func SetCelery() + func SetDB() + func SetElasticsearch() + type Config struct + Bucket string + Queues []Queue + Topics []Topic + XMLName xml.Name + func (conf *Config) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error + func (conf Config) ToRulesMap() RulesMap + type Endpoint struct + Name string + Protocol string + ResourceID uint + URI string + func ParseSubscription(s string) (*Endpoint, error) + type Event struct + Name event.Name + QueueID uint + TopicID uint + func (e *Event) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error + func (event *Event) MarshalXML(e *xml.Encoder, start xml.StartElement) error + type FilterRule struct + FilterRuleListID uint + Name string + Value string + func (filter *FilterRule) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error + type FilterRuleList struct + Rules []FilterRule + S3KeyID uint + func (ruleList *FilterRuleList) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error + func (ruleList FilterRuleList) Pattern() string + type Model struct + CreatedAt time.Time + DeletedAt *time.Time + ID uint + UpdatedAt time.Time + type Queue struct + ARN string + ConfigID uint + Events []Event + Filter S3Key + QueueIdentifier string + Resource Resource + ResourceID uint + func (q *Queue) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error + func (q Queue) ToRulesMap() RulesMap + type Resource struct + AccountID string + Endpoints []Endpoint + Name string + Queues []Queue + Service Service + Topics []Topic + Type string + func ParseARN(s string) (*Resource, error) + func (r Resource) ARN() string + func (r Resource) URL() string + type Rules map[string][]Resource + func (rules Rules) Clone() Rules + func (rules Rules) Match(objectName string) []Resource + func (rules Rules) Union(rules2 Rules) Rules + type RulesMap map[event.Name]Rules + func NewRulesMap(eventNames []event.Name, pattern string, resource Resource) RulesMap + func (rulesMap RulesMap) Add(rulesMap2 RulesMap) + type S3Key struct + QueueID uint + RuleList FilterRuleList + TopicID uint + type Service int + const SNS + const SQS + func ParseService(s string) Service + func (s *Service) Scan(src interface{}) error + func (s Service) String() string + func (s Service) Value() (driver.Value, error) + type Topic struct + ARN string + ConfigID uint + Events []Event + Filter S3Key + Resource Resource + ResourceID uint + TopicIdentifier string + func (t Topic) ToRulesMap() RulesMap