grpc

Documentation

Index

• type SourceConn
• type SourceMeta
• type SourceState
• type SourceStore
  • func NewSourceStore(logger *logrus.Logger, timeout, readyTimeout time.Duration, ...) *SourceStore
  • func (s *SourceStore) Add(key registry.CatalogKey, address string) (*SourceConn, error)
  • func (s *SourceStore) AsClients(namespaces ...string) map[registry.CatalogKey]registry.ClientInterface
  • func (s *SourceStore) ClientsForNamespaces(namespaces ...string) map[registry.CatalogKey]client.Interface
  • func (s *SourceStore) Exists(key registry.CatalogKey) bool
  • func (s *SourceStore) Get(key registry.CatalogKey) *SourceConn
  • func (s *SourceStore) GetMeta(key registry.CatalogKey) *SourceMeta
  • func (s *SourceStore) Remove(key registry.CatalogKey) error
  • func (s *SourceStore) Start(ctx context.Context)

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 (s *SourceStore) Get(key registry.CatalogKey) *SourceConn

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)