resourcerun

Documentation

Index

• func AddSubscriber(n string, h func(context.Context, BusMessage) error) error
• func Notify(ctx context.Context, mc model.ClientSet, refer *model.ResourceRun) error
• type BusMessage

Functions

func AddSubscriber

func AddSubscriber(n string, h func(context.Context, BusMessage) error) error

AddSubscriber add the subscriber to handle the changed notification from model.ResourceRun.

func Notify

func Notify(ctx context.Context, mc model.ClientSet, refer *model.ResourceRun) error

Notify notifies the changed model.ResourceRun.

Types

type BusMessage

type BusMessage struct {
	// TransactionalModelClient holds the model.ClientSet of this calling session,
	// it should be a transactional DAO client,
	// please don't keep for long-term using.
	TransactionalModelClient model.ClientSet
	// Refer holds the updating model.ResourceRun item of this calling session.
	Refer *model.ResourceRun
}

BusMessage wraps the changed model.ResourceRun as a bus.Message.