Help us shape the future of Go! Take the 2026 Go Developer Survey

grpc

package
v0.46.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 23, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type SourceConn

type SourceConn struct {
	SourceMeta
	Conn *grpc.ClientConn
	// contains filtered or unexported fields
}

type SourceMeta

type SourceMeta struct {
	Address         string
	LastConnect     metav1.Time
	ConnectionState connectivity.State
}

type SourceState

type SourceState struct {
	Key   registry.CatalogKey
	State connectivity.State
}

type SourceStore

type SourceStore struct {
	sync.Once
	// contains filtered or unexported fields
}

func NewSourceStore

func NewSourceStore(logger *logrus.Logger, timeout, readyTimeout time.Duration, sync func(SourceState)) *SourceStore

func (*SourceStore) Add

func (s *SourceStore) Add(key registry.CatalogKey, address string) (*SourceConn, error)

func (*SourceStore) AsClients

func (s *SourceStore) AsClients(namespaces ...string) map[registry.CatalogKey]registry.ClientInterface

func (*SourceStore) ClientsForNamespaces

func (s *SourceStore) ClientsForNamespaces(namespaces ...string) map[registry.CatalogKey]client.Interface

func (*SourceStore) Exists

func (s *SourceStore) Exists(key registry.CatalogKey) bool

func (*SourceStore) Get

func (*SourceStore) GetMeta

func (s *SourceStore) GetMeta(key registry.CatalogKey) *SourceMeta

func (*SourceStore) Remove

func (s *SourceStore) Remove(key registry.CatalogKey) error

func (*SourceStore) Start

func (s *SourceStore) Start(ctx context.Context)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL