Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChanListener ¶
type ChanListener struct {
// contains filtered or unexported fields
}
ChanListener listens for audit logs and processes them blocking one event at a time
func NewChanListener ¶
func NewChanListener(inputChan <-chan audit.Log, processor *Processor) *ChanListener
type ChanPublisher ¶
type ChanPublisher struct {
// contains filtered or unexported fields
}
ChanPublisher is a blocking audit event publisher
func NewChanPublisher ¶
func NewChanPublisher(target chan<- audit.Log) *ChanPublisher
type CheckoutService ¶
type CheckoutService interface {
Apply(ctx context.Context, ch checkout.Checkout) (*subscription.Subscription, *product.Product, error)
}
type CustomerService ¶
type OrganizationService ¶
type OrganizationService interface {
GetRaw(ctx context.Context, id string) (organization.Organization, error)
}
type PlanService ¶
type Processor ¶
type Processor struct {
// contains filtered or unexported fields
}
func NewProcessor ¶
func NewProcessor(billingConf billing.Config, organizationService OrganizationService, checkoutService CheckoutService, customerService CustomerService, planService PlanService, userService UserService) *Processor
Source Files
Click to show internal directories.
Click to hide internal directories.