transformation

Documentation

Index

• func EventFromAttempt(att *entities.Attempt) (*streaming.Event, error)
• func EventFromAttemptTask(task *entities.AttemptTask) (*streaming.Event, error)
• func EventFromAttemptTrigger(task *entities.AttemptTrigger) (*streaming.Event, error)
• func EventFromMessage(msg *entities.Message) (*streaming.Event, error)
• func EventFromRecoveryTask(task *entities.RecoveryTask) (*streaming.Event, error)
• func EventFromRequest(req *entities.Request) (*streaming.Event, error)
• func EventFromResponse(res *entities.Response) (*streaming.Event, error)
• func EventToAttempt(event *streaming.Event) (*entities.Attempt, error)
• func EventToAttemptTask(event *streaming.Event) (*entities.AttemptTask, error)
• func EventToAttemptTrigger(event *streaming.Event) (*entities.AttemptTrigger, error)
• func EventToMessage(event *streaming.Event) (*entities.Message, error)
• func EventToRecoveryTask(event *streaming.Event) (*entities.RecoveryTask, error)
• func EventToRequest(event *streaming.Event) (*entities.Request, error)
• func EventToResponse(event *streaming.Event) (*entities.Response, error)

Functions

func EventFromAttempt

func EventFromAttempt(att *entities.Attempt) (*streaming.Event, error)

func EventFromAttemptTask

func EventFromAttemptTask(task *entities.AttemptTask) (*streaming.Event, error)

func EventFromAttemptTrigger

func EventFromAttemptTrigger(task *entities.AttemptTrigger) (*streaming.Event, error)

func EventFromMessage

func EventFromMessage(msg *entities.Message) (*streaming.Event, error)

func EventFromRecoveryTask

func EventFromRecoveryTask(task *entities.RecoveryTask) (*streaming.Event, error)

func EventFromRequest

func EventFromRequest(req *entities.Request) (*streaming.Event, error)

func EventFromResponse

func EventFromResponse(res *entities.Response) (*streaming.Event, error)

func EventToAttempt

func EventToAttempt(event *streaming.Event) (*entities.Attempt, error)

func EventToAttemptTask

func EventToAttemptTask(event *streaming.Event) (*entities.AttemptTask, error)

func EventToAttemptTrigger

func EventToAttemptTrigger(event *streaming.Event) (*entities.AttemptTrigger, error)

func EventToMessage

func EventToMessage(event *streaming.Event) (*entities.Message, error)

func EventToRecoveryTask

func EventToRecoveryTask(event *streaming.Event) (*entities.RecoveryTask, error)

func EventToRequest

func EventToRequest(event *streaming.Event) (*entities.Request, error)

func EventToResponse

func EventToResponse(event *streaming.Event) (*entities.Response, error)