security_groups

Documentation

Index

• func NewProvider(req *pb.CreateRequest) providers.Provider
• func NewProviderFromConfig(cfg *Config) (providers.Provider, error)
• type Config
  • func DefaultConfig() *Config
  • func MergeDefaultConfig(cfg *Config) *Config
• type SecurityGroupBuilder
  • func NewSecurityGroupBuilder(cfg Config) (*SecurityGroupBuilder, error)
  • func (b *SecurityGroupBuilder) AuthorizeSecurityGroupIngress(input *ec2.AuthorizeSecurityGroupIngressInput) error
  • func (b *SecurityGroupBuilder) CreateBitcoinP2PSecurityGroup() (string, error)
  • func (b *SecurityGroupBuilder) CreateBitcoinP2PSecurityGroupInput(bitcoinP2PSecurityGroupId string) *ec2.AuthorizeSecurityGroupIngressInput
  • func (b *SecurityGroupBuilder) CreateSecurityGroups() error
  • func (b *SecurityGroupBuilder) CreateSshSecurityGroup() string
  • func (b *SecurityGroupBuilder) CreateSshSecurityGroupInput(sshSecurityGroupId string) *ec2.AuthorizeSecurityGroupIngressInput
  • func (b *SecurityGroupBuilder) CreateSubscriberSecurityGroup() (string, error)
  • func (b *SecurityGroupBuilder) CreateZmqBroadcasterSecurityGroup() (string, error)
  • func (b *SecurityGroupBuilder) ListenerSelfSecurityGroupInput(subscriberSecurityGroupId string) *ec2.AuthorizeSecurityGroupIngressInput
• type SecurityGroupsProvider
  • func (p *SecurityGroupsProvider) Annotate(id string, l labels.Labels) error
  • func (p *SecurityGroupsProvider) Apply() error
  • func (p *SecurityGroupsProvider) AwaitReadiness() chan error
  • func (p *SecurityGroupsProvider) Cancel() error
  • func (p *SecurityGroupsProvider) Clone() error
  • func (p *SecurityGroupsProvider) ProbeReadiness() (bool, error)
  • func (p *SecurityGroupsProvider) Read() error
  • func (p *SecurityGroupsProvider) Select() (target.Selection, error)
  • func (p *SecurityGroupsProvider) Stop() error
  • func (p *SecurityGroupsProvider) Teardown() error

Functions

func NewProvider

func NewProvider(req *pb.CreateRequest) providers.Provider

NewProvider initializes a SecurityGroupsProvider with defaults

func NewProviderFromConfig

func NewProviderFromConfig(cfg *Config) (providers.Provider, error)

Types

type Config

type Config struct {
	VpcId  string
	DryRun bool
	All    bool
	Kind   string
	Tags   []labels.Label // optionally define some extra tags
}

func DefaultConfig

func DefaultConfig() *Config

func MergeDefaultConfig

func MergeDefaultConfig(cfg *Config) *Config

type SecurityGroupBuilder

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

func NewSecurityGroupBuilder

func NewSecurityGroupBuilder(cfg Config) (*SecurityGroupBuilder, error)

func (*SecurityGroupBuilder) AuthorizeSecurityGroupIngress

func (b *SecurityGroupBuilder) AuthorizeSecurityGroupIngress(input *ec2.AuthorizeSecurityGroupIngressInput) error

func (*SecurityGroupBuilder) CreateBitcoinP2PSecurityGroup

func (b *SecurityGroupBuilder) CreateBitcoinP2PSecurityGroup() (string, error)

func (*SecurityGroupBuilder) CreateBitcoinP2PSecurityGroupInput

func (b *SecurityGroupBuilder) CreateBitcoinP2PSecurityGroupInput(bitcoinP2PSecurityGroupId string) *ec2.AuthorizeSecurityGroupIngressInput

func (*SecurityGroupBuilder) CreateSecurityGroups

func (b *SecurityGroupBuilder) CreateSecurityGroups() error

func (*SecurityGroupBuilder) CreateSshSecurityGroup

func (b *SecurityGroupBuilder) CreateSshSecurityGroup() string

func (*SecurityGroupBuilder) CreateSshSecurityGroupInput

func (b *SecurityGroupBuilder) CreateSshSecurityGroupInput(sshSecurityGroupId string) *ec2.AuthorizeSecurityGroupIngressInput

func (*SecurityGroupBuilder) CreateSubscriberSecurityGroup

func (b *SecurityGroupBuilder) CreateSubscriberSecurityGroup() (string, error)

func (*SecurityGroupBuilder) CreateZmqBroadcasterSecurityGroup

func (b *SecurityGroupBuilder) CreateZmqBroadcasterSecurityGroup() (string, error)

func (*SecurityGroupBuilder) ListenerSelfSecurityGroupInput

func (b *SecurityGroupBuilder) ListenerSelfSecurityGroupInput(subscriberSecurityGroupId string) *ec2.AuthorizeSecurityGroupIngressInput

type SecurityGroupsProvider

type SecurityGroupsProvider struct {
	// Config holds our internal configuration options
	// for the instance of the SecurityGroupsProvider
	Config *Config

	SGs []interface{}
}

SecurityGroupsProvider implements a SecurityGroupsProvider

func (*SecurityGroupsProvider) Annotate

func (p *SecurityGroupsProvider) Annotate(id string, l labels.Labels) error

Annotate should implement applying labels or tags for a given resource type

func (*SecurityGroupsProvider) Apply

func (p *SecurityGroupsProvider) Apply() error

func (*SecurityGroupsProvider) AwaitReadiness

func (p *SecurityGroupsProvider) AwaitReadiness() chan error

AwaitReadiness should be implemented to detect when a SecurityGroupsProvider has finished setting up a variant and can begin using it in an experiment

func (*SecurityGroupsProvider) Cancel

func (p *SecurityGroupsProvider) Cancel() error

Cancel will abort and running or submitted SecurityGroupsProvider

func (*SecurityGroupsProvider) Clone

func (p *SecurityGroupsProvider) Clone() error

Clone creates a modified variant

func (*SecurityGroupsProvider) ProbeReadiness

func (p *SecurityGroupsProvider) ProbeReadiness() (bool, error)

ProbeReadiness checks that the provisioned resource is available and ready to be included in a request

func (*SecurityGroupsProvider) Read

func (p *SecurityGroupsProvider) Read() error

Read fetches and stores the configuration for an existing SecurityGroups zone. What is read of the existing resource acts as the template/configuration to implement a clone via creating a new resource with the existing output as input for a variant

func (*SecurityGroupsProvider) Select

func (p *SecurityGroupsProvider) Select() (target.Selection, error)

func (*SecurityGroupsProvider) Stop

func (p *SecurityGroupsProvider) Stop() error

Stop will stop any running SecurityGroupsProvider

func (*SecurityGroupsProvider) Teardown

func (p *SecurityGroupsProvider) Teardown() error

Teardown eradicates any resource that has been provisioned as part of a variant