types

Documentation

Index

• type Config
• type EnvConfig
• type Event
• type EventErrorType
• type EventID
• type EventType
• type Provider
  • func (p Provider) String() string
• type QueryOp
• type StanConfig

Types

type Config

type Config struct {
	Sink StanConfig            `yaml:"event_sink"`
	Srcs map[string]StanConfig `yaml:"event_srcs"`
}

Config is config read from file.

type EnvConfig

type EnvConfig struct {
	PodName    string `envconfig:"POD_NAME"`
	ConfigFile string `envconfig:"CONFIG_FILE" default:"config.yml"`
	LogLevel   string `envconfig:"LOG_LEVEL" default:"debug"`
}

EnvConfig is config from environment variables. Include config for NATS Streaming.

type Event

type Event interface {
	EventType() EventType
}

Event is a common interface for Events

type EventErrorType

type EventErrorType string

EventErrorType is the error type that appear in the failure/error event emitted

type EventID

type EventID string

EventID is the ID of events, this is used to track trasaction

type EventType

type EventType string

EventType is a type to represent event operations

type Provider

type Provider cacaosvc.AWMProvider

Provider is the ID of cloud provider

func (Provider) String

func (p Provider) String() string

type QueryOp

type QueryOp string

QueryOp is a type to represent query operations

type StanConfig

type StanConfig struct {
	URL        string `yaml:"url"`
	QueueGroup string `yaml:"queue"`
	Subject    string `yaml:"subject"`
	ClusterID  string `yaml:"cluster_id"`
}

StanConfig is config for NATS Streaming