redis

package
v0.29.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 21, 2023 License: MPL-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SinkerPrefix = "sinker."
	SinkerUpdate = SinkerPrefix + "update"
	GroupMaestro = "orb.maestro"
	Exists       = "BUSYGROUP Consumer Group name already exists"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type DeploymentEvent 

type DeploymentEvent struct {
	SinkID         string
	DeploymentYaml string
}

type SinkerUpdateEvent 

type SinkerUpdateEvent struct {
	OwnerID   string
	SinkID    string
	State     string
	Size      string
	Timestamp time.Time
}

func (*SinkerUpdateEvent) Decode added in v0.29.0 

func (cse *SinkerUpdateEvent) Decode(values map[string]interface{})

func (*SinkerUpdateEvent) Encode 

func (cse *SinkerUpdateEvent) Encode() map[string]interface{}

type SinksUpdateEvent 

type SinksUpdateEvent struct {
	SinkID    string
	Owner     string
	Config    types.Metadata
	Backend   string
	Timestamp time.Time
}

func (*SinksUpdateEvent) Decode added in v0.29.0 

func (sue *SinksUpdateEvent) Decode(values map[string]interface{})

Source Files

View all Source files

Directories

Path Synopsis
Package esconsumer contains events esconsumer for events
 Package esconsumer contains events esconsumer for events

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.