Versions in this module Expand all Collapse all v4 v4.1.7 Jun 28, 2021 Changes in this version + const SchemaLatestVersion + var ACLOperations = map[ACLResourceType][]ACLOperation + var BuildVersion string + var DefaultConfigurationHomeDir = filepath.Join(HomeDir(), ".lenses") + var DefaultContextKey = "master" + var DefaultQuotaConfigPropertiesToRemove = []string + var ErrCredentialsMissing = fmt.Errorf("credentials missing or invalid") + var ErrUnknownResponse = fmt.Errorf("unknown") + var ValidCompatibilityLevels = []CompatibilityLevel + func ClientConfigMarshalJSON(c ClientConfig) ([]byte, error) + func ClientConfigMarshalYAML(c ClientConfig) ([]byte, error) + func ClientConfigUnmarshalJSON(b []byte, c *ClientConfig) error + func ConfigMarshalJSON(c Config) ([]byte, error) + func ConfigMarshalYAML(c Config) ([]byte, error) + func ConfigUnmarshalJSON(b []byte, c *Config) error + func ConfigUnmarshalYAML(b []byte, c *Config) error + func GetAvailableReplicas(esIndex Index) int + func HomeDir() (homeDir string) + func IsValidCompatibilityLevel(compatibility string) bool + func JSONAvroSchema(avroSchema string) (json.RawMessage, error) + func ReadConfig(r io.Reader, unmarshaler UnmarshalFunc, outPtr *Config) error + func ReadConfigFromFile(filename string, unmarshaler UnmarshalFunc, outPtr *Config) error + func ReadConfigFromJSON(filename string, outPtr *Config) error + func ReadConfigFromYAML(filename string, outPtr *Config) error + func TryReadConfigFromCurrentWorkingDir(outPtr *Config) bool + func TryReadConfigFromExecutable(outPtr *Config) bool + func TryReadConfigFromFile(filename string, outPtr *Config) (err error) + func TryReadConfigFromHome(outPtr *Config) bool + type ACL struct + Host string + Operation ACLOperation + PatternType string + PermissionType ACLPermissionType + Principal string + ResourceName string + ResourceType ACLResourceType + func (acl *ACL) Validate() error + type ACLOperation string + const ACLOperationAll + const ACLOperationAlter + const ACLOperationAlterConfigs + const ACLOperationAny + const ACLOperationClusterAction + const ACLOperationCreate + const ACLOperationDelete + const ACLOperationDescribe + const ACLOperationDescribeConfigs + const ACLOperationIdempotentWrite + const ACLOperationRead + const ACLOperationWrite + type ACLPermissionType string + const ACLPermissionAllow + const ACLPermissionDeny + type ACLResourceType string + const ACLResourceAny + const ACLResourceCluster + const ACLResourceDelegationToken + const ACLResourceGroup + const ACLResourceTopic + const ACLResourceTransactionalID + type Alert struct + AlertID int + Category string + Docs string + Instance string + Map map[string]interface{} + Severity string + Source string + Summary string + type AlertConditionDetails struct + Channels []Channel + ConditionDsl map[string]interface{} + CreatedAt string + CreatedBy string + ModifiedAt string + ModifiedBy string + type AlertConditionDsl struct + Group string + Threshold int + Topic string + type AlertConditionRequestv1 struct + Channels []string + Condition DataProduced + type AlertResult struct + Alerts []Alert + PagesCount int + type AlertSetting struct + Category string + Channels []Channel + ConditionDetails map[string]AlertConditionDetails + ConditionRegex string + ConditionTemplate string + Conditions map[string]string + Description string + Docs string + Enabled bool + ID int + IsAvailable bool + type AlertSettingCondition struct + Channels []string + ConditionDsl map[string]interface{} + ID string + type AlertSettings struct + Categories AlertSettingsCategoryMap + type AlertSettingsCategoryMap struct + Apps []AlertSetting + Consumers []AlertSetting + Infrastructure []AlertSetting + Producers []AlertSetting + type AlertSettingsConditionPayload struct + AlertID string + Channels []string + Condition string + ConditionID string + type AlertSettingsPayload struct + AlertID string + Channels []string + Enable bool + type AuditEntry struct + Change AuditEntryChange + Content map[string]string + Timestamp int64 + Type AuditEntryType + UserID string + type AuditEntryChange string + const AuditEntryAdd + const AuditEntryInsert + const AuditEntryRemove + const AuditEntryUpdate + type AuditEntryHandler func(AuditEntry) error + type AuditEntryType string + const AuditEntryACL + const AuditEntryBrokerConfig + const AuditEntryConnector + const AuditEntryProcessor + const AuditEntryQuotas + const AuditEntrySchema + const AuditEntryTopic + const AuditEntryTopicData + type Authentication interface + Auth func(c *Client) error + type AuthenticationFunc func(*Client) error + func (auth AuthenticationFunc) Auth(c *Client) error + type BasicAuthentication struct + Password string + Username string + func (auth BasicAuthentication) Auth(c *Client) error + type BoxConfig struct + ConnectClusters []BoxConnectClusterConfigProperty + IP string + JMXPort FlexInt + KafkaBrokers string + KubernetesConfigFile string + KubernetesImageName string + KubernetesImageTag string + KubernetesServiceAccount string + LicenseFile string + Port int + RootPath string + SQLExecutionMode ExecutionMode + SchemaRegistryURLs []BoxURLConfigProperty + SecurityMode string + TopicsAlertsSettings string + TopicsAlertsStorage string + TopicsAudits string + TopicsCluster string + TopicsExternalMetrics string + TopicsExternalTopology string + TopicsLSQLStorage string + TopicsMetadata string + TopicsMetrics string + TopicsProcessors string + TopicsProfiles string + Version string + ZookeeperChroot string + ZookeeperHosts []BoxURLConfigProperty + type BoxConnectClusterConfigProperty struct + Configs string + Name string + Offsets string + Statuses string + URLs []BoxURLConfigProperty + type BoxURLConfigProperty struct + JMX string + URL string + type BrokerConfig struct + AdvertisedPort int + CompressionType CompressionType + LogCleanerThreads int + type Channel struct + ConnectionName string + CreatedAt string + CreatedBy string + ID string + Name string + Properties []KV + TemplateName string + TemplateVersion int + UpdatedAt string + UpdatedBy string + type ChannelPayload struct + ConnectionName string + Name string + Properties []KV + TemplateName string + type ChannelResponse struct + PagesAmount int + TotalCount int + Values []Channel + type ChannelResponseWithDetails struct + PagesAmount int + TotalCount int + Values []ChannelWithDetails + type ChannelTemplate struct + BuiltIn bool + Configuration []struct{ ... } + Enabled bool + ID int + Metadata struct{ ... } + Name string + SuitableConnections []struct{ ... } + TemplateVersion int + Version string + type ChannelWithDetails struct + ConnectionName string + CreatedAt string + CreatedBy string + ID string + Name string + Properties []KV + TemplateName string + TemplateVersion int + UpdatedAt string + UpdatedBy string + type Client struct + Config *ClientConfig + PersistentRequestModifier RequestOption + User User + func OpenConnection(cfg ClientConfig, options ...ConnectionOption) (*Client, error) + func (c *Client) CancelQuery(id int64) (bool, error) + func (c *Client) CloneGroup(currentName string, newName string) error + func (c *Client) CreateAlertSettingsCondition(alertID, condition string, channels []string) error + func (c *Client) CreateChannel(chnl ChannelPayload, channelPath string) error + func (c *Client) CreateConnection(connectionName string, templateName string, configString string, ...) (err error) + func (c *Client) CreateConnector(clusterName, name string, config ConnectorConfig) (connector Connector, err error) + func (c *Client) CreateGroup(group *Group) error + func (c *Client) CreateOrUpdateACL(acl ACL) error + func (c *Client) CreateOrUpdateQuotaForAllClients(config QuotaConfig) error + func (c *Client) CreateOrUpdateQuotaForAllUsers(config QuotaConfig) error + func (c *Client) CreateOrUpdateQuotaForClient(clientID string, config QuotaConfig) error + func (c *Client) CreateOrUpdateQuotaForUser(user string, config QuotaConfig) error + func (c *Client) CreateOrUpdateQuotaForUserAllClients(user string, config QuotaConfig) error + func (c *Client) CreateOrUpdateQuotaForUserClient(user, clientID string, config QuotaConfig) error + func (c *Client) CreateOrUpdateTopicMetadata(metadata TopicMetadata) error + func (c *Client) CreatePolicy(policy DataPolicyRequest) error + func (c *Client) CreateProcessor(name string, sql string, runners int, clusterName, namespace, pipeline string, ...) error + func (c *Client) CreateServiceAccount(serviceAccount *ServiceAccount) (token CreateSvcAccPayload, err error) + func (c *Client) CreateTopic(topicName string, replication, partitions int, configs KV) error + func (c *Client) CreateUser(user *UserMember) error + func (c *Client) CreateUserProfilePropertyValue(property, value string) error + func (c *Client) DeleteACL(acl ACL) error + func (c *Client) DeleteAlertEvents(timestamp int64) (err error) + func (c *Client) DeleteAlertSettingCondition(alertSettingID int, conditionUUID string) error + func (c *Client) DeleteAuditEntries(timestamp int64) (err error) + func (c *Client) DeleteChannel(path, channelID string) error + func (c *Client) DeleteConnection(connectionName string) (err error) + func (c *Client) DeleteConnector(clusterName, name string) error + func (c *Client) DeleteDynamicBrokerConfigs(brokerID int, configKeysToBeReseted ...string) error + func (c *Client) DeleteDynamicClusterConfigs(configKeysToBeReset ...string) error + func (c *Client) DeleteGroup(name string) error + func (c *Client) DeleteLatestSubjectVersion(subject string) (int, error) + func (c *Client) DeletePolicy(id string) error + func (c *Client) DeleteProcessor(processorNameOrID string) error + func (c *Client) DeleteQuotaForAllClients(propertiesToRemove ...string) error + func (c *Client) DeleteQuotaForAllUsers(propertiesToRemove ...string) error + func (c *Client) DeleteQuotaForClient(clientID string, propertiesToRemove ...string) error + func (c *Client) DeleteQuotaForUser(user string, propertiesToRemove ...string) error + func (c *Client) DeleteQuotaForUserAllClients(user string, propertiesToRemove ...string) error + func (c *Client) DeleteQuotaForUserClient(user, clientID string, propertiesToRemove ...string) error + func (c *Client) DeleteServiceAccount(name string) error + func (c *Client) DeleteSubject(subject string) (versions []int, err error) + func (c *Client) DeleteSubjectVersion(subject string, versionID int) (int, error) + func (c *Client) DeleteTopic(topicName string) error + func (c *Client) DeleteTopicMetadata(topicName string) error + func (c *Client) DeleteTopicRecords(topicName string, fromPartition int, toOffset int64) error + func (c *Client) DeleteUser(username string) error + func (c *Client) DeleteUserProfilePropertyValue(property, value string) error + func (c *Client) Do(method, path, contentType string, send []byte, options ...RequestOption) (*http.Response, error) + func (c *Client) EnableAlertSetting(id int, enable bool) error + func (c *Client) GetACLs() ([]ACL, error) + func (c *Client) GetAccessToken() string + func (c *Client) GetAlertChannelTemplates() (response []ChannelTemplate, err error) + func (c *Client) GetAlertSetting(id int) (setting AlertSetting, err error) + func (c *Client) GetAlertSettingConditions(id int) ([]AlertSettingCondition, error) + func (c *Client) GetAlertSettings() (AlertSettings, error) + func (c *Client) GetAlerts(pageSize int) (alerts []Alert, err error) + func (c *Client) GetAuditChannelTemplates() (response []ChannelTemplate, err error) + func (c *Client) GetAuditEntries() (entries []AuditEntry, err error) + func (c *Client) GetAuditEntriesLive(handler AuditEntryHandler) error + func (c *Client) GetAvailableTopicConfigKeys() ([]string, error) + func (c *Client) GetChannels(path string, page int, pageSize int, ...) (response ChannelResponse, err error) + func (c *Client) GetChannelsWithDetails(path string, page int, pageSize int, ...) (response ChannelResponseWithDetails, err error) + func (c *Client) GetConfig() (cfg BoxConfig, err error) + func (c *Client) GetConfigEntry(outPtr interface{}, keys ...string) error + func (c *Client) GetConnectClusters() (clusters []ConnectCluster, err error) + func (c *Client) GetConnection(name string) (response Connection, err error) + func (c *Client) GetConnectionTemplates() (response []ConnectionTemplate, err error) + func (c *Client) GetConnections() (response []ConnectionList, err error) + func (c *Client) GetConnector(clusterName, name string) (connector Connector, err error) + func (c *Client) GetConnectorConfig(clusterName, name string) (cfg ConnectorConfig, err error) + func (c *Client) GetConnectorPlugins(clusterName string) (cp []ConnectorPlugin, err error) + func (c *Client) GetConnectorStatus(clusterName, name string) (cs ConnectorStatus, err error) + func (c *Client) GetConnectorTaskStatus(clusterName, name string, taskID int) (cst ConnectorStatusTask, err error) + func (c *Client) GetConnectorTasks(clusterName, name string) (m []map[string]interface{}, err error) + func (c *Client) GetConnectors(clusterName string) (names []string, err error) + func (c *Client) GetDeploymentTargets() (DeploymentTargets, error) + func (c *Client) GetDynamicBrokerConfigs(brokerID int) (config BrokerConfig, err error) + func (c *Client) GetDynamicClusterConfigs() (configs BrokerConfig, err error) + func (c *Client) GetExecutionMode() (ExecutionMode, error) + func (c *Client) GetGlobalCompatibilityLevel() (level CompatibilityLevel, err error) + func (c *Client) GetGroup(name string) (group Group, err error) + func (c *Client) GetGroups() (groups []Group, err error) + func (c *Client) GetIndex(connectionName string, indexName string) (index Index, err error) + func (c *Client) GetIndexes(connectionName string, includeSystemIndexes bool) (indexes []Index, err error) + func (c *Client) GetLatestSchema(subject string) (Schema, error) + func (c *Client) GetLicenseInfo() (LicenseInfo, error) + func (c *Client) GetLogsInfo() ([]LogLine, error) + func (c *Client) GetLogsMetrics() ([]LogLine, error) + func (c *Client) GetPolicies() ([]DataPolicy, error) + func (c *Client) GetPolicy(id string) (DataPolicy, error) + func (c *Client) GetPolicyCategory() ([]string, error) + func (c *Client) GetPolicyImpacts() ([]DataImpactType, error) + func (c *Client) GetPolicyObfuscation() ([]DataObfuscationType, error) + func (c *Client) GetProcessor(processorID string) (ProcessorStream, error) + func (c *Client) GetProcessors() (ProcessorsResult, error) + func (c *Client) GetProcessorsLogs(clusterName, ns, podName string, follow bool, lines int, ...) error + func (c *Client) GetQuotas() ([]Quota, error) + func (c *Client) GetRunningQueries() ([]LSQLRunningQuery, error) + func (c *Client) GetSchema(subjectID int) (string, error) + func (c *Client) GetSchemaAsRequest(schema Schema) SchemaAsRequest + func (c *Client) GetSchemaAtVersion(subject string, versionID int) (Schema, error) + func (c *Client) GetServiceAccount(name string) (serviceAccount ServiceAccount, err error) + func (c *Client) GetServiceAccounts() (serviceAccounts []ServiceAccount, err error) + func (c *Client) GetSubjectCompatibilityLevel(subject string) (level CompatibilityLevel, err error) + func (c *Client) GetSubjectVersions(subject string) (versions []int, err error) + func (c *Client) GetSubjects() (subjects []string, err error) + func (c *Client) GetSupportedConnectors() ([]ConnectorInfoUI, error) + func (c *Client) GetTopic(topicName string) (topic Topic, err error) + func (c *Client) GetTopicExtract(id string) ([]TopicExtract, error) + func (c *Client) GetTopicMetadata(topicName string) (TopicMetadata, error) + func (c *Client) GetTopics() (topics []Topic, err error) + func (c *Client) GetTopicsMetadata() ([]TopicMetadata, error) + func (c *Client) GetTopicsNames() ([]string, error) + func (c *Client) GetUser(name string) (user UserMember, err error) + func (c *Client) GetUserProfile() (UserProfile, error) + func (c *Client) GetUsers() (users []UserMember, err error) + func (c *Client) Logout() error + func (c *Client) LookupProcessorIdentifier(id, name, clusterName, namespace string) (string, error) + func (c *Client) PauseConnector(clusterName, name string) error + func (c *Client) PolicyAsRequest(p DataPolicy) DataPolicyRequest + func (c *Client) PolicyForPrint(p DataPolicy) DataPolicyTablePrint + func (c *Client) ReadJSON(resp *http.Response, valuePtr interface{}) error + func (c *Client) ReadResponseBody(resp *http.Response) ([]byte, error) + func (c *Client) RegisterSchema(subject string, avroSchema string) (int, error) + func (c *Client) RestartConnector(clusterName, name string) error + func (c *Client) RestartConnectorTask(clusterName, name string, taskID int) error + func (c *Client) ResumeConnector(clusterName, name string) error + func (c *Client) ResumeProcessor(processorID string) error + func (c *Client) RevokeServiceAccountToken(name string, newToken string) (token CreateSvcAccPayload, err error) + func (c *Client) SetAlertSettingsConsumerCondition(alertID string, consumerAlert ConsumerAlertConditionRequestv1) error + func (c *Client) SetAlertSettingsProducerCondition(alertID, conditionID, topic string, threshold Threshold, duration string, ...) error + func (c *Client) StopProcessor(processorID string) error + func (c *Client) UpdateAlertSettings(alertSettings AlertSettingsPayload) error + func (c *Client) UpdateAlertSettingsCondition(alertID, condition, conditionID string, channels []string) error + func (c *Client) UpdateChannel(chnl ChannelPayload, channelPath, channelID string) error + func (c *Client) UpdateConnection(connectionName string, newName string, configString string, ...) (err error) + func (c *Client) UpdateConnector(clusterName, name string, config ConnectorConfig) (connector Connector, err error) + func (c *Client) UpdateDatasetDescription(connection, name, description string) (err error) + func (c *Client) UpdateDatasetTags(connection, name string, tags []string) (err error) + func (c *Client) UpdateDynamicBrokerConfigs(brokerID int, toAddOrUpdate BrokerConfig) error + func (c *Client) UpdateDynamicClusterConfigs(toAddOrUpdate BrokerConfig) error + func (c *Client) UpdateGlobalCompatibilityLevel(level CompatibilityLevel) error + func (c *Client) UpdateGroup(group *Group) error + func (c *Client) UpdateLicense(license License) error + func (c *Client) UpdateMultipleTopicsOffset(groupID, offsetType, target string, topics []string) error + func (c *Client) UpdatePolicy(policy DataPolicyUpdateRequest) error + func (c *Client) UpdateProcessorRunners(processorID string, numberOfRunners int) error + func (c *Client) UpdateServiceAccount(serviceAccount *ServiceAccount) error + func (c *Client) UpdateSingleTopicOffset(groupID, topic, partitionID, offsetType string, offset int) error + func (c *Client) UpdateSubjectCompatibilityLevel(subject string, level CompatibilityLevel) error + func (c *Client) UpdateTopic(topicName string, configsSlice []KV, partitions int) error + func (c *Client) UpdateUser(user *UserMember) error + func (c *Client) UpdateUserPassword(username, password string) error + func (c *Client) ValidateLSQL(sql string) (v LSQLValidation, err error) + func (c *Client) ValidateSQL(sql string, caret int) (SQLValidationResponse, error) + type ClientConfig struct + Authentication Authentication + Debug bool + Host string + Insecure bool + Timeout string + Token string + func (c *ClientConfig) Fill(other ClientConfig) bool + func (c *ClientConfig) FormatHost() + func (c *ClientConfig) IsBasicAuth() (BasicAuthentication, bool) + func (c *ClientConfig) IsKerberosAuth() (KerberosAuthentication, bool) + func (c *ClientConfig) IsValid() bool + type CompatibilityLevel string + const CompatibilityLevelBackward + const CompatibilityLevelBackwardTransitive + const CompatibilityLevelForward + const CompatibilityLevelForwardTransitive + const CompatibilityLevelFull + const CompatibilityLevelFullTransitive + const CompatibilityLevelNone + type CompressionType string + const Gzip + const LZ4 + const Producer + const Snappy + const Uncompressed + type Config struct + Contexts map[string]*ClientConfig + CurrentContext string + func (c *Config) AddContext(name string, context *ClientConfig) + func (c *Config) Clone() Config + func (c *Config) ContextExists(name string) bool + func (c *Config) CurrentContextExists() bool + func (c *Config) FillCurrent(cfg ClientConfig) + func (c *Config) GetCurrent() *ClientConfig + func (c *Config) IsValid() bool + func (c *Config) RemoveContext(contextName string) bool + func (c *Config) RemoveTokens() + func (c *Config) SetCurrent(currentContextName string) + type ConnectCluster struct + Config string + Name string + Offsets string + Statuses string + URL string + type Connection struct + BuiltIn bool + Configuration []ConnectionConfig + CreatedAt int64 + CreatedBy string + ModifiedAt int64 + ModifiedBy string + Name string + ReadOnly bool + Tags []string + TemplateName string + TemplateVersion int + type ConnectionApp struct + Name string + Status string + type ConnectionConfig struct + Key string + Value interface{} + type ConnectionEntity struct + ConnectionName string + ConnectionType string + DatasetsWithFields []DatasetsWithFields + Entities []string + type ConnectionList struct + Name string + ReadOnly bool + Tags []string + TemplateName string + TemplateVersion int + type ConnectionOption func(*Client) + func UsingClient(httpClient *http.Client) ConnectionOption + func UsingToken(tok string) ConnectionOption + func WithContext(contextName string) ConnectionOption + type ConnectionTemplate struct + BuiltIn bool + Category string + Config []ConnectionTemplateConfig + Enabled bool + Metadata ConnectionTemplateMetadata + Name string + TemplateVersion int + Type string + Version string + type ConnectionTemplateConfig struct + Description string + DisplayName string + Key string + Mounted bool + Placeholder string + Required bool + Type ConnectionTemplateConfigType + type ConnectionTemplateConfigType struct + DisplayName string + Name string + type ConnectionTemplateMetadata struct + Author string + Description string + DocURL string + GitCommit string + GitRepo string + Image string + ImageTag string + type Connector struct + ClusterName string + Config ConnectorConfig + Name string + Tasks []ConnectorTaskReadOnly + func (connector *Connector) ConnectorAsRequest() CreateUpdateConnectorPayload + type ConnectorConfig map[string]interface + type ConnectorInfoUI struct + Author string + Class string + Description string + Docs string + Name string + Type string + UIEnabled bool + Version string + type ConnectorPlugin struct + Class string + Type string + Version string + type ConnectorState string + const FAILED + const PAUSED + const RUNNING + const UNASSIGNED + type ConnectorStatus struct + Connector ConnectorStatusConnectorField + Name string + Tasks []ConnectorStatusTask + type ConnectorStatusConnectorField struct + State string + WorkerID string + type ConnectorStatusTask struct + ID int + State string + Trace string + WorkerID string + type ConnectorTaskReadOnly struct + Connector string + Task int + type Consumer struct + ClientID string + ConsumerID string + CurrentOffset int64 + Host string + Lag int64 + LogEndOffset int64 + MessagesPerSecond int64 + ProducerMessagesPerSecond int64 + Topic string + type ConsumerAlertConditionRequestv1 struct + Channels []string + Condition ConsumerConditionDsl + type ConsumerAlertSettings struct + ConditionDetails []ConsumerAlertConditionRequestv1 + Description string + ID int + type ConsumerConditionDsl struct + Group string + Threshold int + Topic string + type ConsumerCoordinator struct + Host string + ID int + Port int + Rack string + type ConsumerGroupState string + const StateCoordinatorNotFound + const StateDead + const StateExistsNot + const StateNoActiveMembers + const StateRebalancing + const StateStable + const StateUnknown + type ConsumersGroup struct + Active bool + Consumers []string + ConsumersCount int + Coordinator ConsumerCoordinator + ID string + MaxLag int64 + MinLag int64 + State ConsumerGroupState + TopicPartitionsCount int + type CreateConnectionPayload struct + Configuration []ConnectionConfig + Name string + Tags []string + TemplateName string + type CreateProcessorFilePayload struct + ClusterName string + Name string + Namespace string + Pipeline string + ProcessorID string + Runners int + SQL string + type CreateProcessorRequestPayload struct + AppID string + ClusterName string + Name string + Namespace string + Pipeline string + Runners int + SQL string + type CreateQuotaPayload struct + ClientID string + Config QuotaConfig + QuotaType string + User string + type CreateSvcAccPayload struct + Token string + type CreateTopicPayload struct + Configs KV + Description string + Partitions int + Replication int + TopicName string + type CreateUpdateConnectorPayload struct + ClusterName string + Config ConnectorConfig + Name string + func (c *CreateUpdateConnectorPayload) ApplyAndValidateName() error + type DataImpactType struct + ImpactType string + type DataObfuscationType struct + RedactionType string + type DataPolicy struct + Category string + Datasets *[]string + Fields []string + ID string + Impact Impacts + ImpactType string + LastUpdated string + LastUpdatedUser string + Name string + Obfuscation string + Versions int + type DataPolicyFields struct + Fields map[string][]string + type DataPolicyRequest struct + Category string + Datasets *[]string + Fields []string + ImpactType string + Impacts Impacts + LastUpdated string + LastUpdatedUser string + Name string + Obfuscation string + Versions int + type DataPolicyTablePrint struct + Apps []ImpactsDetails + Category string + Connectors []ImpactsDetails + Fields []string + ID string + ImpactType string + LastUpdated string + LastUpdatedUser string + Name string + Obfuscation string + Processors []ImpactsDetails + Versions int + type DataPolicyUpdateRequest struct + Category string + Datasets *[]string + Fields []string + ID string + ImpactType string + Name string + Obfuscation string + type DataProduced struct + ConnectionName string + DatasetName string + Duration string + Threshold Threshold + type DatasetTag struct + Name string + type DatasetsWithFields struct + DatasetName string + MatchingKeyFields []MatchingFields + MatchingValueFields []MatchingFields + type DeploymentTargets struct + Connect []KafkaConnectTarget + Kubernetes []KubernetesTarget + type ExecutionMode string + const ExecutionModeConnect + const ExecutionModeInProcess + const ExecutionModeInvalid + const ExecutionModeKubernetes + func MatchExecutionMode(modeStr string) (ExecutionMode, bool) + type FlexInt int + func (fi *FlexInt) UnmarshalJSON(b []byte) error + type Group struct + AdminPermissions []string + ConnectClustersPermissions []string + Description string + Name string + Namespaces []Namespace + ScopedPermissions []string + ServiceAccountsCount int + UserAccountsCount int + type Impacts struct + Apps []ImpactsDetails + ConnectionEntities []ConnectionEntity + Connectors []ImpactsDetails + Processors []ImpactsDetails + type ImpactsDetails struct + ID string + Name string + Type string + type Index struct + ConnectionName string + Description string + IndexName string + KeySchema string + KeyType string + Permission []string + Replicas int + Shards []Shard + ShardsCount int + Size int + Status string + Tags []DatasetTag + TotalRecords int + ValueSchema string + ValueType string + type KV map[string]interface + type KafkaConnectTarget struct + Cluster string + Version string + type KerberosAuthentication struct + ConfFile string + Method KerberosAuthenticationMethod + func (auth KerberosAuthentication) Auth(c *Client) error + func (auth KerberosAuthentication) FromCCache() (KerberosFromCCache, bool) + func (auth KerberosAuthentication) WithKeytab() (KerberosWithKeytab, bool) + func (auth KerberosAuthentication) WithPassword() (KerberosWithPassword, bool) + type KerberosAuthenticationMethod interface + NewClient func() (client.Client, error) + type KerberosFromCCache struct + CCacheFile string + func (m KerberosFromCCache) NewClient() (client.Client, error) + type KerberosWithKeytab struct + KeytabFile string + Realm string + Username string + func (m KerberosWithKeytab) NewClient() (client.Client, error) + type KerberosWithPassword struct + Password string + Realm string + Username string + func (m KerberosWithPassword) NewClient() (client.Client, error) + type KeyVal struct + Key string + Value string + type KubernetesTarget struct + Cluster string + Namespaces []string + Version string + type LSQLRunningQuery struct + ID int64 + SQL string + Timestamp int64 + User string + type LSQLValidation struct + Column int + IsValid bool + Line int + Message string + type License struct + ClientID string + Details string + Key string + Source string + type LicenseInfo struct + ClientID string + DaysToExpire int + ExpiresAt time.Time + ExpiresDur time.Duration + Expiry int64 + IsRespected bool + MaxBrokers int + MaxMessages int + MonthsToExpire int + YearsToExpire int + type LogLine struct + Level string + Logger string + Message string + Stacktrace string + Thread string + Time string + Timestamp int64 + type MatchingFields struct + Name string + Parents []string + type MultipleTopicOffsets struct + Target string + Topics []string + Type string + type Namespace struct + Instance string + Permissions []string + System string + Wildcards []string + type PartitionMessage struct + Begin int64 + End int64 + Messages int64 + Partition int + type ProcessorAppState struct + DeploymentError string + DeploymentStatus string + RunnerStataus map[string]ProcessorRunnerState + type ProcessorLastAction struct + Action string + Message string + type ProcessorRunnerState struct + ErrorMessage string + ID string + State string + Worker string + type ProcessorStream struct + ClusterName string + DeploymentState string + FromTopics []string + ID string + InputTopics []TopicDecoders + LastAction ProcessorLastAction + Name string + Namespace string + OutputTopics []TopicDecoders + Pipeline string + ProcessorID string + RunnerState ProcessorAppState + Runners int + SQL string + Settings map[string]string + StartTimestamp int64 + StopTimestamp int64 + ToTopics []string + Uptime int64 + User string + func (p *ProcessorStream) ProcessorAsFile() CreateProcessorFilePayload + type ProcessorsResult struct + Streams []ProcessorStream + type ProducerAlertSettings struct + ConditionDetails []AlertConditionRequestv1 + Description string + ID int + type QueryFiltering struct + Name string + Page int + PageSize int + SortBy string + SortingOrder string + type Quota struct + Child string + EntityName string + EntityType QuotaEntityType + IsAuthorized bool + Properties QuotaConfig + URL string + func (q *Quota) GetQuotaAsRequest() CreateQuotaPayload + type QuotaConfig struct + ConsumerByteRate string + ProducerByteRate string + RequestPercentage string + type QuotaEntityType string + const QuotaEntityClient + const QuotaEntityClients + const QuotaEntityClientsDefault + const QuotaEntityUser + const QuotaEntityUserClient + const QuotaEntityUsers + const QuotaEntityUsersDefault + type RequestOption func(r *http.Request) error + type ResourceError struct + Body string + Method string + StatusCode int + URI string + func NewResourceError(statusCode int, uri, method, body string) ResourceError + func (err ResourceError) Code() int + func (err ResourceError) Error() string + func (err ResourceError) String() string + type SQLValidationRequest struct + Caret int + SQL string + type SQLValidationResponse struct + Caret int + Highlights []ValidationLints + Input string + Lints []ValidationLints + Suggestions []Suggestions + type Schema struct + AvroSchema string + ID int + Name string + Version int + type SchemaAsRequest struct + AvroSchema string + Name string + type ServiceAccount struct + Groups []string + Name string + Owner string + type Shard struct + AvailableReplicas int + Records int + Replicas int + Shard string + type SingleTopicOffset struct + Offset int + Type string + type Suggestions struct + Display string + Text string + type Threshold struct + Messages int + Type string + type Topic struct + Configs []KV + ConsumersGroup []ConsumersGroup + Description string + IsControlTopic bool + IsMarkedForDeletion bool + KeySchema string + KeyType string + MessagesPerPartition []PartitionMessage + MessagesPerSecond int64 + Partitions int + Replication int + Tags []DatasetTag + Timestamp int64 + TopicName string + TotalMessages int64 + ValueSchema string + ValueType string + func (topic *Topic) GetTopicAsRequest(config KV) CreateTopicPayload + type TopicCleanupPolicy string + const TopicCompactPolicy + const TopicDeletePolicy + type TopicConfig struct + CleanupPolicy TopicCleanupPolicy + CompressionType CompressionType + DeleteRetentionMs int64 + FileDeleteDelayMs int64 + FlushMessages int64 + FlushMs int64 + FollowerReplicationThrottledReplicas string + IndexIntervalBytes int64 + KV KV + LeaderReplicationThrottledReplicas string + MaxMessageBytes int64 + MessageFormatVersion string + MessageTimestampDifferenceMaxMs int64 + MessageTimestampType TopicMessageTimestampType + MinCleanableDirtyRatio float32 + MinCompactionLagMs int64 + MinInsyncReplicas int + Preallocate bool + RetentionBytes int64 + RetentionMs int64 + SegmentBytes int64 + SegmentIndexBytes int64 + SegmentJitterMs int64 + SegmentMs int64 + UncleanLeaderElectionEnable bool + type TopicDecoders struct + Key string + Name string + Value string + type TopicExtract struct + Descendants []string + Parents []string + type TopicMessageTimestampType string + const TopicMessageCreateTime + const TopicMessageLogAppendTime + type TopicMetadata struct + KeySchemaRaw string + KeyType string + TopicName string + ValueSchemaRaw string + ValueType string + type UnmarshalFunc func(in []byte, outPtr *Config) error + type UpdateConfigs struct + Configs []KeyVal + type UpdateConnectionPayload struct + Configuration []ConnectionConfig + Name string + Tags []string + type UpdateDatasetDescription struct + Description string + type UpdateDatasetTags struct + Tags []DatasetTag + type User struct + Name string + Permissions []string + SchemaRegistryDelete bool + Token string + type UserMember struct + Email string + Groups []string + Password string + Type string + Username string + type UserProfile struct + Schemas []string + Topics []string + Transformers []string + type ValidationLints struct + End int + Start int + Text string + Type string Other modules containing this package github.com/rollulus/lenses-go/v5
Go to main page