state

Documentation

Index

• type InputMySQL
  • func (s InputMySQL) DebugString() string
• type InputPostgres
  • func (s InputPostgres) DebugString() string
• type InputTopic
  • func (s InputTopic) DebugString() string
• type OutputMySQL
  • func (s OutputMySQL) DebugString() string
• type OutputPostgres
  • func (s OutputPostgres) DebugString() string
• type OutputSubscription
  • func (s OutputSubscription) DebugString() string
• type OutputTopic
  • func (s OutputTopic) DebugString() string
• type RDSInstanceReadyMySQL
  • func (s RDSInstanceReadyMySQL) DebugString() string
• type RDSInstanceReadyPostgres
  • func (s RDSInstanceReadyPostgres) DebugString() string
• type State
• type TopicClusterReady
  • func (s TopicClusterReady) DebugString() string

Types

type InputMySQL

type InputMySQL struct {
	ResourceID string
	Cluster    string
	Module     string
}

func (InputMySQL) DebugString

func (s InputMySQL) DebugString() string

type InputPostgres

type InputPostgres struct {
	ResourceID string
	Cluster    string
	Module     string
}

func (InputPostgres) DebugString

func (s InputPostgres) DebugString() string

type InputTopic

type InputTopic struct {
	Topic      string
	Module     string
	Partitions int
}

func (InputTopic) DebugString

func (s InputTopic) DebugString() string

type OutputMySQL

type OutputMySQL struct {
	Module     string
	ResourceID string

	Connector schema.DatabaseConnector
}

func (OutputMySQL) DebugString

func (s OutputMySQL) DebugString() string

type OutputPostgres

type OutputPostgres struct {
	Module     string
	ResourceID string

	Connector schema.DatabaseConnector
}

func (OutputPostgres) DebugString

func (s OutputPostgres) DebugString() string

type OutputSubscription

type OutputSubscription struct {
	Module string
	Verb   string

	Connector schema.SubscriptionConnector
}

func (OutputSubscription) DebugString

func (s OutputSubscription) DebugString() string

type OutputTopic

type OutputTopic struct {
	Module string
	Topic  string

	Runtime *schema.TopicRuntime
}

func (OutputTopic) DebugString

func (s OutputTopic) DebugString() string

type RDSInstanceReadyMySQL

type RDSInstanceReadyMySQL struct {
	Module     string
	ResourceID string

	MasterUserSecretARN string
	WriteEndpoint       string
	ReadEndpoint        string
}

func (RDSInstanceReadyMySQL) DebugString

func (s RDSInstanceReadyMySQL) DebugString() string

type RDSInstanceReadyPostgres

type RDSInstanceReadyPostgres struct {
	Module     string
	ResourceID string

	MasterUserSecretARN string
	WriteEndpoint       string
	ReadEndpoint        string
}

func (RDSInstanceReadyPostgres) DebugString

func (s RDSInstanceReadyPostgres) DebugString() string

type State

type State interface {
	DebugString() string
}

State of a single resource in execution.

type TopicClusterReady

type TopicClusterReady struct {
	InputTopic

	Brokers []string
}

func (TopicClusterReady) DebugString

func (s TopicClusterReady) DebugString() string