cmd

Documentation

Index

• func Execute()
• func ParseInput(input string) (command string, params []string)
• func ResetSystemInfo[T any](m *dynamomq.Message[T], now time.Time)
• type CommandFactory
  • func (f CommandFactory) CreatReceiveCommand(flgs *Flags) *cobra.Command
  • func (f CommandFactory) CreateDLQCommand(flgs *Flags) *cobra.Command
  • func (f CommandFactory) CreateDeleteCommand(flgs *Flags) *cobra.Command
  • func (f CommandFactory) CreateEnqueueTestCommand(flgs *Flags) *cobra.Command
  • func (f CommandFactory) CreateFailCommand(flgs *Flags) *cobra.Command
  • func (f CommandFactory) CreateGetCommand(flgs *Flags) *cobra.Command
  • func (f CommandFactory) CreateInvalidCommand(flgs *Flags) *cobra.Command
  • func (f CommandFactory) CreateLSCommand(flgs *Flags) *cobra.Command
  • func (f CommandFactory) CreatePurgeCommand(flgs *Flags) *cobra.Command
  • func (f CommandFactory) CreateQueueStatCommand(flgs *Flags) *cobra.Command
  • func (f CommandFactory) CreateRedriveCommand(flgs *Flags) *cobra.Command
  • func (f CommandFactory) CreateResetCommand(flgs *Flags) *cobra.Command
  • func (f CommandFactory) CreateRootCommand(flgs *Flags) *cobra.Command
• type EnqueueTestResult
• type Failure
• type FlagMap
• type FlagSet
• type Flags
• type Interactive
  • func (c *Interactive) Run(ctx context.Context, command string, params []string) (err error)
  • func (c *Interactive) Start(in io.Reader) error
• type LSResult
• type PurgeResult
• type Status
• type SystemInfo
  • func GetSystemInfo[T any](m *dynamomq.Message[T]) *SystemInfo

Functions

func Execute

func Execute()

func ParseInput

func ParseInput(input string) (command string, params []string)

func ResetSystemInfo

func ResetSystemInfo[T any](m *dynamomq.Message[T], now time.Time)

Types

type CommandFactory

type CommandFactory struct {
	CreateDynamoMQClient func(ctx context.Context, flags *Flags) (dynamomq.Client[any], aws.Config, error)
	Stdin                io.Reader
}

func (CommandFactory) CreatReceiveCommand

func (f CommandFactory) CreatReceiveCommand(flgs *Flags) *cobra.Command

func (CommandFactory) CreateDLQCommand

func (f CommandFactory) CreateDLQCommand(flgs *Flags) *cobra.Command

func (CommandFactory) CreateDeleteCommand

func (f CommandFactory) CreateDeleteCommand(flgs *Flags) *cobra.Command

func (CommandFactory) CreateEnqueueTestCommand

func (f CommandFactory) CreateEnqueueTestCommand(flgs *Flags) *cobra.Command

func (CommandFactory) CreateFailCommand

func (f CommandFactory) CreateFailCommand(flgs *Flags) *cobra.Command

func (CommandFactory) CreateGetCommand

func (f CommandFactory) CreateGetCommand(flgs *Flags) *cobra.Command

func (CommandFactory) CreateInvalidCommand

func (f CommandFactory) CreateInvalidCommand(flgs *Flags) *cobra.Command

func (CommandFactory) CreateLSCommand

func (f CommandFactory) CreateLSCommand(flgs *Flags) *cobra.Command

func (CommandFactory) CreatePurgeCommand

func (f CommandFactory) CreatePurgeCommand(flgs *Flags) *cobra.Command

func (CommandFactory) CreateQueueStatCommand

func (f CommandFactory) CreateQueueStatCommand(flgs *Flags) *cobra.Command

func (CommandFactory) CreateRedriveCommand

func (f CommandFactory) CreateRedriveCommand(flgs *Flags) *cobra.Command

func (CommandFactory) CreateResetCommand

func (f CommandFactory) CreateResetCommand(flgs *Flags) *cobra.Command

func (CommandFactory) CreateRootCommand

func (f CommandFactory) CreateRootCommand(flgs *Flags) *cobra.Command

type EnqueueTestResult

type EnqueueTestResult struct {
	Successes []string `json:"successes"`
}

type Failure

type Failure struct {
	ID    string
	Error error
}

type FlagMap

type FlagMap struct {
	TableName   FlagSet[string]
	IndexName   FlagSet[string]
	EndpointURL FlagSet[string]
	ID          FlagSet[string]
}

type FlagSet

type FlagSet[T any] struct {
	Name  string
	Usage string
	Value T
}

type Flags

type Flags struct {
	TableName   string
	IndexName   string
	EndpointURL string

	ID string
}

type Interactive

type Interactive struct {
	Client  dynamomq.Client[any]
	Message *dynamomq.Message[any]
}

func (*Interactive) Run

func (c *Interactive) Run(ctx context.Context, command string, params []string) (err error)

func (*Interactive) Start

func (c *Interactive) Start(in io.Reader) error

type LSResult

type LSResult struct {
	Statuses []Status `json:"statuses"`
}

type PurgeResult

type PurgeResult struct {
	Successes []string  `json:"successes"`
	Failures  []Failure `json:"failures"`
}

type Status

type Status struct {
	ID        string             `json:"id"`
	Status    dynamomq.Status    `json:"status"`
	QueueType dynamomq.QueueType `json:"queue_type"`
}

type SystemInfo

type SystemInfo struct {
	ID               string             `json:"id"`
	Status           dynamomq.Status    `json:"status"`
	ReceiveCount     int                `json:"receive_count"`
	QueueType        dynamomq.QueueType `json:"queue_type"`
	Version          int                `json:"version"`
	CreatedAt        string             `json:"created_at"`
	UpdatedAt        string             `json:"updated_at"`
	SentAt           string             `json:"sent_at"`
	ReceivedAt       string             `json:"received_at"`
	InvisibleUntilAt string             `json:"invisible_until_at"`
}

func GetSystemInfo

func GetSystemInfo[T any](m *dynamomq.Message[T]) *SystemInfo