logs

Documentation

Index

• Constants
• Variables
• func GetCurPath() string
• func RegisterRule(fieldname string, r Rule)
• type BasicLogConfig
  • func (f *BasicLogConfig) ApplyRule(input interface{}) (returnKey string, returnVal interface{})
• type Concurrency
  • func (c *Concurrency) ApplyRule(input any) (string, any)
• type DeploymentEnvironment
  • func (f *DeploymentEnvironment) ApplyRule(input interface{}) (returnKey string, returnVal interface{})
• type EndpointOverride
  • func (r *EndpointOverride) ApplyRule(input interface{}) (returnKey string, returnVal interface{})
• type ForceFlushInterval
  • func (f *ForceFlushInterval) ApplyRule(input interface{}) (string, interface{})
• type LogCreds
  • func (c *LogCreds) ApplyRule(input interface{}) (returnKey string, returnVal interface{})
• type LogStreamName
  • func (l *LogStreamName) ApplyRule(input interface{}) (returnKey string, returnVal interface{})
• type Logs
  • func (l *Logs) ApplyRule(input interface{}) (returnKey string, returnVal interface{})
  • func (l *Logs) Merge(source map[string]interface{}, result map[string]interface{})
• type Rule
• type ServiceName
  • func (f *ServiceName) ApplyRule(input interface{}) (returnKey string, returnVal interface{})

Constants

const (
	SectionKey             = "logs"
	Output_Cloudwatch_Logs = "cloudwatchlogs"
)

const (
	Role_Arn_Key          = "role_arn"
	CredentialsSectionKey = "credentials"
)

const ConcurrencySectionKey = "concurrency"

Variables

var ChildRule = map[string]Rule{}

var (
	GlobalLogConfig = Logs{}
)

var MergeRuleMap = map[string]mergeJsonRule.MergeRule{}

Functions

func GetCurPath

func GetCurPath() string

func RegisterRule

func RegisterRule(fieldname string, r Rule)

Types

type BasicLogConfig

type BasicLogConfig struct {
}

func (*BasicLogConfig) ApplyRule

func (f *BasicLogConfig) ApplyRule(input interface{}) (returnKey string, returnVal interface{})

type Concurrency

type Concurrency struct {
}

func (*Concurrency) ApplyRule

func (c *Concurrency) ApplyRule(input any) (string, any)

type DeploymentEnvironment

type DeploymentEnvironment struct {
}

func (*DeploymentEnvironment) ApplyRule

func (f *DeploymentEnvironment) ApplyRule(input interface{}) (returnKey string, returnVal interface{})

type EndpointOverride

type EndpointOverride struct {
}

func (*EndpointOverride) ApplyRule

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

type ForceFlushInterval

type ForceFlushInterval struct {
}

func (*ForceFlushInterval) ApplyRule

func (f *ForceFlushInterval) ApplyRule(input interface{}) (string, interface{})

type LogCreds

type LogCreds struct {
}

func (*LogCreds) ApplyRule

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

type LogStreamName

type LogStreamName struct {
}

func (*LogStreamName) ApplyRule

func (l *LogStreamName) ApplyRule(input interface{}) (returnKey string, returnVal interface{})

type Logs

type Logs struct {
	FileStateFolder       string
	MetadataInfo          map[string]string
	ServiceName           string
	DeploymentEnvironment string
	Concurrency           int
}

func (*Logs) ApplyRule

func (l *Logs) ApplyRule(input interface{}) (returnKey string, returnVal interface{})

func (*Logs) Merge

func (l *Logs) Merge(source map[string]interface{}, result map[string]interface{})

type Rule

type Rule translator.Rule

type ServiceName

type ServiceName struct {
}

func (*ServiceName) ApplyRule

func (f *ServiceName) ApplyRule(input interface{}) (returnKey string, returnVal interface{})