execute

Feb 26, 2024

Changes in this version

type Conversation

+ ParentActivityID string

Nov 20, 2023

Changes in this version

type CommandContext

+ AuditContext map[string]interface{}

type Conversation

+ Text string

+ URL string

type NewDefaultInput

+ AuditContext map[string]interface{}

Oct 9, 2023

Changes in this version

type CommandContext

+ PluginHealthStats *plugin.HealthStats

type DefaultExecutorFactoryParams

+ PluginHealthStats *plugin.HealthStats

Jul 17, 2023

Changes in this version

type CommandContext

+ CmdHeader string

type Flags

+ CmdHeader string

May 12, 2023

Changes in this version

type Conversation

+ IsKnown bool

Apr 3, 2023

Changes in this version

+ func GetInstallHelpForKnownPlugin(args []string) (string, bool)

+ type ActionsStorage interface

+ PersistActionEnabled func(ctx context.Context, name string, enabled bool) error

type Conversation

+ DisplayName string

+ SlackState *slack.BlockActionStates

type DefaultExecutorFactoryParams

+ AuditReporter audit.AuditReporter

+ RestCfg *rest.Config

+ type NotificationsStorage interface

+ PersistNotificationsEnabled func(ctx context.Context, commGroupName string, ...) error

+ type UserInput struct

+ DisplayName string

+ Mention string

Feb 6, 2023

Changes in this version

+ type AliasExecutor struct

+ func NewAliasExecutor(log logrus.FieldLogger, analyticsReporter AnalyticsReporter, cfg config.Config) *AliasExecutor

+ func (e *AliasExecutor) Commands() map[command.Verb]CommandFn

+ func (e *AliasExecutor) FeatureName() FeatureName

+ func (e *AliasExecutor) List(_ context.Context, cmdCtx CommandContext) (interactive.Message, error)

type CommandContext

+ ExpandedRawCmd string

type DefaultExecutor

+ func (e *DefaultExecutor) ExecuteHelp(ctx context.Context, cmdCtx CommandContext) interactive.Message

type PluginExecutor

+ func (e *PluginExecutor) Help(ctx context.Context, bindings []string, args []string, command string) (interactive.Message, error)

Jan 9, 2023

Changes in this version

+ const KubectlBinary

type ActionExecutor

+ func (e *ActionExecutor) Commands() map[CommandVerb]CommandFn

+ func (e *ActionExecutor) Disable(ctx context.Context, cmdCtx CommandContext) (interactive.Message, error)

+ func (e *ActionExecutor) Enable(ctx context.Context, cmdCtx CommandContext) (interactive.Message, error)

+ func (e *ActionExecutor) FeatureName() FeatureName

+ func (e *ActionExecutor) List(ctx context.Context, cmdCtx CommandContext) (interactive.Message, error)

+ type CommandContext struct

+ Args []string

+ BotName string

+ CleanCmd string

+ ClusterName string

+ CommGroupName string

+ Conversation Conversation

+ ExecutorFilter executorFilter

+ Mapping *CommandMapping

+ NotifierHandler NotifierHandler

+ Platform config.CommPlatformIntegration

+ ProvidedClusterName string

+ RawCmd string

+ User string

+ func (cmdCtx CommandContext) ProvidedClusterNameEqual() bool

+ func (cmdCtx CommandContext) ProvidedClusterNameEqualOrEmpty() bool

+ type CommandExecutor interface

+ Commands func() map[CommandVerb]CommandFn

+ FeatureName func() FeatureName

+ type CommandFn func(ctx context.Context, cmdCtx CommandContext) (interactive.Message, error)

+ type CommandMapping struct

+ func NewCmdsMapping(executors []CommandExecutor) (*CommandMapping, error)

+ func (m *CommandMapping) FindFn(verb CommandVerb, feature string) (CommandFn, bool, bool)

+ func (m *CommandMapping) HelpMessageForVerb(verb CommandVerb, botName string) string

type CommandVerb

+ const CommandEdit

+ const CommandFeedback

+ const CommandHelp

+ const CommandPing

+ const CommandShow

+ const CommandStatus

+ const CommandVersion

+ type ConfigExecutor struct

+ func NewConfigExecutor(log logrus.FieldLogger, analyticsReporter AnalyticsReporter, ...) *ConfigExecutor

+ func (e *ConfigExecutor) Commands() map[CommandVerb]CommandFn

+ func (e *ConfigExecutor) FeatureName() FeatureName

+ func (e *ConfigExecutor) Show(ctx context.Context, cmdCtx CommandContext) (interactive.Message, error)

