pubsub

Documentation

Index

• type Client
  • func NewClient(ctx context.Context) (*Client, error)
• type PubSub
  • func New(cli *Client, ac model.ActionConfig) *PubSub
  • func (a *PubSub) List(_ context.Context) (model.ScheduleEvents, error)
  • func (a *PubSub) Register(_ context.Context, events ...model.ScheduleEvent) error
  • func (a *PubSub) Unregister(_ context.Context, events ...model.ScheduleEvent) error

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client represents cloud pubsub client.

func NewClient

func NewClient(ctx context.Context) (*Client, error)

NewClient returns cloud pubsub client.

type PubSub

type PubSub struct {
	// contains filtered or unexported fields
}

PubSub implements repository.Action for pubsub.

func New

func New(cli *Client, ac model.ActionConfig) *PubSub

New returns an action for cloud pubsub.

func (*PubSub) List

func (a *PubSub) List(_ context.Context) (model.ScheduleEvents, error)

List lists schedule events from cloud pubsub action scheduler.

func (*PubSub) Register

func (a *PubSub) Register(_ context.Context, events ...model.ScheduleEvent) error

Register registers schedule events to cloud pubsub action scheduler.

func (*PubSub) Unregister

func (a *PubSub) Unregister(_ context.Context, events ...model.ScheduleEvent) error

Unregister unregisters schedule events from cloud pubsub action scheduler.