redis

Documentation

Index

• Constants
• func New(args *RedisArgs, logger *zap.SugaredLogger) backend.Interface
• type RedisArgs
  • func (ra *RedisArgs) Validate() error

Constants

const (
	BackendIDAttribute = "triggermeshbackendid"
)

Functions

func New

func New(args *RedisArgs, logger *zap.SugaredLogger) backend.Interface

Types

type RedisArgs

type RedisArgs struct {
	Address          string   `help:"Redis address." env:"ADDRESS" default:"0.0.0.0:6379"`
	ClusterAddresses []string `help:"Redis address." env:"CLUSTER_ADDRESSES"`

	Username         string `help:"Redis username." env:"USERNAME"`
	Password         string `help:"Redis password." env:"PASSWORD"`
	Database         int    `help:"Database ordinal at Redis." env:"DATABASE" default:"0"`
	TLSEnabled       bool   `help:"TLS enablement for Redis connection." env:"TLS_ENABLED" default:"false"`
	TLSSkipVerify    bool   `help:"TLS skipping certificate verification." env:"TLS_SKIP_VERIFY" default:"false"`
	TLSCertificate   string `help:"TLS Certificate to connect to Redis." env:"TLS_CERTIFICATE"`
	TLSKey           string `help:"TLS Certificate key to connect to Redis." env:"TLS_KEY"`
	TLSCACertificate string `help:"CA Certificate to connect to Redis." name:"tls-ca-certificate" env:"TLS_CA_CERTIFICATE"`

	Stream string `help:"Stream name that stores the broker's CloudEvents." env:"STREAM" default:"triggermesh"`
	Group  string `help:"Redis stream consumer group name." env:"GROUP" default:"default"`
	// Instance at the Redis stream consumer group. Copied from the InstanceName at the global args.
	Instance string `kong:"-"`

	StreamMaxLen      int  `help:"Limit the number of items in a stream by trimming it. Set to 0 for unlimited." env:"STREAM_MAX_LEN" default:"1000"`
	TrackingIDEnabled bool `help:"Enables adding Redis ID as a CloudEvent attribute." env:"TRACKING_ID_ENABLED" default:"false"`
}

func (*RedisArgs) Validate

func (ra *RedisArgs) Validate() error