grpc

package
v0.27.0 Latest Latest
Warning

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

Go to latest
Published: Feb 20, 2024 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