redis

Documentation

Index

• Constants
• type Method
  • func (m *Method) NotifyComponentVersion(version common.NameVersion) error
• type Spec
  • func New(serverurl, channel string, db int) (*Spec, error)
  • func (s *Spec) Describe(_ cpi.Context) string
  • func (s *Spec) PubSubMethod(repo cpi.Repository) (pubsub.PubSubMethod, error)

Constants

const (
	Type   = "redis"
	TypeV1 = Type + runtime.VersionSeparator + "v1"
)

Types

type Method

type Method struct {
	// contains filtered or unexported fields
}

Method finally publishes events.

func (*Method) NotifyComponentVersion

func (m *Method) NotifyComponentVersion(version common.NameVersion) error

type Spec

type Spec struct {
	runtime.ObjectVersionedType
	ServerAddr string `json:"serverAddr"`
	Channel    string `json:"channel"`
	Database   int    `json:"database"`
}

Spec provides a pub sub adapter registering events at its provider.

func New

func New(serverurl, channel string, db int) (*Spec, error)

func (*Spec) Describe

func (s *Spec) Describe(_ cpi.Context) string

func (*Spec) PubSubMethod

func (s *Spec) PubSubMethod(repo cpi.Repository) (pubsub.PubSubMethod, error)