awscache

Documentation

Index

• Variables
• type Cache
  • func New(ctx context.Context, secrets v1.SecretList, ...) (*Cache, error)
  • func (c *Cache) FilterEndpointsForUpstream(upstream *glooec2.UpstreamSpecRef) ([]*ec2.Instance, error)
• type CredentialInstanceGroup
  • func NewCredentialInstanceGroup() *CredentialInstanceGroup

Variables

var (
	ListCredentialError = func(err error) error {
		return errors.Wrapf(err, "unable to list credentials")
	}

	TimeoutError = errors.New("timed out while waiting for response from aws")

	ResourceMapInitializationError = errors.New("credential resource map not initialized correctly")
)

Types

type Cache

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

a credential batch stores the credentialMap available to a given credential spec it is possible that there will be duplicate resource records, for example, if two credentials have access to the same resource, then that resource will be present in both CredentialInstanceGroup entries. For simplicity, we will let that be.

func New

func New(ctx context.Context, secrets v1.SecretList, upstreams map[core.ResourceRef]*glooec2.UpstreamSpecRef, ec2InstanceLister awslister.Ec2InstanceLister) (*Cache, error)

func (*Cache) FilterEndpointsForUpstream

func (c *Cache) FilterEndpointsForUpstream(upstream *glooec2.UpstreamSpecRef) ([]*ec2.Instance, error)

type CredentialInstanceGroup

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

CredentialInstanceGroup represents the instances available to a given credentialSpec

func NewCredentialInstanceGroup

func NewCredentialInstanceGroup() *CredentialInstanceGroup