Documentation ¶
Index ¶
- Constants
- Variables
- func DefaultCloudoregConfig() *config.Config
- func ForwardableMessageHeaders(msg *kafka.Message) []kafka.Header
- func HeadersAsMap(msg *kafka.Message) map[string]kafka.Header
- func LogKafka(logChan chan kafka.LogEvent)
- type ApplicationAuthenticationCreate
- type Cloudoreg
- func (c *Cloudoreg) ConsumeAndProcess(ctx context.Context)
- func (c *Cloudoreg) ProcessApplicationAuthenticationCreate(ctx context.Context, appAuth *ApplicationAuthenticationCreate, ...) (bool, error)
- func (c *Cloudoreg) ProcessSourceEventMessage(ctx context.Context, msg *kafka.Message)
- func (c *Cloudoreg) Produce(applicationId string, available bool, err error, headers []kafka.Header) error
- func (c *Cloudoreg) Run(ctx context.Context)
- func (c *Cloudoreg) VerifyAccountAccess(awsARN arn.ARN) (bool, error)
Constants ¶
View Source
const ( HeaderRHIdentity = "x-rh-identity" HeaderRHSourcesAccountNumber = "x-rh-sources-account-number" HeaderRHSourcesOrgID = "x-rh-sources-org-id" HeaderEventType = "event_type" SOURCES_RESOURCE_TYPE = "Application" )
Variables ¶
View Source
var ( AvailabilityStatusMap = map[bool]string{ // contains filtered or unexported fields } )
Functions ¶
func DefaultCloudoregConfig ¶
Types ¶
type ApplicationAuthenticationCreate ¶
type ApplicationAuthenticationCreate struct { ID json.Number `json:"id"` CreatedAt string `json:"created_at"` UpdatedAt string `json:"updated_at"` PausedAt string `json:"paused_at"` ApplicationID json.Number `json:"application_id"` AuthenticationID json.Number `json:"authentication_id"` Tenant string `json:"tenant"` }
type Cloudoreg ¶
type Cloudoreg struct {
// contains filtered or unexported fields
}
func NewCloudoreg ¶
func (*Cloudoreg) ConsumeAndProcess ¶
func (*Cloudoreg) ProcessApplicationAuthenticationCreate ¶
func (c *Cloudoreg) ProcessApplicationAuthenticationCreate(ctx context.Context, appAuth *ApplicationAuthenticationCreate, ebsAccount, orgID string) (bool, error)
ProcessApplicationAuthenticationCreate validates the source and establishes the trust at rhsm-api cloudaccess side
func (*Cloudoreg) ProcessSourceEventMessage ¶
Click to show internal directories.
Click to hide internal directories.