repo

Documentation

Index

• Constants
• Variables
• func CompareRules(old *rules.Rule, new *rules.Rule) []string
• func FmtSubjectKey(id string, fmtSubject string) (string, error)
• func RedisFmtKey(id string, prefix string) (string, error)
• type RuleRepo
  • func NewDiskRuleRepo(root string) RuleRepo
  • func NewInMemoryRuleRepo() RuleRepo
  • func NewJetstreamRuleRepo(natsURL string) (RuleRepo, error)
  • func NewPostgresRuleRepo(connectionString string) (RuleRepo, error)
  • func NewRedisRuleRepo(redisStoreURL string) (RuleRepo, error)

Constants

const (
	STREAM_NAME  = "rules"
	RULE_SUBJECT = "rule.>"
)

const (
	RULE_PREFIX = "rules" // => rules:id {..}
)

Variables

var STREAM_SUBJECTS = []string{
	RULE_SUBJECT,
}

Functions

func CompareRules

func CompareRules(old *rules.Rule, new *rules.Rule) []string

func FmtSubjectKey

func FmtSubjectKey(id string, fmtSubject string) (string, error)

func RedisFmtKey

func RedisFmtKey(id string, prefix string) (string, error)

Types

type RuleRepo

type RuleRepo interface {
	Name() string
	Get(id string) (*rules.Rule, error)
	Save(rule *rules.Rule) error
	Expire(id string, ttl int64) error
	Remove(id string) error
	RemoveAll() error
	Each(skip int, limit int, fn func(rule *rules.Rule)) error
	Count() int
	Active() int
	Close()
}

func NewDiskRuleRepo

func NewDiskRuleRepo(root string) RuleRepo

func NewInMemoryRuleRepo

func NewInMemoryRuleRepo() RuleRepo

func NewJetstreamRuleRepo

func NewJetstreamRuleRepo(natsURL string) (RuleRepo, error)

func NewPostgresRuleRepo

func NewPostgresRuleRepo(connectionString string) (RuleRepo, error)

func NewRedisRuleRepo

func NewRedisRuleRepo(redisStoreURL string) (RuleRepo, error)