kafui

Apr 18, 2024

Changes in this version

+ type ResouceTopic struct

+ LastFetchedTopics map[string]api.Topic

+ func NewResouceTopic(dataSource api.KafkaDataSource, onError func(err error), recoverFunc func()) *ResouceTopic

+ func (r *ResouceTopic) FetchTopics(dataSource api.KafkaDataSource) map[string]api.Topic

+ func (r *ResouceTopic) ShowTopicsInTable(table *tview.Table, topics map[string]api.Topic, search string)

+ func (r *ResouceTopic) StartFetchingData()

+ func (r *ResouceTopic) StopFetching()

+ func (r *ResouceTopic) UpdateTable(table *tview.Table, dataSource api.KafkaDataSource, search string)

+ func (r *ResouceTopic) UpdateTableDataRoutine(ctx context.Context, dataSource api.KafkaDataSource)

+ func (r ResouceTopic) GetName() string

+ type Resource interface

+ GetName func() string

+ StartFetchingData func()

+ StopFetching func()

+ UpdateTable func(table *tview.Table, dataSource api.KafkaDataSource, search string)

+ type ResourceContext struct

+ FetchedContexts map[string]string

+ Name string

+ func NewResourceContext(dataSource api.KafkaDataSource, onError func(err error), recoverFunc func()) *ResourceContext

+ func (c *ResourceContext) FetchContextRoutine(ctx context.Context, dataSource api.KafkaDataSource)

+ func (r *ResourceContext) StartFetchingData()

+ func (r *ResourceContext) StopFetching()

+ func (r *ResourceContext) UpdateTable(table *tview.Table, dataSource api.KafkaDataSource, search string)

+ func (r ResourceContext) GetName() string

+ func (r ResourceContext) ShowContextsInTable(table *tview.Table, contexts map[string]string, search string)

+ func (rc *ResourceContext) FetchContexts(dataSource api.KafkaDataSource) []string

+ type ResourceGroup struct

+ FetchedConsumerGroups map[string]api.ConsumerGroup

+ func NewResourceGroup(onError func(err error), dataSource api.KafkaDataSource, recoverFunc func()) *ResourceGroup

+ func (g *ResourceGroup) FetchConsumerGroups(dataSource api.KafkaDataSource) []api.ConsumerGroup

+ func (g *ResourceGroup) FetchGroupsRoutine(ctx context.Context, dataSource api.KafkaDataSource)

+ func (r *ResourceGroup) StartFetchingData()

+ func (r *ResourceGroup) StopFetching()

+ func (r *ResourceGroup) UpdateTable(table *tview.Table, dataSource api.KafkaDataSource, search string)

+ func (r ResourceGroup) GetName() string

+ func (r ResourceGroup) ShowConsumerGroups(table *tview.Table, cgs map[string]api.ConsumerGroup, search string)

Apr 5, 2024

Changes in this version

type MainPage

+ FetchedConsumerGroups map[string]api.ConsumerGroup

+ FetchedContexts map[string]string

+ func (m *MainPage) UpdateTableDataRoutine(app *tview.Application, dataSource api.KafkaDataSource)

Apr 4, 2024

Changes in this version

+ func RecoverAndExit(app *tview.Application)

+ type MainPage struct

+ ContextInfo *tview.InputField

+ CurrentContextName string

+ CurrentResource string

+ CurrentSearchString string

+ LastFetchedTopics map[string]api.Topic

+ MidFlex *tview.Flex

+ NotificationTextView *tview.TextView

+ SearchBar SearchBar

+ func NewMainPage() *MainPage

+ func (m *MainPage) CreateMainPage(dataSource api.KafkaDataSource, pages *tview.Pages, app *tview.Application, ...) *tview.Flex

+ func (m *MainPage) CurrentTimeString() string

+ func (m *MainPage) FetchConsumerGroups(dataSource api.KafkaDataSource) []api.ConsumerGroup

+ func (m *MainPage) FetchContexts(dataSource api.KafkaDataSource) []string

+ func (m *MainPage) FetchTopics(dataSource api.KafkaDataSource) map[string]api.Topic

+ func (m *MainPage) SetupTableInput(table *tview.Table, app *tview.Application, pages *tview.Pages, ...)

+ func (m *MainPage) ShowConsumerGroups(table *tview.Table, cgs []api.ConsumerGroup)

+ func (m *MainPage) ShowContextsInTable(table *tview.Table, contexts []string)

+ func (m *MainPage) ShowNotification(message string)

