- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 117 for Nevett (0.2 sec)
-
internal/event/event.go
package event import ( "github.com/minio/madmin-go/v3" ) const ( // NamespaceFormat - namespace log format used in some event targets. NamespaceFormat = "namespace" // AccessFormat - access log format used in some event targets. AccessFormat = "access" // AMZTimeFormat - event time format. AMZTimeFormat = "2006-01-02T15:04:05.000Z"
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jun 20 00:53:08 GMT 2023 - 3.4K bytes - Viewed (0) -
internal/config/lambda/event/event.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package event import "net/http" // Identity represents access key who caused the event. type Identity struct { Type string `json:"type"` PrincipalID string `json:"principalId"` AccessKeyID string `json:"accessKeyId"` }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 2.6K bytes - Viewed (0) -
cmd/event-notification.go
} type eventArgs struct { EventName event.Name BucketName string Object ObjectInfo ReqParams map[string]string RespElements map[string]string Host string UserAgent string } // ToEvent - converts to notification event. func (args eventArgs) ToEvent(escape bool) event.Event { eventTime := UTCNow() uniqueID := fmt.Sprintf("%X", eventTime.UnixNano())
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.8K bytes - Viewed (0) -
internal/event/target/redis.go
} // RedisAccessEvent holds event log data and timestamp type RedisAccessEvent struct { Event []event.Event EventTime string } // Validate RedisArgs fields func (r RedisArgs) Validate() error { if !r.Enable { return nil } if r.Format != "" { f := strings.ToLower(r.Format) if f != event.NamespaceFormat && f != event.AccessFormat { return fmt.Errorf("unrecognized format")
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 9.1K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
return fmt.Errorf("unexpected event type: %+v", input) } } func (s *InformerHandlers) reconcileNamespace(input any) error { event := input.(controllers.Event) ns := event.Latest().(*corev1.Namespace) switch event.Event { case controllers.EventAdd: log.Debugf("Namespace %s added", ns.Name) s.enqueueNamespace(ns) case controllers.EventUpdate: newNs := event.New.(*corev1.Namespace)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 01:03:24 GMT 2024 - 9.9K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle.go
return lc.eval(obj, time.Now().UTC()) } // eval returns the lifecycle event applicable at the given now. If now is the // zero value of time.Time, it returns the upcoming lifecycle event. func (lc Lifecycle) eval(obj ObjectOpts, now time.Time) Event { var events []Event if obj.ModTime.IsZero() { return Event{} } // Handle expiry of restored object; NB Restored Objects have expiry set on
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 09 06:41:22 GMT 2024 - 17K bytes - Viewed (0) -
internal/event/errors.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package event import ( "encoding/xml" "fmt" ) // IsEventError - checks whether given error is event error or not. func IsEventError(err error) bool { switch err.(type) { case ErrInvalidFilterName, *ErrInvalidFilterName: return true
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 4.1K bytes - Viewed (0) -
internal/config/lambda/parse.go
} } return targets, nil } // FetchEnabledTargets - Returns a set of configured TargetList func FetchEnabledTargets(ctx context.Context, cfg config.Config, transport *http.Transport) (*event.TargetList, error) { targetList := event.NewTargetList() for _, subSys := range config.LambdaSubSystems.ToSlice() { targets, err := fetchSubSysTargets(ctx, cfg, subSys, transport) if err != nil { return nil, err }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
internal/event/targetlist_test.go
package event import ( "context" "crypto/rand" "errors" "reflect" "testing" "time" "github.com/minio/minio/internal/store" ) type ExampleTarget struct { id TargetID sendErr bool closeErr bool } func (target ExampleTarget) ID() TargetID { return target.id } // Save - Sends event directly without persisting.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Dec 05 10:16:33 GMT 2023 - 6.1K bytes - Viewed (0) -
cmd/object-handlers-common.go
import ( "context" "fmt" "net/http" "regexp" "strconv" "time" "github.com/minio/minio/internal/amztime" "github.com/minio/minio/internal/bucket/lifecycle" "github.com/minio/minio/internal/event" "github.com/minio/minio/internal/hash" xhttp "github.com/minio/minio/internal/http" ) var etagRegex = regexp.MustCompile("\"*?([^\"]*?)\"*?$")
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 09 08:17:49 GMT 2024 - 14.6K bytes - Viewed (0)