- Sort Score
- Result 10 results
- Languages All
Results 591 - 600 of 1,214 for Func (0.03 sec)
-
internal/logger/target/console/console.go
output io.Writer } // Validate - validate if the tty can be written to func (c *Target) Validate() error { return nil } // Endpoint returns the backend endpoint func (c *Target) Endpoint() string { return "" } func (c *Target) String() string { return "console" } // Send log message 'e' to console func (c *Target) Send(e interface{}) error { entry, ok := e.(log.Entry) if !ok {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 3.9K bytes - Viewed (0) -
internal/s3select/sql/stringfuncs.go
if len(parts) == 1 { return "", false } res = parts[1] } return res, true } func dropRune(text string) (res string, ok bool) { r := []rune(text) if len(r) == 0 { return "", false } return string(r[1:]), true } func evalSQLSubstring(s string, startIdx, length int) (res string, err error) { rs := []rune(s)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 4.2K bytes - Viewed (0) -
internal/config/lambda/parse.go
"github.com/minio/minio/internal/config/lambda/target" "github.com/minio/minio/internal/logger" "github.com/minio/pkg/v3/env" xnet "github.com/minio/pkg/v3/net" ) const ( logSubsys = "notify" ) func logOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) { logger.LogOnceIf(ctx, logSubsys, err, id, errKind...) } // ErrTargetsOffline - Indicates single/multiple target failures.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0) -
utils/tests/dummy_dialecter.go
}) return nil } func (DummyDialector) DefaultValueOf(field *schema.Field) clause.Expression { return clause.Expr{SQL: "DEFAULT"} } func (DummyDialector) Migrator(*gorm.DB) gorm.Migrator { return nil } func (DummyDialector) BindVarTo(writer clause.Writer, stmt *gorm.Statement, v interface{}) { writer.WriteByte('?') } func (DummyDialector) QuoteTo(writer clause.Writer, str string) {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Mon Mar 06 06:03:31 UTC 2023 - 2.2K bytes - Viewed (0) -
cmd/bucket-policy.go
} // NewPolicySys - creates new policy system. func NewPolicySys() *PolicySys { return &PolicySys{} } func getSTSConditionValues(r *http.Request, lc string, cred auth.Credentials) map[string][]string { m := make(map[string][]string) if d := r.Form.Get("DurationSeconds"); d != "" { m["DurationSeconds"] = []string{d} } return m }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8K bytes - Viewed (0) -
internal/crypto/key.go
type ObjectKey [32]byte // GenerateKey generates a unique ObjectKey from a 256 bit external key // and a source of randomness. If random is nil the default PRNG of the // system (crypto/rand) is used. func GenerateKey(extKey []byte, random io.Reader) (key ObjectKey) { if random == nil { random = rand.Reader } if len(extKey) != 32 { // safety check
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Mar 19 20:28:10 UTC 2024 - 6.4K bytes - Viewed (0) -
cmd/endpoint_test.go
} } } func TestCreateEndpoints(t *testing.T) { tempGlobalMinioPort := globalMinioPort defer func() { globalMinioPort = tempGlobalMinioPort }() globalMinioPort = "9000" // Filter ipList by IPs those do not start with '127.'. nonLoopBackIPs := localIP4.FuncMatch(func(ip string, matchString string) bool { return !net.ParseIP(ip).IsLoopback() }, "")
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Jan 13 07:53:03 UTC 2024 - 18.9K bytes - Viewed (0) -
association.go
} } else { association.Error = err } return association } func (association *Association) Unscoped() *Association { return &Association{ DB: association.DB, Relationship: association.Relationship, Error: association.Error, Unscope: true, } } func (association *Association) Find(out interface{}, conds ...interface{}) error { if association.Error == nil {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Jun 12 10:49:45 UTC 2024 - 21.5K bytes - Viewed (0) -
internal/disk/stat_freebsd.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package disk import ( "errors" "fmt" "syscall" ) // GetInfo returns total and free bytes available in a directory, e.g. `/`. func GetInfo(path string, _ bool) (info Info, err error) { s := syscall.Statfs_t{} err = syscall.Statfs(path, &s) if err != nil { return Info{}, err } reservedBlocks := s.Bfree - uint64(s.Bavail) info = Info{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 26 19:34:50 UTC 2024 - 1.7K bytes - Viewed (0) -
internal/config/dns/etcd_dns.go
// constructor initializes. func DomainNames(domainNames []string) EtcdOption { return func(args *CoreDNS) { args.domainNames = domainNames } } // DomainIPs set a list of custom domain IPs, note this will // fail if set to empty when constructor initializes. func DomainIPs(domainIPs set.StringSet) EtcdOption { return func(args *CoreDNS) { args.domainIPs = domainIPs } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 26 15:03:08 UTC 2024 - 8K bytes - Viewed (0)