Search Options

Results per page
Sort
Preferred Languages
Advance

Results 721 - 730 of 1,384 for funcs (0.1 sec)

  1. internal/s3select/csv/errors.go

    	cause      error
    }
    
    func (err *s3Error) Cause() error {
    	return err.cause
    }
    
    func (err *s3Error) ErrorCode() string {
    	return err.code
    }
    
    func (err *s3Error) ErrorMessage() string {
    	return err.message
    }
    
    func (err *s3Error) HTTPStatusCode() int {
    	return err.statusCode
    }
    
    func (err *s3Error) Error() string {
    	return err.message
    }
    
    func errCSVParsingError(err error) *s3Error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.6K bytes
    - Viewed (0)
  2. internal/config/callhome/callhome.go

    }
    
    var configLock sync.RWMutex
    
    // Enabled - indicates if callhome is enabled or not
    func (c *Config) Enabled() bool {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	return c.Enable
    }
    
    // FrequencyDur - returns the currently configured callhome frequency
    func (c *Config) FrequencyDur() time.Duration {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	if c.Frequency == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  3. internal/config/storageclass/storage-class_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package storageclass
    
    import (
    	"errors"
    	"reflect"
    	"testing"
    )
    
    func TestParseStorageClass(t *testing.T) {
    	tests := []struct {
    		storageClassEnv string
    		wantSc          StorageClass
    		expectedError   error
    	}{
    		{
    			"EC:3",
    			StorageClass{
    				Parity: 3,
    			},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 15 23:04:20 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. internal/s3select/csv/args.go

    	AllowQuotedRecordDelimiter bool   `xml:"AllowQuotedRecordDelimiter"`
    	unmarshaled                bool
    }
    
    // IsEmpty - returns whether reader args is empty or not.
    func (args *ReaderArgs) IsEmpty() bool {
    	return !args.unmarshaled
    }
    
    // UnmarshalXML - decodes XML data.
    func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    	args.FileHeaderInfo = none
    	args.RecordDelimiter = defaultRecordDelimiter
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 20 18:31:45 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  7. src/cmd/asm/internal/lex/input.go

    // enabled reports whether the input is enabled by an ifdef, or is at the top level.
    func (in *Input) enabled() bool {
    	return len(in.ifdefStack) == 0 || in.ifdefStack[len(in.ifdefStack)-1]
    }
    
    func (in *Input) expectNewline(directive string) {
    	tok := in.Stack.Next()
    	if tok != '\n' {
    		in.expectText("expected newline after", directive)
    	}
    }
    
    func (in *Input) Next() ScanToken {
    	if in.peek {
    		in.peek = false
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 06 13:17:27 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  8. internal/auth/credentials.go

    func ContainsReservedChars(s string) bool {
    	return strings.ContainsAny(s, reservedChars)
    }
    
    // IsAccessKeyValid - validate access key for right length.
    func IsAccessKeyValid(accessKey string) bool {
    	return len(accessKey) >= accessKeyMinLen
    }
    
    // IsSecretKeyValid - validate secret key for right length.
    func IsSecretKeyValid(secretKey string) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 28 17:14:16 UTC 2024
    - 12K bytes
    - Viewed (0)
  9. internal/grid/manager.go

    func (m *Manager) AddToMux(router *mux.Router, authReq func(r *http.Request) error) {
    	router.Handle(m.routePath, m.Handler(authReq))
    }
    
    // Handler returns a handler that can be used to serve grid requests.
    // This should be connected on RoutePath to the main server.
    func (m *Manager) Handler(authReq func(r *http.Request) error) http.HandlerFunc {
    	return func(w http.ResponseWriter, req *http.Request) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  10. 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)
Back to top