cli

Documentation

Index

• type Backend
• type BackendConfig
  • func (c BackendConfig) Validate() error
• type BackendConstructor
• type Dialog
• type DialogResult
• type Message
  • func NewMessage(id string, uuid string, payload string, metadata map[string]string) (Message, error)
• type MessagesUpdated
• type Model
  • func NewModel(backend Backend) Model
  • func (m Model) FetchMessages() tea.Cmd
  • func (m Model) Init() tea.Cmd
  • func (m Model) Update(msg tea.Msg) (tea.Model, tea.Cmd)
  • func (m Model) View() string
  • func (m Model) WaitForMessages() tea.Cmd

Types

type Backend

type Backend interface {
	AllMessages(ctx context.Context) ([]Message, error)
	Requeue(ctx context.Context, msg Message) error
	Ack(ctx context.Context, msg Message) error
}

type BackendConfig

type BackendConfig struct {
	Topic    string
	RawTopic string
}

func (BackendConfig) Validate

func (c BackendConfig) Validate() error

type BackendConstructor

type BackendConstructor func(ctx context.Context, cfg BackendConfig) (Backend, error)

type Dialog

type Dialog struct {
	Prompt  string
	Action  func() tea.Msg
	Choice  int
	Running bool
}

type DialogResult

type DialogResult struct {
	Err error
}

type Message

type Message struct {
	// ID is a unique message ID across the Pub/Sub's topic.
	ID       string
	UUID     string
	Payload  string
	Metadata map[string]string

	OriginalTopic string
	DelayedUntil  string
	DelayedFor    string
	RequeueIn     time.Duration
}

func NewMessage

func NewMessage(id string, uuid string, payload string, metadata map[string]string) (Message, error)

type MessagesUpdated

type MessagesUpdated struct {
	Messages []Message
}

type Model

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

func NewModel

func NewModel(backend Backend) Model

func (Model) FetchMessages

func (m Model) FetchMessages() tea.Cmd

func (Model) Init

func (m Model) Init() tea.Cmd

func (Model) Update

func (m Model) Update(msg tea.Msg) (tea.Model, tea.Cmd)

func (Model) View

func (m Model) View() string

func (Model) WaitForMessages

func (m Model) WaitForMessages() tea.Cmd