controller

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

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

type BOPAccountIdResolver struct {
	Config *config.Config
}

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

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

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 interface {
	CreateProxy(context.Context, domain.OrgID, domain.AccountID, domain.ClientID, domain.CanonicalFacts, domain.Dispatchers, domain.Tags) (ConnectorClient, error)
}

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

type FakeConnectedClientRecorder struct {
}

type FakeSourcesRecorder struct {
}

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

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

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

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

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