type Conversation

+ SourceBindings []string

type DefaultExecutorFactoryParams

+ BotKubeVersion string

+ PluginManager *plugin.Manager

+ type ExecExecutor struct

+ func NewExecExecutor(log logrus.FieldLogger, analyticsReporter AnalyticsReporter, cfg config.Config) *ExecExecutor

+ func (e *ExecExecutor) Commands() map[CommandVerb]CommandFn

+ func (e *ExecExecutor) FeatureName() FeatureName

+ func (e *ExecExecutor) List(ctx context.Context, cmdCtx CommandContext) (interactive.Message, error)

+ func (e *ExecExecutor) TabularOutput(bindings []string) string

+ type FeatureName struct

+ Aliases []string

+ Name string

+ type FeedbackExecutor struct

+ func NewFeedbackExecutor(log logrus.FieldLogger, analyticsReporter AnalyticsReporter) *FeedbackExecutor

+ func (e *FeedbackExecutor) Commands() map[CommandVerb]CommandFn

+ func (e *FeedbackExecutor) FeatureName() FeatureName

+ func (e *FeedbackExecutor) Feedback(ctx context.Context, cmdCtx CommandContext) (interactive.Message, error)

+ type FilterExecutor struct

+ func NewFilterExecutor(log logrus.FieldLogger, analyticsReporter AnalyticsReporter, ...) *FilterExecutor

+ func (e *FilterExecutor) Commands() map[CommandVerb]CommandFn

+ func (e *FilterExecutor) Disable(ctx context.Context, cmdCtx CommandContext) (interactive.Message, error)

+ func (e *FilterExecutor) Enable(ctx context.Context, cmdCtx CommandContext) (interactive.Message, error)

+ func (e *FilterExecutor) FeatureName() FeatureName

+ func (e *FilterExecutor) List(ctx context.Context, cmdCtx CommandContext) (interactive.Message, error)

+ func (e *FilterExecutor) TabularOutput() string

+ type Flags struct

+ CleanCmd string

+ ClusterName string

+ Filter string

+ TokenizedCmd []string

+ func ParseFlags(cmd string) (Flags, error)

+ type HelpExecutor struct

+ func NewHelpExecutor(log logrus.FieldLogger, analyticsReporter AnalyticsReporter, cfg config.Config) *HelpExecutor

+ func (e *HelpExecutor) Commands() map[CommandVerb]CommandFn

+ func (e *HelpExecutor) FeatureName() FeatureName

+ func (e *HelpExecutor) Help(_ context.Context, cmdCtx CommandContext) (interactive.Message, error)

type NotifierExecutor

+ func (e *NotifierExecutor) Commands() map[CommandVerb]CommandFn

+ func (e *NotifierExecutor) Disable(ctx context.Context, cmdCtx CommandContext) (interactive.Message, error)

+ func (e *NotifierExecutor) Enable(ctx context.Context, cmdCtx CommandContext) (interactive.Message, error)

+ func (e *NotifierExecutor) FeatureName() FeatureName

+ func (e *NotifierExecutor) Status(ctx context.Context, cmdCtx CommandContext) (interactive.Message, error)

+ type PingExecutor struct

+ func NewPingExecutor(log logrus.FieldLogger, analyticsReporter AnalyticsReporter, ...) *PingExecutor

+ func (e *PingExecutor) Commands() map[CommandVerb]CommandFn

+ func (e *PingExecutor) FeatureName() FeatureName

+ func (e *PingExecutor) Ping(ctx context.Context, cmdCtx CommandContext) (interactive.Message, error)

+ type PluginExecutor struct

+ func NewPluginExecutor(log logrus.FieldLogger, cfg config.Config, manager *plugin.Manager) *PluginExecutor

+ func (e *PluginExecutor) CanHandle(bindings []string, args []string) bool

+ func (e *PluginExecutor) Execute(ctx context.Context, bindings []string, args []string, command string) (string, error)

+ func (e *PluginExecutor) GetCommandPrefix(args []string) string

+ type SourceBindingExecutor struct

+ func NewSourceBindingExecutor(log logrus.FieldLogger, analyticsReporter AnalyticsReporter, ...) *SourceBindingExecutor

+ func (e *SourceBindingExecutor) Commands() map[CommandVerb]CommandFn

+ func (e *SourceBindingExecutor) Edit(_ context.Context, cmdCtx CommandContext) (interactive.Message, error)

+ func (e *SourceBindingExecutor) FeatureName() FeatureName

