controller

Documentation

Index

• Variables
• type AccountIdResolver
  • func NewAccountIdResolver(accountIdResolverImpl string, cfg *config.Config) (AccountIdResolver, error)
  • func NewExpirableCachedAccountIdResolver(baseResolver AccountIdResolver, cacheSize int, ...) (AccountIdResolver, error)
• type AuthGwResp
• type BOPAccountIdResolver
  • func (bar *BOPAccountIdResolver) MapClientIdToAccountId(ctx context.Context, clientID domain.ClientID) (domain.Identity, domain.AccountID, domain.OrgID, error)
• type ConfigurableAccountIdResolver
  • func (bar *ConfigurableAccountIdResolver) MapClientIdToAccountId(ctx context.Context, clientID domain.ClientID) (domain.Identity, domain.AccountID, domain.OrgID, error)
• type ConnectedClientRecorder
  • func NewConnectedClientRecorder(impl string, cfg *config.Config) (ConnectedClientRecorder, error)
  • func NewInventoryBasedConnectedClientRecorder(kafkaWriter InventoryMessageProducer, staleTimestampOffset time.Duration, ...) (ConnectedClientRecorder, error)
• type ConnectorClient
• type ConnectorClientProxyFactory
• type ExpirableCachedAccountIdResolver
  • func (ecar *ExpirableCachedAccountIdResolver) MapClientIdToAccountId(ctx context.Context, clientID domain.ClientID) (domain.Identity, domain.AccountID, domain.OrgID, error)
• type FakeConnectedClientRecorder
  • func (fccr *FakeConnectedClientRecorder) RecordConnectedClient(ctx context.Context, identity domain.Identity, ...) error
• type FakeSourcesRecorder
  • func (f *FakeSourcesRecorder) RegisterWithSources(identity domain.Identity, account domain.AccountID, orgID domain.OrgID, ...) error
• type InventoryBasedConnectedClientRecorder
  • func (ibccr *InventoryBasedConnectedClientRecorder) RecordConnectedClient(ctx context.Context, identity domain.Identity, ...) error
• type InventoryMessageProducer
  • func BuildInventoryMessageProducer(kafkaWriter *kafka.Writer) InventoryMessageProducer
• type Metrics
  • func NewMetrics() *Metrics
• type SourcesRecorder
  • func NewSourcesRecorder(impl string, cfg *config.Config) (SourcesRecorder, error)
• type SourcesRecorderImpl
  • func (sri *SourcesRecorderImpl) RegisterWithSources(identity domain.Identity, account domain.AccountID, orgID domain.OrgID, ...) error

Variables

var (
	ErrUnableToSendMessage = errors.New("unable to send message")
	ErrDisconnectedNode    = errors.New("disconnected node")
)

Types

type AccountIdResolver

type AccountIdResolver interface {
	MapClientIdToAccountId(context.Context, domain.ClientID) (domain.Identity, domain.AccountID, domain.OrgID, error)
}

func NewAccountIdResolver

func NewAccountIdResolver(accountIdResolverImpl string, cfg *config.Config) (AccountIdResolver, error)

func NewExpirableCachedAccountIdResolver

func NewExpirableCachedAccountIdResolver(baseResolver AccountIdResolver, cacheSize int, cacheTTL, errorTTL time.Duration) (AccountIdResolver, error)

type AuthGwResp

type AuthGwResp struct {
	Identity string `json:"x-rh-identity"`
}

type BOPAccountIdResolver

type BOPAccountIdResolver struct {
	Config *config.Config
}

func (*BOPAccountIdResolver) MapClientIdToAccountId

func (bar *BOPAccountIdResolver) MapClientIdToAccountId(ctx context.Context, clientID domain.ClientID) (domain.Identity, domain.AccountID, domain.OrgID, error)

type ConfigurableAccountIdResolver

type ConfigurableAccountIdResolver struct {
	Config *config.Config
	// contains filtered or unexported fields
}

func (*ConfigurableAccountIdResolver) MapClientIdToAccountId

