s3

Documentation

Index

• Variables
• type Arguments
  • func (a *Arguments) SetToDefault()
  • func (a *Arguments) Validate() error
• type Client
• type Component
  • func New(o component.Options, args Arguments) (*Component, error)
  • func (s *Component) CurrentHealth() component.Health
  • func (s *Component) Run(ctx context.Context) error
  • func (s *Component) Update(args component.Arguments) error
• type Exports

Variables

var DefaultArguments = Arguments{
	PollFrequency: 10 * time.Minute,
}

DefaultArguments sets the poll frequency

Types

type Arguments

type Arguments struct {
	Path string `river:"path,attr"`
	// PollFrequency determines the frequency to check for changes
	// defaults to 10m.
	PollFrequency time.Duration `river:"poll_frequency,attr,optional"`
	// IsSecret determines if the content should be displayed to the user.
	IsSecret bool `river:"is_secret,attr,optional"`
	// Options allows the overriding of default settings.
	Options Client `river:"client,block,optional"`
}

Arguments implements the input for the S3 component.

func (*Arguments) SetToDefault

func (a *Arguments) SetToDefault()

SetToDefault implements river.Defaulter.

func (*Arguments) Validate

func (a *Arguments) Validate() error

Validate implements river.Validator.

type Client

type Client struct {
	AccessKey     string            `river:"key,attr,optional"`
	Secret        rivertypes.Secret `river:"secret,attr,optional"`
	Endpoint      string            `river:"endpoint,attr,optional"`
	DisableSSL    bool              `river:"disable_ssl,attr,optional"`
	UsePathStyle  bool              `river:"use_path_style,attr,optional"`
	Region        string            `river:"region,attr,optional"`
	SigningRegion string            `river:"signing_region,attr,optional"`
}

Client implements specific AWS configuration options

type Component

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

Component handles reading content from a file located in an Component-compatible system.

func New

func New(o component.Options, args Arguments) (*Component, error)

New initializes the S3 component.

func (*Component) CurrentHealth

func (s *Component) CurrentHealth() component.Health

CurrentHealth returns the health of the component.

func (*Component) Run

func (s *Component) Run(ctx context.Context) error

Run activates the content handler and watcher.

func (*Component) Update

func (s *Component) Update(args component.Arguments) error

Update is called whenever the arguments have changed.

type Exports

type Exports struct {
	Content rivertypes.OptionalSecret `river:"content,attr"`
}

Exports implements the file content