+ func (e *SourceBindingExecutor) Status(_ context.Context, cmdCtx CommandContext) (interactive.Message, error)

+ type SourceExecutor struct

+ func NewSourceExecutor(log logrus.FieldLogger, analyticsReporter AnalyticsReporter, cfg config.Config) *SourceExecutor

+ func (e *SourceExecutor) Commands() map[CommandVerb]CommandFn

+ func (e *SourceExecutor) FeatureName() FeatureName

+ func (e *SourceExecutor) List(ctx context.Context, cmdCtx CommandContext) (interactive.Message, error)

+ func (e *SourceExecutor) TabularOutput(bindings []string) string

+ type VersionExecutor struct

+ func NewVersionExecutor(log logrus.FieldLogger, analyticsReporter AnalyticsReporter, ...) *VersionExecutor

+ func (e *VersionExecutor) Commands() map[CommandVerb]CommandFn

+ func (e *VersionExecutor) FeatureName() FeatureName

+ func (e *VersionExecutor) Version(ctx context.Context, cmdCtx CommandContext) (interactive.Message, error)

Nov 28, 2022

Changes in this version

+ type ActionExecutor struct

+ func NewActionExecutor(log logrus.FieldLogger, analyticsReporter AnalyticsReporter, ...) *ActionExecutor

+ func (a *ActionExecutor) ActionsTabularOutput() string

+ func (a *ActionExecutor) Do(ctx context.Context, args []string, clusterName string, ...) (string, error)

+ type CommandVerb string

+ const CommandDisable

+ const CommandEnable

+ const CommandList

type ConfigPersistenceManager

+ PersistActionEnabled func(ctx context.Context, name string, enabled bool) error

Oct 24, 2022

Changes in this version

+ func EmptyResourceNameDropdown() *interactive.Select

+ func FilterSection(botName string) interactive.LabelInput

+ func InternalErrorSection() interactive.Section

+ func IsExecutionCommandError(err error) bool

+ func KubectlCmdBuilderMessage(dropdownsBlockID string, verbs interactive.Select, ...) interactive.Message

+ func PreviewSection(botName, cmd string, input interactive.LabelInput) []interactive.Section

+ func ResourceNamesSelect(botName string, names []string, initialItem string) *interactive.Select

+ func ResourceNamespaceSelect(botName string, names []dropdownItem, initialNamespace dropdownItem) *interactive.Select

+ func ResourceTypeSelect(botName string, resources []string, initialItem string) *interactive.Select

+ func VerbSelect(botName string, verbs []string, initialItem string) *interactive.Select

+ type CommandGuard interface

+ FilterSupportedVerbs func(allVerbs []string) []string

+ GetAllowedResourcesForVerb func(verb string, allConfiguredResources []string) ([]kubectl.Resource, error)

+ GetResourceDetails func(verb, resourceType string) (kubectl.Resource, error)

type Conversation

+ CommandOrigin command.Origin

+ State *slack.BlockActionStates

type DefaultExecutorFactoryParams

+ CommandGuard CommandGuard

+ NamespaceLister NamespaceLister

+ type ExecutionCommandError struct

+ func NewExecutionCommandError(format string, args ...any) *ExecutionCommandError

+ func (e *ExecutionCommandError) Error() string

+ type KubectlCmdBuilder struct

+ func NewKubectlCmdBuilder(log logrus.FieldLogger, merger kcMerger, executor kcExecutor, ...) *KubectlCmdBuilder

+ func (e *KubectlCmdBuilder) CanHandle(args []string) bool

+ func (e *KubectlCmdBuilder) Do(ctx context.Context, args []string, platform config.CommPlatformIntegration, ...) (interactive.Message, error)

+ func (e *KubectlCmdBuilder) GetCommandPrefix(args []string) string

+ type KubectlCmdBuilderOption func(options *KubectlCmdBuilderOptions)

+ func WithAdditionalSections(in ...interactive.Section) KubectlCmdBuilderOption

+ func WithAdditionalSelects(in ...*interactive.Select) KubectlCmdBuilderOption

+ type KubectlCmdBuilderOptions struct

+ type NamespaceLister interface

+ List func(ctx context.Context, opts metav1.ListOptions) (*corev1.NamespaceList, error)

Oct 3, 2022

Changes in this version

+ type BindingsStorage interface

+ PersistSourceBindings func(ctx context.Context, commGroupName string, ...) error

+ type ConfigPersistenceManager interface

+ PersistFilterEnabled func(ctx context.Context, name string, enabled bool) error

