Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrParsingPayload = errors.New("could not parse task payload")
)
Functions ¶
This section is empty.
Types ¶
type TaskPayload ¶
type TaskPayload struct {
TenantID string
ClientData auth.ClientData
Data []byte
}
TaskPayload represents the payload for an async task, including tenant context.
func NewTaskPayload ¶
func NewTaskPayload(ctx context.Context, data []byte) TaskPayload
func ParseTaskPayload ¶
func ParseTaskPayload(payload []byte) (TaskPayload, error)
func (*TaskPayload) InjectContext ¶
func (p *TaskPayload) InjectContext(ctx context.Context) context.Context
func (*TaskPayload) ToBytes ¶
func (p *TaskPayload) ToBytes() ([]byte, error)
type TenantListPayload ¶
type TenantListPayload struct {
TenantIDs []string
}
TenantListPayload represents a payload containing a list of tenant IDs. Can be used to trigger multi-tenant tasks to process specific tenants.
func NewTenantListPayload ¶
func NewTenantListPayload(tenantIDs []string) TenantListPayload
func ParseTenantListPayload ¶
func ParseTenantListPayload(payload []byte) (TenantListPayload, error)
func (*TenantListPayload) ToBytes ¶
func (p *TenantListPayload) ToBytes() ([]byte, error)
Source Files
Click to show internal directories.
Click to hide internal directories.