+ func (m *MainPage) ShowTopicsInTable(table *tview.Table, topics map[string]api.Topic)

+ func (m *MainPage) UpdateMidFlexTitle(currentResouce string, amount int)

+ func (m *MainPage) UpdateTable(table *tview.Table, dataSource api.KafkaDataSource)

+ func (m *MainPage) UpdateTableRoutine(app *tview.Application, table *tview.Table, timerView *tview.TextView, ...)

+ type SearchBar struct

+ App *tview.Application

+ CurrentMode SearchMode

+ CurrentResource string

+ CurrentString string

+ DataSource api.KafkaDataSource

+ DefaultLabel string

+ Modal *tview.Modal

+ Pages *tview.Pages

+ SearchInput *tview.InputField

+ Table *tview.Table

+ UpdateTable func(resourceName string, searchText string)

+ func NewSearchBar(table *tview.Table, dataSource api.KafkaDataSource, pages *tview.Pages, ...) *SearchBar

+ func (s *SearchBar) CreateSearchInput(msgChannel chan UIEvent) *tview.InputField

+ func (s *SearchBar) ReceivingMessage(app *tview.Application, table *tview.Table, searchInput *tview.InputField, ...)

Mar 24, 2024

Changes in this version

+ func CloseTopicPage()

Mar 20, 2024

Changes in this version

+ func PageConsumeTopic(app *tview.Application, dataSource api.KafkaDataSource)

Mar 17, 2024

Changes in this version

+ func CreateTopicPage(dataSource api.KafkaDataSource, pages *tview.Pages, app *tview.Application, ...) *tview.Flex

+ func ReportConsumption(message string, textView *tview.TextView)

Apr 1, 2024

Changes in this version

+ func Contains[T comparable](s []T, e T) bool

+ func CopySelectedRowToClipboard(table *tview.Table, ConsumeMessage func(message string))

+ func CreateMainInputLegend() *tview.Flex

+ func CreateMainPage(dataSource api.KafkaDataSource, pages *tview.Pages, app *tview.Application, ...) *tview.Flex

+ func CreatePropertyInfo(propertyName string, propertyValue string) *tview.InputField

+ func CreateRunInfo(runeName string, info string) *tview.InputField

+ func CreateSearchInput(table *tview.Table, dataSource api.KafkaDataSource, pages *tview.Pages, ...) *tview.InputField

+ func Init(useMock bool)

+ func OpenUI(dataSource api.KafkaDataSource)

+ func SetupTableInput(table *tview.Table, app *tview.Application, pages *tview.Pages, ...)

+ func ShowNotification(message string)

+ func UpdateTable(table *tview.Table, dataSource api.KafkaDataSource)

+ type ByOffsetThenPartition []api.Message

+ func (a ByOffsetThenPartition) Len() int

+ func (a ByOffsetThenPartition) Less(i, j int) bool

+ func (a ByOffsetThenPartition) Swap(i, j int)

+ type DetailPage struct

+ func NewDetailPage(app *tview.Application, pages *tview.Pages, value string) *DetailPage

+ func (vp *DetailPage) CreateInputLegend() *tview.Flex

+ func (vp *DetailPage) Hide()

+ func (vp *DetailPage) Show()

+ type ResouceName []string

+ var ConsumerGroup ResouceName = []string{ ... }

+ var Context ResouceName = []string{ ... }

+ var Topic ResouceName = []string{ ... }

+ type SearchMode string

+ const ResouceSearch

+ const TableSearch

+ type TopicPage struct

+ func NewTopicPage(dataSource api.KafkaDataSource, pages *tview.Pages, app *tview.Application, ...) *TopicPage

+ func (tp *TopicPage) CloseTopicPage()

+ func (tp *TopicPage) CreateConsumeFlagsSection() *tview.Flex

+ func (tp *TopicPage) CreateInputLegend() *tview.Flex

+ func (tp *TopicPage) CreateInputSearch(onDone func()) *tview.Flex

+ func (tp *TopicPage) CreateTopicInfoSection(topicName string, topicDetail api.Topic) *tview.Flex

+ func (tp *TopicPage) CreateTopicPage(currentTopic string) *tview.Flex

+ func (tp *TopicPage) PageConsumeTopic(topicName string, currentTopic api.Topic, flags api.ConsumeFlags)

+ func (tp *TopicPage) RestartConsumer()

+ func (tp *TopicPage) ShowNotification(message string)

+ type UIEvent string

+ const OnFocusSearch

+ const OnModalClose

+ const OnPageChange

+ const OnStartTableSearch