Search Options

Results per page
Sort
Preferred Languages
Advance

Results 291 - 300 of 1,349 for Struct (0.05 sec)

  1. internal/s3select/json/reader.go

    // https://docs.aws.amazon.com/AmazonS3/latest/userguide/selecting-content-from-objects.html
    const maxDocumentSize = 10 << 20
    
    // Reader - JSON record reader for S3Select.
    type Reader struct {
    	args       *ReaderArgs
    	decoder    *jstream.Decoder
    	valueCh    chan *jstream.MetaValue
    	readCloser io.ReadCloser
    }
    
    // Read - reads single record.
    func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  2. internal/event/target/redis.go

    		}
    	}
    
    	return nil
    }
    
    // RedisTarget - Redis target.
    type RedisTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       RedisArgs
    	pool       *redis.Pool
    	store      store.Store[event.Event]
    	firstPing  bool
    	loggerOnce logger.LogOnce
    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *RedisTarget) ID() event.TargetID {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/compare/sds/writer_test.go

    // limitations under the License.
    
    package sdscompare
    
    import (
    	"bytes"
    	"strings"
    	"testing"
    )
    
    func TestSDSWriterSecretItems(t *testing.T) {
    	tests := []struct {
    		name       string
    		format     Format
    		items      []SecretItem
    		expected   []string
    		unexpected []string
    	}{
    		{
    			name:       "test tabular output with no secret items is equivalent to the header",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri May 29 20:42:01 UTC 2020
    - 4.9K bytes
    - Viewed (0)
  4. clause/delete_test.go

    package clause_test
    
    import (
    	"fmt"
    	"testing"
    
    	"gorm.io/gorm/clause"
    )
    
    func TestDelete(t *testing.T) {
    	results := []struct {
    		Clauses []clause.Interface
    		Result  string
    		Vars    []interface{}
    	}{
    		{
    			[]clause.Interface{clause.Delete{}, clause.From{}},
    			"DELETE FROM `users`", nil,
    		},
    		{
    			[]clause.Interface{clause.Delete{Modifier: "LOW_PRIORITY"}, clause.From{}},
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Jun 02 01:18:01 UTC 2020
    - 608 bytes
    - Viewed (0)
  5. src/cmd/api/testdata/src/pkg/p3/p3.go

    // Copyright 2012 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    package p3
    
    type ThirdBase struct{}
    
    func (tb *ThirdBase) GoodPlayer() (i, j, k int)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Nov 09 14:05:53 UTC 2022
    - 310 bytes
    - Viewed (0)
  6. cmd/httprange_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"testing"
    )
    
    func TestHTTPRequestRangeSpec(t *testing.T) {
    	resourceSize := int64(10)
    	validRangeSpecs := []struct {
    		spec                 string
    		expOffset, expLength int64
    	}{
    		{"bytes=0-", 0, 10},
    		{"bytes=1-", 1, 9},
    		{"bytes=0-9", 0, 10},
    		{"bytes=1-10", 1, 9},
    		{"bytes=1-1", 1, 1},
    		{"bytes=2-5", 2, 4},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun May 05 16:56:21 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  7. cni/pkg/util/podutil_test.go

    				Name:        "test",
    				Namespace:   "test",
    				Labels:      ambientEnabledLabel,
    				Annotations: sidecarStatusAnnotation,
    			},
    		}
    	)
    
    	type args struct {
    		namespace *corev1.Namespace
    		pod       *corev1.Pod
    	}
    	tests := []struct {
    		name string
    		args args
    		want bool
    	}{
    		{
    			name: "ambient mode enabled for namespace",
    			args: args{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  8. cmd/admin-handlers.go

    	disks := strings.Split(r.Form.Get("disks"), ",")
    	byDisk := strings.EqualFold(r.Form.Get("by-disk"), "true")
    	var diskMap map[string]struct{}
    	if len(disks) > 0 && disks[0] != "" {
    		diskMap = make(map[string]struct{}, len(disks))
    		for _, k := range disks {
    			if k != "" {
    				diskMap[k] = struct{}{}
    			}
    		}
    	}
    	jobID := r.Form.Get("by-jobID")
    
    	hosts := strings.Split(r.Form.Get("hosts"), ",")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  9. cmd/metrics-v3-handler.go

    	"github.com/prometheus/client_golang/prometheus"
    	"github.com/prometheus/client_golang/prometheus/promhttp"
    )
    
    type promLogger struct{}
    
    func (p promLogger) Println(v ...interface{}) {
    	metricsLogIf(GlobalContext, fmt.Errorf("metrics handler error: %v", v))
    }
    
    type metricsV3Server struct {
    	registry *prometheus.Registry
    	opts     promhttp.HandlerOpts
    	auth     func(http.Handler) http.Handler
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  10. callbacks.go

    			"row":    {db: db},
    			"raw":    {db: db},
    		},
    	}
    }
    
    // callbacks gorm callbacks manager
    type callbacks struct {
    	processors map[string]*processor
    }
    
    type processor struct {
    	db        *DB
    	Clauses   []string
    	fns       []func(*DB)
    	callbacks []*callback
    }
    
    type callback struct {
    	name      string
    	before    string
    	after     string
    	remove    bool
    	replace   bool
    	match     func(*DB) bool
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Mar 26 03:33:36 UTC 2024
    - 8.6K bytes
    - Viewed (0)
Back to top