Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 424 for msgs (0.02 seconds)

  1. cmd/iam.go

    	}
    	var arns []string
    	for arn := range sys.rolesMap {
    		arns = append(arns, arn.String())
    	}
    	sort.Strings(arns)
    	msgs := make([]string, 0, len(arns))
    	for _, arn := range arns {
    		msgs = append(msgs, color.Bold(arn))
    	}
    
    	logger.Info(fmt.Sprintf("%s %s", color.Blue("IAM Roles:"), strings.Join(msgs, " ")))
    }
    
    // HasWatcher - returns if the IAM system has a watcher to be notified of
    // changes.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 76.5K bytes
    - Click Count (0)
  2. cmd/site-replication.go

    		keys = append(keys, d)
    	}
    	sort.Strings(keys)
    
    	var success int
    	msgs := []string{}
    	for _, d := range keys {
    		name := c.state.Peers[d].Name
    		err := errMap[d]
    		if err == nil {
    			msgs = append(msgs, fmt.Sprintf("'%s' on site %s (%s): succeeded", actionName, name, d))
    			success++
    		} else {
    			msgs = append(msgs, fmt.Sprintf("'%s' on site %s (%s): failed(%v)", actionName, name, d, err))
    		}
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
  3. internal/grid/types_test.go

    package grid
    
    import (
    	"reflect"
    	"testing"
    
    	"github.com/tinylib/msgp/msgp"
    )
    
    func TestMarshalUnmarshalMSS(t *testing.T) {
    	v := MSS{"abc": "def", "ghi": "jkl"}
    	bts, err := v.MarshalMsg(nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    	var v2 MSS
    	left, err := v2.UnmarshalMsg(bts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if len(left) != 0 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  4. internal/grid/types.go

    func (m *MSS) Msgsize() int {
    	if m == nil || *m == nil {
    		return msgp.NilSize
    	}
    	s := msgp.MapHeaderSize
    	for za0001, za0002 := range *m {
    		s += msgp.StringPrefixSize + len(za0001) + msgp.StringPrefixSize + len(za0002)
    	}
    	return s
    }
    
    // NewMSS returns a new MSS.
    func NewMSS() *MSS {
    	m := MSS(mssPool.Get())
    	clear(m)
    	return &m
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.5K bytes
    - Click Count (0)
  5. cmd/data-usage-cache.go

    type dataUsageEntry struct {
    	Children dataUsageHashMap `msg:"ch"`
    	// These fields do no include any children.
    	Size          int64             `msg:"sz"`
    	Objects       uint64            `msg:"os"`
    	Versions      uint64            `msg:"vs"` // Versions that are not delete markers.
    	DeleteMarkers uint64            `msg:"dms"`
    	ObjSizes      sizeHistogram     `msg:"szs"`
    	ObjVersions   versionsHistogram `msg:"vh"`
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  6. cmd/xl-storage-format-v2.go

    	var zb0001 uint32
    	zb0001, bts, err = msgp.ReadMapHeaderBytes(bts)
    	if err != nil {
    		return msgp.WrapError(err, "loadLegacy.ReadMapHeader")
    	}
    
    	var tmp xlMetaV2Version
    	for zb0001 > 0 {
    		zb0001--
    		field, bts, err = msgp.ReadMapKeyZC(bts)
    		if err != nil {
    			return msgp.WrapError(err, "loadLegacy.ReadMapKey")
    		}
    		switch msgp.UnsafeString(field) {
    		case "Versions":
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 65.6K bytes
    - Click Count (1)
  7. cmd/server-startup-msg.go

    Daryl White <******@****.***> 1755022836 -0400
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  8. internal/config/errors-utils.go

    	if u.detail == "" {
    		if u.msg != "" {
    			return u.msg
    		}
    		return "<nil>"
    	}
    	return u.detail
    }
    
    // Msg - Replace the current error's message
    func (u Err) Msg(m string) Err {
    	e := u.Clone()
    	e.msg = m
    	return e
    }
    
    // Msgf - Replace the current error's message
    func (u Err) Msgf(m string, args ...any) Err {
    	e := u.Clone()
    	if len(args) == 0 {
    		e.msg = m
    	} else {
    		e.msg = fmt.Sprintf(m, args...)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  9. internal/grid/README.md

    ### Typed handlers
    
    Typed handlers are handlers that have a specific type for the request and response payloads.
    These must provide `msgp` serialization and deserialization.
    
    In the examples we use a `MSS` type, which is a `map[string]string` that is `msgp` serializable.
    
    ```go
        handler := func(request *grid.MSS) (*grid.MSS, *grid.RemoteErr) {
            fmt.Println("Got request with field", request["myfield"])
            // Do something with payload
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  10. internal/grid/grid_test.go

    	// 1: Echo
    	h1 := NewSingleHandler[*MSS, *MSS](handlerTest, NewMSS, NewMSS)
    	// Handles incoming requests, returns a response
    	handler1 := func(req *MSS) (resp *MSS, err *RemoteErr) {
    		resp = h1.NewResponse()
    		maps.Copy((*resp), *req)
    		return resp, nil
    	}
    	// Return error
    	h2 := NewSingleHandler[*MSS, *MSS](handlerTest2, NewMSS, NewMSS)
    	handler2 := func(req *MSS) (resp *MSS, err *RemoteErr) {
    		defer req.Recycle()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.1K bytes
    - Click Count (0)
Back to Top