Versions in this module Expand all Collapse all v0 v0.1.1 Oct 11, 2021 Changes in this version + type Acl struct + ClusterId string + Host string + Operation string + PatternType string + Permission string + Principal string + ResourceName string + ResourceType string + type Authenticate struct + AuthToken string + ExpiresIn int + TokenType string + type AuthenticateError struct + Errors []struct{ ... } + ErrrorCode int + Message string + StatusCode int + Type string + type AuthorClusters struct + KafkaCluster string + type Client struct + func NewClient(httpClient HttpClient, saramaClient SaramaClient, ...) *Client + func (c *Client) BindPrincipalToRole(principal, roleName string, cDetails ClusterDetails) error + func (c *Client) CreateAcl(clusterId string, aclConfig *Acl) error + func (c *Client) CreatePrincipal(userPrincipal string, principals []UserPrincipalAction) (*UserPrincipal, error) + func (c *Client) CreateTopic(clusterId, topicName string, partitionsCount, replicationFactor int, ...) error + func (c *Client) DecreaseRoleBinding(principal, roleName string, uRoleBinding RoleBinding) error + func (c *Client) DeleteAcl(clusterId, resourceName string) error + func (c *Client) DeleteRoleBinding(principal, roleName string, cDetails ClusterDetails) error + func (c *Client) DeleteTopic(clusterId, topicName string) error + func (c *Client) DoRequest(method string, uri string, reqBody io.Reader) ([]byte, error) + func (c *Client) GetKafkaCluster(clusterId string) (*KafkaCluster, error) + func (c *Client) GetTopic(clusterId, topicName string) (*Topic, error) + func (c *Client) GetTopicConfigs(clusterId string, topicName string) ([]TopicConfig, error) + func (c *Client) GetTopicPartitions(clusterId, topicName string) ([]Partition, error) + func (c *Client) IncreaseRoleBinding(principal, roleName string, uRoleBinding RoleBinding) error + func (c *Client) IsReplicationFactorUpdating(topic string) (bool, error) + func (c *Client) ListAcls(clusterId string) ([]Acl, error) + func (c *Client) ListKafkaCluster() ([]KafkaCluster, error) + func (c *Client) ListTopics(clusterId string) ([]Topic, error) + func (c *Client) Login() (string, error) + func (c *Client) LookupRoleBinding(principal, roleName string, cDetails ClusterDetails) ([]ResourcePattern, error) + func (c *Client) OverwriteRoleBinding(principal, roleName string, uRoleBinding RoleBinding) error + func (c *Client) UpdatePartitions(t Topic) error + func (c *Client) UpdateReplicationsFactor(t Topic) error + func (c *Client) UpdateTopicConfigs(clusterId string, topicName string, data []TopicConfig) error + type ClusterDetails struct + ClusterName string + Clusters Clusters + type Clusters struct + ConnectCluster string + KSqlCluster string + KafkaCluster string + SchemaRegistryCluster string + type Config struct + BootstrapServers *[]string + CACert string + ClientCert string + ClientCertKey string + ClientCertKeyPassphrase string + SASLMechanism string + SASLPassword string + SASLUsername string + SkipTLSVerify bool + TLSEnabled bool + Timeout int + type DefaultHttpClient struct + BaseUrl string + Password string + Token string + UserAgent string + Username string + func NewDefaultHttpClient(baseUrl string, username string, password string) *DefaultHttpClient + func (c *DefaultHttpClient) DoRequest(method string, uri string, reqBody io.Reader) (responseBody []byte, statusCode int, status string, err error) + type DefaultSaramaClient struct + func NewDefaultSaramaClient(config *Config) (*DefaultSaramaClient, sarama.Client, error) + func (k *DefaultSaramaClient) Brokers() []*sarama.Broker + func (k *DefaultSaramaClient) Config() *sarama.Config + func (k *DefaultSaramaClient) Controller() (*sarama.Broker, error) + func (k *DefaultSaramaClient) ID(broker *sarama.Broker) int32 + func (k *DefaultSaramaClient) Partitions(topic string) ([]int32, error) + func (k *DefaultSaramaClient) RefreshMetadata() error + func (k *DefaultSaramaClient) Replicas(topic string, partitionId int32) ([]int32, error) + type DefaultSaramaClusterAdmin struct + func (ca *DefaultSaramaClusterAdmin) AlterPartitionReassignments(topic string, assignment [][]int32) error + func (ca *DefaultSaramaClusterAdmin) ListPartitionReassignments(topic string, partitions []int32) (map[string]map[int32]*sarama.PartitionReplicaReassignmentsStatus, error) + type ErrorResponse struct + ErrorCode int + Errors []struct{ ... } + Message string + StatusCode int + Type string + type HttpClient interface + DoRequest func(method string, uri string, reqBody io.Reader) (responseBody []byte, statusCode int, status string, err error) + type KafkaCluster struct + ClusterID string + type Metadata struct + Next string + ResourceName string + Self string + type Partition struct + ClusterID string + PartitionId int + TopicName string + type Related struct + Related string + type ReplicasAssignment struct + BrokerIds []int + ParitionId int + type ResourcePattern struct + Name string + PatternType string + ResourceType string + type RoleBinding struct + ResourcePatterns []ResourcePattern + Scope ClusterDetails + type SaramaClient interface + Brokers func() []*sarama.Broker + Config func() *sarama.Config + Controller func() (*sarama.Broker, error) + ID func(broker *sarama.Broker) int32 + Partitions func(topic string) ([]int32, error) + RefreshMetadata func() error + Replicas func(topic string, partitionId int32) ([]int32, error) + type SaramaClusterAdmin interface + AlterPartitionReassignments func(topic string, assignment [][]int32) error + ListPartitionReassignments func(topic string, partitions []int32) (map[string]map[int32]*sarama.PartitionReplicaReassignmentsStatus, error) + func NewDefaultSaramaClusterAdmin(saramaClient sarama.Client) (SaramaClusterAdmin, error) + type Scope struct + Clusters AuthorClusters + type Synonyms struct + Name string + Operation string + Source string + Value string + type Topic struct + ClusterID string + Config []TopicConfig + IsInternal bool + Name string + Partitions int32 + PartitionsDetails []Partition + ReplicasAssignments []ReplicasAssignment + ReplicationFactor int16 + type TopicConfig struct + ClusterId string + IsDefault bool + IsReadOnly bool + IsSensitive bool + Name string + Source string + Synonyms []Synonyms + TopicName string + Value string + type UserPrincipal struct + Actions []UserPrincipalAction + UserPrincipal string + type UserPrincipalAction struct + Operation string + ResourceName string + ResourceType string + Scope Scope