util

Documentation

Index

• Constants
• Variables
• func AddHighResolutionTag(tags interface{})
• func Cleanup(input interface{})
• func GetMetadataInfo(provider MetadataInfoProvider) map[string]string
• func ResolvePlaceholder(placeholder string, metadata map[string]string) string
• type Creds
  • func GetCredsRule(returnTargetKey string) *Creds
  • func (c *Creds) ApplyRule(input interface{}) (returnKey string, returnVal interface{})
• type Metadata
• type MetadataInfoProvider
• type Region
  • func GetRegionRule(returnTargetKey string) *Region
  • func (r *Region) ApplyRule(input interface{}) (returnKey string, returnVal interface{})

Constants

const (
	High_Resolution_Tag_Key      = "aws:StorageResolution"
	Aggregation_Interval_Tag_Key = "aws:AggregationInterval"
)

Variables

var Ec2MetadataInfoProvider = func() *Metadata {
	ec2 := ec2util.GetEC2UtilSingleton()
	return &Metadata{
		InstanceID: ec2.InstanceID,
		Hostname:   ec2.Hostname,
		PrivateIP:  ec2.PrivateIP,
		AccountID:  ec2.AccountID,
	}
}

var Reserved_Tag_Keys = []string{High_Resolution_Tag_Key, Aggregation_Interval_Tag_Key}

Functions

func AddHighResolutionTag

func AddHighResolutionTag(tags interface{})

func Cleanup

func Cleanup(input interface{})

Filter out reserved tag keys

func GetMetadataInfo

func GetMetadataInfo(provider MetadataInfoProvider) map[string]string

func ResolvePlaceholder

func ResolvePlaceholder(placeholder string, metadata map[string]string) string

resolve place holder for log group and log stream.

Types

type Creds

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

func GetCredsRule

func GetCredsRule(returnTargetKey string) *Creds

func (*Creds) ApplyRule

func (c *Creds) ApplyRule(input interface{}) (returnKey string, returnVal interface{})

Grant the global creds(if exist)

type Metadata

type Metadata struct {
	InstanceID string
	Hostname   string
	PrivateIP  string
	AccountID  string
}

type MetadataInfoProvider

type MetadataInfoProvider func() *Metadata

type Region

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

func GetRegionRule

func GetRegionRule(returnTargetKey string) *Region

func (*Region) ApplyRule

func (r *Region) ApplyRule(input interface{}) (returnKey string, returnVal interface{})

Grant the global creds(if exist)