model

Documentation

Index

• func FetchRecords(cl *kgo.Client, numRecords int) tea.Cmd
• func InitialModel(kCl *kgo.Client, deserFmt DeserializationFmt) model
• func RightPadTrim(s string, length int) string
• func Trim(s string, length int) string
• type DeserializationFmt
• type KMsgChosenMsg
• type KMsgFetchedMsg
• type KMsgItem
  • func (item KMsgItem) Description() string
  • func (item KMsgItem) FilterValue() string
  • func (item KMsgItem) Title() string
• type KMsgMetadataReadyMsg
• type KMsgValueReadyMsg
• type RecordSavedToDiskMsg

Functions

func FetchRecords

func FetchRecords(cl *kgo.Client, numRecords int) tea.Cmd

func InitialModel

func InitialModel(kCl *kgo.Client, deserFmt DeserializationFmt) model

func RightPadTrim

func RightPadTrim(s string, length int) string

func Trim

func Trim(s string, length int) string

Types

type DeserializationFmt

type DeserializationFmt uint

const (
	JsonFmt DeserializationFmt = iota
	ProtobufFmt
)

type KMsgChosenMsg

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

type KMsgFetchedMsg

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

type KMsg struct{
    Offset int64
    Key []byte
    Value []byte
    Header []byte

}

type KMsgItem

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

func (KMsgItem) Description

func (item KMsgItem) Description() string

func (KMsgItem) FilterValue

func (item KMsgItem) FilterValue() string

func (KMsgItem) Title

func (item KMsgItem) Title() string

type KMsgMetadataReadyMsg

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

type KMsgValueReadyMsg

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

type RecordSavedToDiskMsg

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