gocbcoreps

Documentation

Index

• func NewGrpcBasicAuth(username, password string) (credentials.PerRPCCredentials, error)
• type Conn
• type ConnState
• type DataNode
• type DialOptions
• type GrpcBasicAuth
  • func (j GrpcBasicAuth) GetRequestMetadata(ctx context.Context, uri ...string) (map[string]string, error)
  • func (j GrpcBasicAuth) RequireTransportSecurity() bool
• type Node
• type RoutingClient
  • func Dial(target string, opts *DialOptions) (*RoutingClient, error)
  • func DialContext(ctx context.Context, target string, opts *DialOptions) (*RoutingClient, error)
  • func (c *RoutingClient) AnalyticsV1() analytics_v1.AnalyticsServiceClient
  • func (c *RoutingClient) BucketV1() admin_bucket_v1.BucketAdminServiceClient
  • func (c *RoutingClient) Close() error
  • func (c *RoutingClient) CloseBucket(bucketName string)
  • func (c *RoutingClient) CollectionV1() admin_collection_v1.CollectionAdminServiceClient
  • func (c *RoutingClient) ConnectionState() ConnState
  • func (c *RoutingClient) KvV1() kv_v1.KvServiceClient
  • func (c *RoutingClient) OpenBucket(bucketName string)
  • func (c *RoutingClient) QueryAdminV1() admin_query_v1.QueryAdminServiceClient
  • func (c *RoutingClient) QueryV1() query_v1.QueryServiceClient
  • func (c *RoutingClient) RoutingV1() routing_v1.RoutingServiceClient
  • func (c *RoutingClient) SearchAdminV1() admin_search_v1.SearchAdminServiceClient
  • func (c *RoutingClient) SearchV1() search_v1.SearchServiceClient
  • func (c *RoutingClient) ViewV1() view_v1.ViewServiceClient
  • func (p *RoutingClient) WatchTopology(ctx context.Context, bucketName string) (<-chan *Topology, error)
• type Topology
• type VbucketRouting

Functions

func NewGrpcBasicAuth

func NewGrpcBasicAuth(username, password string) (credentials.PerRPCCredentials, error)

NewJWTAccessFromKey creates PerRPCCredentials from the given jsonKey.

Types

type Conn

type Conn interface {
	RoutingV1() routing_v1.RoutingServiceClient
	KvV1() kv_v1.KvServiceClient
	QueryV1() query_v1.QueryServiceClient
	CollectionV1() admin_collection_v1.CollectionAdminServiceClient
	BucketV1() admin_bucket_v1.BucketAdminServiceClient
	AnalyticsV1() analytics_v1.AnalyticsServiceClient
	SearchV1() search_v1.SearchServiceClient
}

type ConnState

type ConnState uint8

const (
	ConnStateOffline ConnState = iota
	ConnStateDegraded
	ConnStateOnline
)

type DataNode

type DataNode struct {
	Node *Node

	LocalVbuckets []uint32
	GroupVbuckets []uint32
}

type DialOptions

type DialOptions struct {
	ClientCertificate  *x509.CertPool
	Username           string
	Password           string
	Logger             *zap.Logger
	InsecureSkipVerify bool
	PoolSize           uint32
	TracerProvider     trace.TracerProvider
	MeterProvider      metric.MeterProvider
}

type GrpcBasicAuth

type GrpcBasicAuth struct {
	EncodedData string
}

func (GrpcBasicAuth) GetRequestMetadata

func (j GrpcBasicAuth) GetRequestMetadata(ctx context.Context, uri ...string) (map[string]string, error)

func (GrpcBasicAuth) RequireTransportSecurity

func (j GrpcBasicAuth) RequireTransportSecurity() bool

type Node

type Node struct {
	NodeID      string
	ServerGroup string
}

type RoutingClient

type RoutingClient struct {
	// contains filtered or unexported fields
}

func Dial

func Dial(target string, opts *DialOptions) (*RoutingClient, error)

func DialContext

func DialContext(ctx context.Context, target string, opts *DialOptions) (*RoutingClient, error)

func (*RoutingClient) AnalyticsV1

func (c *RoutingClient) AnalyticsV1() analytics_v1.AnalyticsServiceClient

func (*RoutingClient) BucketV1

func (c *RoutingClient) BucketV1() admin_bucket_v1.BucketAdminServiceClient

func (*RoutingClient) Close

func (c *RoutingClient) Close() error

func (*RoutingClient) CloseBucket

func (c *RoutingClient) CloseBucket(bucketName string)

func (*RoutingClient) CollectionV1

func (c *RoutingClient) CollectionV1() admin_collection_v1.CollectionAdminServiceClient

func (*RoutingClient) ConnectionState

func (c *RoutingClient) ConnectionState() ConnState

func (*RoutingClient) KvV1

func (c *RoutingClient) KvV1() kv_v1.KvServiceClient

func (*RoutingClient) OpenBucket

func (c *RoutingClient) OpenBucket(bucketName string)

func (*RoutingClient) QueryAdminV1

func (c *RoutingClient) QueryAdminV1() admin_query_v1.QueryAdminServiceClient

func (*RoutingClient) QueryV1

func (c *RoutingClient) QueryV1() query_v1.QueryServiceClient

func (*RoutingClient) RoutingV1

func (c *RoutingClient) RoutingV1() routing_v1.RoutingServiceClient

func (*RoutingClient) SearchAdminV1

func (c *RoutingClient) SearchAdminV1() admin_search_v1.SearchAdminServiceClient

func (*RoutingClient) SearchV1

func (c *RoutingClient) SearchV1() search_v1.SearchServiceClient

func (*RoutingClient) ViewV1

func (c *RoutingClient) ViewV1() view_v1.ViewServiceClient

func (*RoutingClient) WatchTopology

func (p *RoutingClient) WatchTopology(ctx context.Context, bucketName string) (<-chan *Topology, error)

type Topology

type Topology struct {
	Revision []uint64

	Nodes          []*Node
	VbucketRouting *VbucketRouting
}

type VbucketRouting

type VbucketRouting struct {
	Nodes       []*DataNode
	NumVbuckets uint
}