stateblock.go

package gocb

import (
	"fmt"
	"time"
)

type clientStateBlock struct {
	BucketName string
}

func (sb *clientStateBlock) Hash() string {
	return fmt.Sprintf("%s", sb.BucketName)
}

type stateBlock struct {
	cachedClient client

	clientStateBlock

	ScopeName      string
	CollectionName string

	UseServerDurations bool

	ConnectTimeout   time.Duration
	KvTimeout        time.Duration
	KvDurableTimeout time.Duration
	DuraPollTimeout  time.Duration

	QueryTimeout      time.Duration
	AnalyticsTimeout  time.Duration
	SearchTimeout     time.Duration
	ViewTimeout       time.Duration
	ManagementTimeout time.Duration

	UseMutationTokens bool

	Transcoder Transcoder

	RetryStrategyWrapper   *retryStrategyWrapper
	OrphanLoggerEnabled    bool
	OrphanLoggerInterval   time.Duration
	OrphanLoggerSampleSize uint32

	Tracer requestTracer

	CircuitBreakerConfig CircuitBreakerConfig
	SecurityConfig       SecurityConfig
	InternalConfig       InternalConfig
}

func (sb *stateBlock) getCachedClient() client {
	if sb.cachedClient == nil {
		panic("attempted to fetch client from incomplete state block")
	}

	return sb.cachedClient
}

func (sb *stateBlock) cacheClient(cli client) {
	sb.cachedClient = cli
}