+ PersistNotificationsEnabled func(ctx context.Context, commGroupName string, ...) error

+ PersistSourceBindings func(ctx context.Context, commGroupName string, ...) error

+ type Conversation struct

+ Alias string

+ ExecutorBindings []string

+ ID string

+ IsAuthenticated bool

+ IsButtonClickOrigin bool

+ type DefaultExecutorFactoryParams struct

+ AnalyticsReporter AnalyticsReporter

+ Cfg config.Config

+ CfgManager ConfigPersistenceManager

+ CmdRunner CommandRunner

+ FilterEngine filterengine.FilterEngine

+ KcChecker *kubectl.Checker

+ Log logrus.FieldLogger

+ Merger *kubectl.Merger

+ type EditExecutor struct

+ func NewEditExecutor(log logrus.FieldLogger, analyticsReporter AnalyticsReporter, ...) *EditExecutor

+ func (e *EditExecutor) Do(args []string, commGroupName string, platform config.CommPlatformIntegration, ...) (interactive.Message, error)

+ type EditResource string

+ const SourceBindings

+ func (e EditResource) Key() string

type Kubectl

+ func (e *Kubectl) GetCommandPrefix(args []string) string

+ func (e *Kubectl) GetVerb(args []string) string

+ type NewDefaultInput struct

+ CommGroupName string

+ Conversation Conversation

+ Message string

+ NotifierHandler NotifierHandler

+ Platform config.CommPlatformIntegration

+ User string

type NotifierHandler

+ BotName func() string

Aug 29, 2022

Changes in this version

+ const WrongClusterCmdMsg

+ var ErrNotificationsNotConfigured = errors.New("notifications not configured for this channel")

+ type AnalyticsReporter interface

+ ReportCommand func(platform config.CommPlatformIntegration, command string) error

+ type CommandCombinedOutputRunner interface

+ RunCombinedOutput func(command string, args []string) (string, error)

+ type CommandRunner interface

+ type CommandSeparateOutputRunner interface

+ RunSeparateOutput func(command string, args []string) (string, string, error)

+ type DefaultExecutorFactory struct

+ func NewExecutorFactory(log logrus.FieldLogger, cmdRunner CommandRunner, cfg config.Config, ...) *DefaultExecutorFactory

+ func (f *DefaultExecutorFactory) NewDefault(platform config.CommPlatformIntegration, notifierHandler NotifierHandler, ...) Executor

+ type Kubectl struct

+ func NewKubectl(log logrus.FieldLogger, cfg config.Config, merger *kubectl.Merger, ...) *Kubectl

+ func (e *Kubectl) CanHandle(bindings []string, args []string) bool

+ func (e *Kubectl) Execute(bindings []string, command string, isAuthChannel bool) (string, error)

+ type NotifierExecutor struct

+ func NewNotifierExecutor(log logrus.FieldLogger, cfg config.Config, analyticsReporter AnalyticsReporter) *NotifierExecutor

+ func (e *NotifierExecutor) CanHandle(args []string) bool

+ func (e *NotifierExecutor) Do(args []string, platform config.CommPlatformIntegration, conversationID string, ...) (string, error)

+ type NotifierHandler interface

+ NotificationsEnabled func(conversationID string) bool

+ SetNotificationsEnabled func(conversationID string, enabled bool) error

+ type OSCommand struct

+ func (*OSCommand) RunCombinedOutput(command string, args []string) (string, error)

+ func (*OSCommand) RunSeparateOutput(command string, args []string) (string, string, error)

Jul 9, 2019

Changes in this version

+ type FiltersAction string

+ const FilterDisable

+ const FilterEnable

+ const FilterList

+ func (action FiltersAction) String() string

Feb 28, 2019

Changes in this version

+ type CommandFlags string

+ const AbbrFollowFlag

+ const AbbrWatchFlag

+ const ClusterFlag

+ const FollowFlag

+ const WatchFlag

+ func (flag CommandFlags) String() string

type DefaultExecutor

+ ChannelName string

+ ClusterName string

+ IsAuthChannel bool

+ type NotifierAction string

+ const ShowConfig

+ const Start

+ const Status

+ const Stop

+ func (action NotifierAction) String() string

Jan 15, 2019

Changes in this version

type DefaultExecutor

+ AllowKubectl bool

Jan 11, 2019

Changes in this version

+ type DefaultExecutor struct

+ Message string

+ func (e *DefaultExecutor) Execute() string

+ type Executor interface

+ Execute func() string

+ func NewDefaultExecutor(msg string) Executor