func (bar *ConfigurableAccountIdResolver) MapClientIdToAccountId(ctx context.Context, clientID domain.ClientID) (domain.Identity, domain.AccountID, domain.OrgID, error)

type ConnectedClientRecorder

type ConnectedClientRecorder interface {
	RecordConnectedClient(context.Context, domain.Identity, domain.ConnectorClientState) error
}

func NewConnectedClientRecorder

func NewConnectedClientRecorder(impl string, cfg *config.Config) (ConnectedClientRecorder, error)

func NewInventoryBasedConnectedClientRecorder

func NewInventoryBasedConnectedClientRecorder(kafkaWriter InventoryMessageProducer, staleTimestampOffset time.Duration, reporterName string) (ConnectedClientRecorder, error)

type ConnectorClient

type ConnectorClient interface {
	SendMessage(context.Context, string, interface{}, interface{}) (*uuid.UUID, error)
	Ping(context.Context) error
	Reconnect(context.Context, string, int) error
	GetDispatchers(context.Context) (domain.Dispatchers, error)
	GetCanonicalFacts(context.Context) (domain.CanonicalFacts, error)
	GetTags(context.Context) (domain.Tags, error)
	Disconnect(context.Context, string) error
}

type ConnectorClientProxyFactory

type ConnectorClientProxyFactory interface {
	CreateProxy(context.Context, domain.OrgID, domain.AccountID, domain.ClientID, domain.CanonicalFacts, domain.Dispatchers, domain.Tags) (ConnectorClient, error)
}

type ExpirableCachedAccountIdResolver

type ExpirableCachedAccountIdResolver struct {
	AccountIdResolver
	// contains filtered or unexported fields
}

func (*ExpirableCachedAccountIdResolver) MapClientIdToAccountId

func (ecar *ExpirableCachedAccountIdResolver) MapClientIdToAccountId(ctx context.Context, clientID domain.ClientID) (domain.Identity, domain.AccountID, domain.OrgID, error)

type FakeConnectedClientRecorder

type FakeConnectedClientRecorder struct {
}

func (*FakeConnectedClientRecorder) RecordConnectedClient

func (fccr *FakeConnectedClientRecorder) RecordConnectedClient(ctx context.Context, identity domain.Identity, rhcClient domain.ConnectorClientState) error

type FakeSourcesRecorder

type FakeSourcesRecorder struct {
}

func (*FakeSourcesRecorder) RegisterWithSources

func (f *FakeSourcesRecorder) RegisterWithSources(identity domain.Identity, account domain.AccountID, orgID domain.OrgID, clientID domain.ClientID, sourceRef, sourceName, sourceType, applicationType string) error

type InventoryBasedConnectedClientRecorder

type InventoryBasedConnectedClientRecorder struct {
	MessageProducer      InventoryMessageProducer
	StaleTimestampOffset time.Duration
	ReporterName         string
}

func (*InventoryBasedConnectedClientRecorder) RecordConnectedClient

func (ibccr *InventoryBasedConnectedClientRecorder) RecordConnectedClient(ctx context.Context, identity domain.Identity, rhcClient domain.ConnectorClientState) error

type InventoryMessageProducer

type InventoryMessageProducer func(ctx context.Context, log *logrus.Entry, msg []byte) error

func BuildInventoryMessageProducer

func BuildInventoryMessageProducer(kafkaWriter *kafka.Writer) InventoryMessageProducer

type Metrics

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

func NewMetrics

func NewMetrics() *Metrics

type SourcesRecorder

type SourcesRecorder interface {
	RegisterWithSources(identity domain.Identity, account domain.AccountID, orgID domain.OrgID, client domain.ClientID, sourceRef, sourceName, sourceType, applicationType string) error
}

func NewSourcesRecorder

func NewSourcesRecorder(impl string, cfg *config.Config) (SourcesRecorder, error)

type SourcesRecorderImpl

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

func (*SourcesRecorderImpl) RegisterWithSources

func (sri *SourcesRecorderImpl) RegisterWithSources(identity domain.Identity, account domain.AccountID, orgID domain.OrgID, clientID domain.ClientID, sourceRef, sourceName, sourceType, applicationType string) error