- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for func (0.32 sec)
-
internal/config/lambda/config.go
// information about various lambda targets. type Config struct { Webhook map[string]target.WebhookArgs `json:"webhook"` } const ( defaultTarget = "1" ) // NewConfig - initialize lambda config. func NewConfig() Config { // Make sure to initialize lambda targets cfg := Config{ Webhook: make(map[string]target.WebhookArgs), } cfg.Webhook[defaultTarget] = target.WebhookArgs{} return cfg
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 1.3K bytes - Viewed (0) -
istioctl/pkg/config/config.go
} // Cmd represents the config subcommand command func Cmd() *cobra.Command { configCmd := &cobra.Command{ Use: "config SUBCOMMAND", Short: "Configure istioctl defaults", Args: cobra.NoArgs, Example: ` # list configuration parameters istioctl experimental config list`, } configCmd.AddCommand(listCommand()) return configCmd } func listCommand() *cobra.Command { listCmd := &cobra.Command{
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sun Jul 30 12:16:07 GMT 2023 - 3.1K bytes - Viewed (0) -
internal/logger/config.go
} // NewConfig - initialize new logger config. func NewConfig() Config { cfg := Config{ // Console logging is on by default Console: Console{ Enabled: true, }, HTTP: make(map[string]http.Config), AuditWebhook: make(map[string]http.Config), AuditKafka: make(map[string]kafka.Config), } return cfg } func getCfgVal(envName, key, defaultValue string) string {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.8K bytes - Viewed (0) -
internal/config/identity/plugin/config.go
currentMinute serviceRTTMinuteStats } func (h *metrics) setConnSuccess(reqStartTime time.Time) { h.Lock() defer h.Unlock() h.LastCheckSuccess = reqStartTime } func (h *metrics) setConnFailure(reqStartTime time.Time) { h.Lock() defer h.Unlock() h.LastCheckFailure = reqStartTime } func (h *metrics) updateLastFullMinute(currReqMinute time.Time) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.3K bytes - Viewed (3) -
cni/pkg/config/config.go
InitContainerName string InitTerminationMsg string InitExitCode int // Label and field selectors to select pods managed by race repair. LabelSelectors string FieldSelectors string } func (c InstallConfig) String() string { var b strings.Builder b.WriteString("CNINetDir: " + c.CNINetDir + "\n") b.WriteString("MountedCNINetDir: " + c.MountedCNINetDir + "\n")
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 5.5K bytes - Viewed (0) -
internal/event/config.go
type FilterRule struct { Name string `xml:"Name"` Value string `xml:"Value"` } func (filter FilterRule) isEmpty() bool { return filter.Name == "" && filter.Value == "" } // MarshalXML implements a custom marshaller to support `omitempty` feature. func (filter FilterRule) MarshalXML(e *xml.Encoder, start xml.StartElement) error { if filter.isEmpty() { return nil }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Nov 16 17:28:29 GMT 2021 - 8.4K bytes - Viewed (0) -
internal/config/policy/opa/config.go
type Opa struct { args Args client *http.Client } // Enabled returns if opa is enabled. func Enabled(kvs config.KVS) bool { return kvs.Get(URL) != "" } // LookupConfig lookup Opa from config, override with any ENVs. func LookupConfig(kv config.KVS, transport *http.Transport, closeRespFn func(io.ReadCloser)) (Args, error) { args := Args{}
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Sep 14 21:50:16 GMT 2023 - 5.2K bytes - Viewed (1) -
internal/config/config.go
// to operate on list of key values. type KVS []KV // Empty - return if kv is empty func (kvs KVS) Empty() bool { return len(kvs) == 0 } // Clone - returns a copy of the KVS func (kvs KVS) Clone() KVS { return append(make(KVS, 0, len(kvs)), kvs...) } // GetWithDefault - returns default value if key not set func (kvs KVS) GetWithDefault(key string, defaultKVS KVS) string { v := kvs.Get(key)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 37.3K bytes - Viewed (0) -
internal/config/policy/plugin/config.go
args Args client *http.Client } // Enabled returns if AuthZPlugin is enabled. func Enabled(kvs config.KVS) bool { return kvs.Get(URL) != "" } // LookupConfig lookup AuthZPlugin from config, override with any ENVs. func LookupConfig(s config.Config, httpSettings xhttp.ConnSettings, closeRespFn func(io.ReadCloser)) (Args, error) { args := Args{}
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Sep 14 21:50:16 GMT 2023 - 5.8K bytes - Viewed (0) -
internal/config/notify/config.go
Webhook map[string]target.WebhookArgs `json:"webhook"` } const ( defaultTarget = "1" ) // NewConfig - initialize notification config. func NewConfig() Config { // Make sure to initialize notification targets cfg := Config{ NSQ: make(map[string]target.NSQArgs), AMQP: make(map[string]target.AMQPArgs),
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 2.8K bytes - Viewed (0)