pubsub

Documentation

Index

• type Config
  • func (c Config) Validate() error
• type MoveCmd
  • func NewMoveCmd(ctx context.Context, config Config) (*MoveCmd, error)
  • func (cmd *MoveCmd) Execute(ctx context.Context) error
  • func (cmd *MoveCmd) StopExecution() error

Types

type Config

type Config struct {
	Topic                 string
	Subscription          string
	TopicProjectID        string
	SubscriptionProjectID string
}

func (Config) Validate

func (c Config) Validate() error

type MoveCmd

type MoveCmd struct {
	Config
	// contains filtered or unexported fields
}

func NewMoveCmd

func NewMoveCmd(ctx context.Context, config Config) (*MoveCmd, error)

func (*MoveCmd) Execute

func (cmd *MoveCmd) Execute(ctx context.Context) error

func (*MoveCmd) StopExecution

func (cmd *MoveCmd) StopExecution() error