strimziadminclient

package
v0.24.4-alpha4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 24, 2021 License: Apache-2.0 Imports: 23 Imported by: 0

README

Go API client for strimziadminclient

An API to provide REST endpoints for query Kafka for admin operations

Overview

This API client was generated by the OpenAPI Generator project. By using the OpenAPI-spec from a remote server, you can easily generate an API client.

  • API version: 0.1.0
  • Package version: 1.0.0
  • Build package: org.openapitools.codegen.languages.GoClientCodegen

Installation

Install the following dependencies:

go get github.com/stretchr/testify/assert
go get golang.org/x/oauth2
go get golang.org/x/net/context

Put the package under your project folder and add the following in import:

import sw "./strimziadminclient"

To use a proxy, set the environment variable HTTP_PROXY:

os.Setenv("HTTP_PROXY", "http://proxy_name:proxy_port")

Configuration of Server URL

Default configuration comes with Servers field that contains server objects as defined in the OpenAPI specification.

Select Server Configuration

For using other server than the one defined on index 0 set context value sw.ContextServerIndex of type int.

ctx := context.WithValue(context.Background(), sw.ContextServerIndex, 1)
Templated Server URL

Templated server URL is formatted using default variables from configuration or from context value sw.ContextServerVariables of type map[string]string.

ctx := context.WithValue(context.Background(), sw.ContextServerVariables, map[string]string{
	"basePath": "v2",
})

Note, enum values are always validated and all unused variables are silently ignored.

URLs Configuration per Operation

Each operation can use different server URL defined using OperationServers map in the Configuration. An operation is uniquely identifield by "{classname}Service.{nickname}" string. Similar rules for overriding default operation server index and variables applies by using sw.ContextOperationServerIndices and sw.ContextOperationServerVariables context maps.

ctx := context.WithValue(context.Background(), sw.ContextOperationServerIndices, map[string]int{
	"{classname}Service.{nickname}": 2,
})
ctx = context.WithValue(context.Background(), sw.ContextOperationServerVariables, map[string]map[string]string{
	"{classname}Service.{nickname}": {
		"port": "8443",
	},
})

Documentation for API Endpoints

All URIs are relative to https://api.openshift.com

Class Method HTTP request Description
DefaultApi CreateTopic Post /topics Creates a new topic
DefaultApi DeleteConsumerGroupById Delete /consumer-groups/{consumerGroupId} Delete a consumer group.
DefaultApi DeleteTopic Delete /topics/{topicName} Deletes a topic
DefaultApi GetConsumerGroupById Get /consumer-groups/{consumerGroupId} Get a single consumer group by its unique ID.
DefaultApi GetConsumerGroupList Get /consumer-groups List of consumer groups in the Kafka instance.
DefaultApi GetTopic Get /topics/{topicName} Retrieves the topic with the specified name.
DefaultApi GetTopicsList Get /topics List of topics
DefaultApi Metrics Get /metrics Admin server metrics
DefaultApi OpenApi Get /api
DefaultApi UpdateTopic Patch /topics/{topicName} Updates the topic with the specified name.

Documentation For Models

Documentation For Authorization

Endpoints do not require authorization.

Documentation for Utility Methods

Due to the fact that model structure members are all pointers, this package contains a number of utility functions to easily obtain pointers to values of basic types. Each of these functions takes a value of the given basic type and returns a pointer to it:

  • PtrBool
  • PtrInt
  • PtrInt32
  • PtrInt64
  • PtrFloat
  • PtrFloat32
  • PtrFloat64
  • PtrString
  • PtrTime

Author

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// ContextOAuth2 takes an oauth2.TokenSource as authentication for the request.
	ContextOAuth2 = contextKey("token")

	// ContextBasicAuth takes BasicAuth as authentication for the request.
	ContextBasicAuth = contextKey("basic")

	// ContextAccessToken takes a string oauth2 access token as authentication for the request.
	ContextAccessToken = contextKey("accesstoken")

	// ContextAPIKeys takes a string apikey as authentication for the request
	ContextAPIKeys = contextKey("apiKeys")

	// ContextHttpSignatureAuth takes HttpSignatureAuth as authentication for the request.
	ContextHttpSignatureAuth = contextKey("httpsignature")

	// ContextServerIndex uses a server configuration from the index.
	ContextServerIndex = contextKey("serverIndex")

	// ContextOperationServerIndices uses a server configuration from the index mapping.
	ContextOperationServerIndices = contextKey("serverOperationIndices")

	// ContextServerVariables overrides a server configuration variables.
	ContextServerVariables = contextKey("serverVariables")

	// ContextOperationServerVariables overrides a server configuration variables using operation specific values.
	ContextOperationServerVariables = contextKey("serverOperationVariables")
)

Functions

func CacheExpires 

func CacheExpires(r *http.Response) time.Time

CacheExpires helper function to determine remaining time before repeating a request.

func PtrBool 

func PtrBool(v bool) *bool

PtrBool is a helper routine that returns a pointer to given boolean value.

func PtrFloat32 

func PtrFloat32(v float32) *float32

PtrFloat32 is a helper routine that returns a pointer to given float value.

func PtrFloat64 

func PtrFloat64(v float64) *float64

PtrFloat64 is a helper routine that returns a pointer to given float value.

func PtrInt 

func PtrInt(v int) *int

PtrInt is a helper routine that returns a pointer to given integer value.

func PtrInt32 

func PtrInt32(v int32) *int32

PtrInt32 is a helper routine that returns a pointer to given integer value.

func PtrInt64 

func PtrInt64(v int64) *int64

PtrInt64 is a helper routine that returns a pointer to given integer value.

func PtrString 

func PtrString(v string) *string

PtrString is a helper routine that returns a pointer to given string value.

func PtrTime 

func PtrTime(v time.Time) *time.Time

PtrTime is helper routine that returns a pointer to given Time value.

Types

type APIClient 

type APIClient struct {
	DefaultApi DefaultApi
	// contains filtered or unexported fields
}

APIClient manages communication with the Kafka Admin REST API API v0.1.0 In most cases there should be only one, shared, APIClient.

func NewAPIClient 

func NewAPIClient(cfg *Configuration) *APIClient

NewAPIClient creates a new API client. Requires a userAgent string describing your application. optionally a custom http.Client to allow for advanced features such as caching.

func (*APIClient) GetConfig 

func (c *APIClient) GetConfig() *Configuration

Allow modification of underlying config for alternate implementations and testing Caution: modifying the configuration while live can cause data races and potentially unwanted behavior

type APIKey 

type APIKey struct {
	Key    string
	Prefix string
}

APIKey provides API key based authentication to a request passed via context using ContextAPIKey

type APIResponse 

type APIResponse struct {
	*http.Response `json:"-"`
	Message        string `json:"message,omitempty"`
	// Operation is the name of the OpenAPI operation.
	Operation string `json:"operation,omitempty"`
	// RequestURL is the request URL. This value is always available, even if the
	// embedded *http.Response is nil.
	RequestURL string `json:"url,omitempty"`
	// Method is the HTTP method used for the request.  This value is always
	// available, even if the embedded *http.Response is nil.
	Method string `json:"method,omitempty"`
	// Payload holds the contents of the response body (which may be nil or empty).
	// This is provided here as the raw response.Body() reader will have already
	// been drained.
	Payload []byte `json:"-"`
}

APIResponse stores the API response returned by the server.

func NewAPIResponse 

func NewAPIResponse(r *http.Response) *APIResponse

NewAPIResponse returns a new APIResonse object.

func NewAPIResponseWithError 

func NewAPIResponseWithError(errorMessage string) *APIResponse

NewAPIResponseWithError returns a new APIResponse object with the provided error message.

type ApiCreateTopicRequest 

type ApiCreateTopicRequest struct {
	ApiService DefaultApi
	// contains filtered or unexported fields
}

func (ApiCreateTopicRequest) Execute 

func (r ApiCreateTopicRequest) Execute() (Topic, *_nethttp.Response, error)

func (ApiCreateTopicRequest) NewTopicInput 

func (r ApiCreateTopicRequest) NewTopicInput(newTopicInput NewTopicInput) ApiCreateTopicRequest

type ApiDeleteConsumerGroupByIdRequest 

type ApiDeleteConsumerGroupByIdRequest struct {
	ApiService DefaultApi
	// contains filtered or unexported fields
}

func (ApiDeleteConsumerGroupByIdRequest) Execute 

func (r ApiDeleteConsumerGroupByIdRequest) Execute() (*_nethttp.Response, error)

type ApiDeleteTopicRequest 

type ApiDeleteTopicRequest struct {
	ApiService DefaultApi
	// contains filtered or unexported fields
}

func (ApiDeleteTopicRequest) Execute 

func (r ApiDeleteTopicRequest) Execute() (*_nethttp.Response, error)

type ApiGetConsumerGroupByIdRequest 

type ApiGetConsumerGroupByIdRequest struct {
	ApiService DefaultApi
	// contains filtered or unexported fields
}

func (ApiGetConsumerGroupByIdRequest) Execute 

func (r ApiGetConsumerGroupByIdRequest) Execute() (ConsumerGroup, *_nethttp.Response, error)

func (ApiGetConsumerGroupByIdRequest) Topic 

func (r ApiGetConsumerGroupByIdRequest) Topic(topic string) ApiGetConsumerGroupByIdRequest

type ApiGetConsumerGroupListRequest 

type ApiGetConsumerGroupListRequest struct {
	ApiService DefaultApi
	// contains filtered or unexported fields
}

func (ApiGetConsumerGroupListRequest) Execute 

func (r ApiGetConsumerGroupListRequest) Execute() (ConsumerGroupList, *_nethttp.Response, error)

func (ApiGetConsumerGroupListRequest) Limit 

func (r ApiGetConsumerGroupListRequest) Limit(limit int32) ApiGetConsumerGroupListRequest

func (ApiGetConsumerGroupListRequest) Offset 

func (r ApiGetConsumerGroupListRequest) Offset(offset int32) ApiGetConsumerGroupListRequest

func (ApiGetConsumerGroupListRequest) Topic 

func (r ApiGetConsumerGroupListRequest) Topic(topic string) ApiGetConsumerGroupListRequest

type ApiGetTopicRequest 

type ApiGetTopicRequest struct {
	ApiService DefaultApi
	// contains filtered or unexported fields
}

func (ApiGetTopicRequest) Execute 

func (r ApiGetTopicRequest) Execute() (Topic, *_nethttp.Response, error)

type ApiGetTopicsListRequest 

type ApiGetTopicsListRequest struct {
	ApiService DefaultApi
	// contains filtered or unexported fields
}

func (ApiGetTopicsListRequest) Execute 

func (r ApiGetTopicsListRequest) Execute() (TopicsList, *_nethttp.Response, error)

func (ApiGetTopicsListRequest) Filter 

func (r ApiGetTopicsListRequest) Filter(filter string) ApiGetTopicsListRequest

func (ApiGetTopicsListRequest) Limit 

func (r ApiGetTopicsListRequest) Limit(limit int32) ApiGetTopicsListRequest

func (ApiGetTopicsListRequest) Offset 

func (r ApiGetTopicsListRequest) Offset(offset int32) ApiGetTopicsListRequest

func (ApiGetTopicsListRequest) Order 

func (r ApiGetTopicsListRequest) Order(order string) ApiGetTopicsListRequest

type ApiMetricsRequest 

type ApiMetricsRequest struct {
	ApiService DefaultApi
	// contains filtered or unexported fields
}

func (ApiMetricsRequest) Execute 

func (r ApiMetricsRequest) Execute() (*_nethttp.Response, error)

type ApiOpenApiRequest 

type ApiOpenApiRequest struct {
	ApiService DefaultApi
	// contains filtered or unexported fields
}

func (ApiOpenApiRequest) Execute 

func (r ApiOpenApiRequest) Execute() (*_nethttp.Response, error)

type ApiUpdateTopicRequest 

type ApiUpdateTopicRequest struct {
	ApiService DefaultApi
	// contains filtered or unexported fields
}

func (ApiUpdateTopicRequest) Execute 

func (r ApiUpdateTopicRequest) Execute() (Topic, *_nethttp.Response, error)

func (ApiUpdateTopicRequest) UpdateTopicInput 

func (r ApiUpdateTopicRequest) UpdateTopicInput(updateTopicInput UpdateTopicInput) ApiUpdateTopicRequest

type BasicAuth 

type BasicAuth struct {
	UserName string `json:"userName,omitempty"`
	Password string `json:"password,omitempty"`
}

BasicAuth provides basic http authentication to a request passed via context using ContextBasicAuth

type ConfigEntry 

type ConfigEntry struct {
	// The key indicating what configuration entry you would like to set for the topic.
	Key *string `json:"key,omitempty"`
	// Value to indicate the setting on the topic configuration entry.
	Value *string `json:"value,omitempty"`
}

ConfigEntry Key value pair indicating possible configuration options for a topic.

func NewConfigEntry 

func NewConfigEntry() *ConfigEntry

NewConfigEntry instantiates a new ConfigEntry object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewConfigEntryWithDefaults 

func NewConfigEntryWithDefaults() *ConfigEntry

NewConfigEntryWithDefaults instantiates a new ConfigEntry object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*ConfigEntry) GetKey 

func (o *ConfigEntry) GetKey() string

GetKey returns the Key field value if set, zero value otherwise.

func (*ConfigEntry) GetKeyOk 

func (o *ConfigEntry) GetKeyOk() (*string, bool)

GetKeyOk returns a tuple with the Key field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigEntry) GetValue 

func (o *ConfigEntry) GetValue() string

GetValue returns the Value field value if set, zero value otherwise.

func (*ConfigEntry) GetValueOk 

func (o *ConfigEntry) GetValueOk() (*string, bool)

GetValueOk returns a tuple with the Value field value if set, nil otherwise and a boolean to check if the value has been set.

func (*ConfigEntry) HasKey 

func (o *ConfigEntry) HasKey() bool

HasKey returns a boolean if a field has been set.

func (*ConfigEntry) HasValue 

func (o *ConfigEntry) HasValue() bool

HasValue returns a boolean if a field has been set.

func (ConfigEntry) MarshalJSON 

func (o ConfigEntry) MarshalJSON() ([]byte, error)

func (*ConfigEntry) SetKey 

func (o *ConfigEntry) SetKey(v string)

SetKey gets a reference to the given string and assigns it to the Key field.

func (*ConfigEntry) SetValue 

func (o *ConfigEntry) SetValue(v string)

SetValue gets a reference to the given string and assigns it to the Value field.

type Configuration 

type Configuration struct {
	Host             string            `json:"host,omitempty"`
	Scheme           string            `json:"scheme,omitempty"`
	DefaultHeader    map[string]string `json:"defaultHeader,omitempty"`
	UserAgent        string            `json:"userAgent,omitempty"`
	Debug            bool              `json:"debug,omitempty"`
	Servers          ServerConfigurations
	OperationServers map[string]ServerConfigurations
	HTTPClient       *http.Client
}

Configuration stores the configuration of the API client

func NewConfiguration 

func NewConfiguration() *Configuration

NewConfiguration returns a new Configuration object

func (*Configuration) AddDefaultHeader 

func (c *Configuration) AddDefaultHeader(key string, value string)

AddDefaultHeader adds a new HTTP header to the default header in the request

func (*Configuration) ServerURL 

func (c *Configuration) ServerURL(index int, variables map[string]string) (string, error)

ServerURL returns URL based on server settings

func (*Configuration) ServerURLWithContext 

func (c *Configuration) ServerURLWithContext(ctx context.Context, endpoint string) (string, error)

ServerURLWithContext returns a new server URL given an endpoint

type Consumer 

type Consumer struct {
	// Unique identifier for the consumer group to which this consumer belongs.
	GroupId string `json:"groupId"`
	// The unique topic name to which this consumer belongs
	Topic string `json:"topic"`
	// The partition number to which this consumer group is assigned to.
	Partition int32 `json:"partition"`
	// Offset denotes the position of the consumer in a partition.
	Offset float32 `json:"offset"`
	// The log end offset is the offset of the last message written to a log.
	LogEndOffset *float32 `json:"logEndOffset,omitempty"`
	// Offset Lag is the delta between the last produced message and the last consumer's committed offset.
	Lag int32 `json:"lag"`
	// The member ID is a unique identifier given to a consumer by the coordinator upon initially joining the group.
	MemberId *string `json:"memberId,omitempty"`
}

Consumer A Kafka consumer is responsible for reading records from one or more topics and one or more partitions of a topic.

func NewConsumer 

func NewConsumer(groupId string, topic string, partition int32, offset float32, lag int32) *Consumer

NewConsumer instantiates a new Consumer object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewConsumerWithDefaults 

func NewConsumerWithDefaults() *Consumer

NewConsumerWithDefaults instantiates a new Consumer object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*Consumer) GetGroupId 

func (o *Consumer) GetGroupId() string

GetGroupId returns the GroupId field value

func (*Consumer) GetGroupIdOk 

func (o *Consumer) GetGroupIdOk() (*string, bool)

GetGroupIdOk returns a tuple with the GroupId field value and a boolean to check if the value has been set.

func (*Consumer) GetLag 

func (o *Consumer) GetLag() int32

GetLag returns the Lag field value

func (*Consumer) GetLagOk 

func (o *Consumer) GetLagOk() (*int32, bool)

GetLagOk returns a tuple with the Lag field value and a boolean to check if the value has been set.

func (*Consumer) GetLogEndOffset 

func (o *Consumer) GetLogEndOffset() float32

GetLogEndOffset returns the LogEndOffset field value if set, zero value otherwise.

func (*Consumer) GetLogEndOffsetOk 

func (o *Consumer) GetLogEndOffsetOk() (*float32, bool)

GetLogEndOffsetOk returns a tuple with the LogEndOffset field value if set, nil otherwise and a boolean to check if the value has been set.

func (*Consumer) GetMemberId 

func (o *Consumer) GetMemberId() string

GetMemberId returns the MemberId field value if set, zero value otherwise.

func (*Consumer) GetMemberIdOk 

func (o *Consumer) GetMemberIdOk() (*string, bool)

GetMemberIdOk returns a tuple with the MemberId field value if set, nil otherwise and a boolean to check if the value has been set.

func (*Consumer) GetOffset 

func (o *Consumer) GetOffset() float32

GetOffset returns the Offset field value

func (*Consumer) GetOffsetOk 

func (o *Consumer) GetOffsetOk() (*float32, bool)

GetOffsetOk returns a tuple with the Offset field value and a boolean to check if the value has been set.

func (*Consumer) GetPartition 

func (o *Consumer) GetPartition() int32

GetPartition returns the Partition field value

func (*Consumer) GetPartitionOk 

func (o *Consumer) GetPartitionOk() (*int32, bool)

GetPartitionOk returns a tuple with the Partition field value and a boolean to check if the value has been set.

func (*Consumer) GetTopic 

func (o *Consumer) GetTopic() string

GetTopic returns the Topic field value

func (*Consumer) GetTopicOk 

func (o *Consumer) GetTopicOk() (*string, bool)

GetTopicOk returns a tuple with the Topic field value and a boolean to check if the value has been set.

func (*Consumer) HasLogEndOffset 

func (o *Consumer) HasLogEndOffset() bool

HasLogEndOffset returns a boolean if a field has been set.

func (*Consumer) HasMemberId 

func (o *Consumer) HasMemberId() bool

HasMemberId returns a boolean if a field has been set.

func (Consumer) MarshalJSON 

func (o Consumer) MarshalJSON() ([]byte, error)

func (*Consumer) SetGroupId 

func (o *Consumer) SetGroupId(v string)

SetGroupId sets field value

func (*Consumer) SetLag 

func (o *Consumer) SetLag(v int32)

SetLag sets field value

func (*Consumer) SetLogEndOffset 

func (o *Consumer) SetLogEndOffset(v float32)

SetLogEndOffset gets a reference to the given float32 and assigns it to the LogEndOffset field.

func (*Consumer) SetMemberId 

func (o *Consumer) SetMemberId(v string)

SetMemberId gets a reference to the given string and assigns it to the MemberId field.

func (*Consumer) SetOffset 

func (o *Consumer) SetOffset(v float32)

SetOffset sets field value

func (*Consumer) SetPartition 

func (o *Consumer) SetPartition(v int32)

SetPartition sets field value

func (*Consumer) SetTopic 

func (o *Consumer) SetTopic(v string)

SetTopic sets field value

type ConsumerGroup 

type ConsumerGroup struct {
	// Unique identifier for the consumer group
	GroupId string `json:"groupId"`
	// The list of consumers associated with this consumer group
	Consumers []Consumer `json:"consumers"`
}

ConsumerGroup A group of Kafka consumers

func NewConsumerGroup 

func NewConsumerGroup(groupId string, consumers []Consumer) *ConsumerGroup

NewConsumerGroup instantiates a new ConsumerGroup object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewConsumerGroupWithDefaults 

func NewConsumerGroupWithDefaults() *ConsumerGroup

NewConsumerGroupWithDefaults instantiates a new ConsumerGroup object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*ConsumerGroup) GetConsumers 

func (o *ConsumerGroup) GetConsumers() []Consumer

GetConsumers returns the Consumers field value

func (*ConsumerGroup) GetConsumersOk 

func (o *ConsumerGroup) GetConsumersOk() (*[]Consumer, bool)

GetConsumersOk returns a tuple with the Consumers field value and a boolean to check if the value has been set.

func (*ConsumerGroup) GetGroupId 

func (o *ConsumerGroup) GetGroupId() string

GetGroupId returns the GroupId field value

func (*ConsumerGroup) GetGroupIdOk 

func (o *ConsumerGroup) GetGroupIdOk() (*string, bool)

GetGroupIdOk returns a tuple with the GroupId field value and a boolean to check if the value has been set.

func (ConsumerGroup) MarshalJSON 

func (o ConsumerGroup) MarshalJSON() ([]byte, error)

func (*ConsumerGroup) SetConsumers 

func (o *ConsumerGroup) SetConsumers(v []Consumer)

SetConsumers sets field value

func (*ConsumerGroup) SetGroupId 

func (o *ConsumerGroup) SetGroupId(v string)

SetGroupId sets field value

type ConsumerGroupList 

type ConsumerGroupList struct {
	// Consumer group list items
	Items []ConsumerGroup `json:"items"`
	// The total number of consumer groups.
	Count float32 `json:"count"`
	// The number of consumer groups per page.
	Limit float32 `json:"limit"`
	// The page offset
	Offset int32 `json:"offset"`
}

ConsumerGroupList A list of consumer groups

func NewConsumerGroupList 

func NewConsumerGroupList(items []ConsumerGroup, count float32, limit float32, offset int32) *ConsumerGroupList

NewConsumerGroupList instantiates a new ConsumerGroupList object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewConsumerGroupListWithDefaults 

func NewConsumerGroupListWithDefaults() *ConsumerGroupList

NewConsumerGroupListWithDefaults instantiates a new ConsumerGroupList object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*ConsumerGroupList) GetCount 

func (o *ConsumerGroupList) GetCount() float32

GetCount returns the Count field value

func (*ConsumerGroupList) GetCountOk 

func (o *ConsumerGroupList) GetCountOk() (*float32, bool)

GetCountOk returns a tuple with the Count field value and a boolean to check if the value has been set.

func (*ConsumerGroupList) GetItems 

func (o *ConsumerGroupList) GetItems() []ConsumerGroup

GetItems returns the Items field value

func (*ConsumerGroupList) GetItemsOk 

func (o *ConsumerGroupList) GetItemsOk() (*[]ConsumerGroup, bool)

GetItemsOk returns a tuple with the Items field value and a boolean to check if the value has been set.

func (*ConsumerGroupList) GetLimit 

func (o *ConsumerGroupList) GetLimit() float32

GetLimit returns the Limit field value

func (*ConsumerGroupList) GetLimitOk 

func (o *ConsumerGroupList) GetLimitOk() (*float32, bool)

GetLimitOk returns a tuple with the Limit field value and a boolean to check if the value has been set.

func (*ConsumerGroupList) GetOffset 

func (o *ConsumerGroupList) GetOffset() int32

GetOffset returns the Offset field value

func (*ConsumerGroupList) GetOffsetOk 

func (o *ConsumerGroupList) GetOffsetOk() (*int32, bool)

GetOffsetOk returns a tuple with the Offset field value and a boolean to check if the value has been set.

func (ConsumerGroupList) MarshalJSON 

func (o ConsumerGroupList) MarshalJSON() ([]byte, error)

func (*ConsumerGroupList) SetCount 

func (o *ConsumerGroupList) SetCount(v float32)

SetCount sets field value

func (*ConsumerGroupList) SetItems 

func (o *ConsumerGroupList) SetItems(v []ConsumerGroup)

SetItems sets field value

func (*ConsumerGroupList) SetLimit 

func (o *ConsumerGroupList) SetLimit(v float32)

SetLimit sets field value

func (*ConsumerGroupList) SetOffset 

func (o *ConsumerGroupList) SetOffset(v int32)

SetOffset sets field value

type DefaultApi 

type DefaultApi interface {

	/*
	 * CreateTopic Creates a new topic
	 * Creates a new topic for Kafka.
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return ApiCreateTopicRequest
	 */
	CreateTopic(ctx _context.Context) ApiCreateTopicRequest

	/*
	 * CreateTopicExecute executes the request
	 * @return Topic
	 */
	CreateTopicExecute(r ApiCreateTopicRequest) (Topic, *_nethttp.Response, error)

	/*
	 * DeleteConsumerGroupById Delete a consumer group.
	 * Delete a consumer group, along with its consumers.
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param consumerGroupId The unique ID of the cobsumer group.
	 * @return ApiDeleteConsumerGroupByIdRequest
	 */
	DeleteConsumerGroupById(ctx _context.Context, consumerGroupId string) ApiDeleteConsumerGroupByIdRequest

	/*
	 * DeleteConsumerGroupByIdExecute executes the request
	 */
	DeleteConsumerGroupByIdExecute(r ApiDeleteConsumerGroupByIdRequest) (*_nethttp.Response, error)

	/*
	 * DeleteTopic Deletes a  topic
	 * Deletes the topic with the specified name.
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param topicName The topic name to delete.
	 * @return ApiDeleteTopicRequest
	 */
	DeleteTopic(ctx _context.Context, topicName string) ApiDeleteTopicRequest

	/*
	 * DeleteTopicExecute executes the request
	 */
	DeleteTopicExecute(r ApiDeleteTopicRequest) (*_nethttp.Response, error)

	/*
	 * GetConsumerGroupById Get a single consumer group by its unique ID.
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param consumerGroupId The unique ID of the consumer group
	 * @return ApiGetConsumerGroupByIdRequest
	 */
	GetConsumerGroupById(ctx _context.Context, consumerGroupId string) ApiGetConsumerGroupByIdRequest

	/*
	 * GetConsumerGroupByIdExecute executes the request
	 * @return ConsumerGroup
	 */
	GetConsumerGroupByIdExecute(r ApiGetConsumerGroupByIdRequest) (ConsumerGroup, *_nethttp.Response, error)

	/*
	 * GetConsumerGroupList List of consumer groups in the Kafka instance.
	 * Returns a list of all consumer groups for a particular Kafka instance.
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return ApiGetConsumerGroupListRequest
	 */
	GetConsumerGroupList(ctx _context.Context) ApiGetConsumerGroupListRequest

	/*
	 * GetConsumerGroupListExecute executes the request
	 * @return ConsumerGroupList
	 */
	GetConsumerGroupListExecute(r ApiGetConsumerGroupListRequest) (ConsumerGroupList, *_nethttp.Response, error)

	/*
	 * GetTopic Retrieves the topic with the specified name.
	 * Topic
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param topicName The topic name to retrieve.
	 * @return ApiGetTopicRequest
	 */
	GetTopic(ctx _context.Context, topicName string) ApiGetTopicRequest

	/*
	 * GetTopicExecute executes the request
	 * @return Topic
	 */
	GetTopicExecute(r ApiGetTopicRequest) (Topic, *_nethttp.Response, error)

	/*
	 * GetTopicsList List of topics
	 * Returns a list of all of the available topics, or the list of topics that meet the users URL Query Parameters.
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return ApiGetTopicsListRequest
	 */
	GetTopicsList(ctx _context.Context) ApiGetTopicsListRequest

	/*
	 * GetTopicsListExecute executes the request
	 * @return TopicsList
	 */
	GetTopicsListExecute(r ApiGetTopicsListRequest) (TopicsList, *_nethttp.Response, error)

	/*
	 * Metrics Admin server metrics
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return ApiMetricsRequest
	 */
	Metrics(ctx _context.Context) ApiMetricsRequest

	/*
	 * MetricsExecute executes the request
	 */
	MetricsExecute(r ApiMetricsRequest) (*_nethttp.Response, error)

	/*
	 * OpenApi Method for OpenApi
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return ApiOpenApiRequest
	 */
	OpenApi(ctx _context.Context) ApiOpenApiRequest

	/*
	 * OpenApiExecute executes the request
	 */
	OpenApiExecute(r ApiOpenApiRequest) (*_nethttp.Response, error)

	/*
	 * UpdateTopic Updates the topic with the specified name.
	 * updates the topic with the new data.
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param topicName The topic name which is its unique id.
	 * @return ApiUpdateTopicRequest
	 */
	UpdateTopic(ctx _context.Context, topicName string) ApiUpdateTopicRequest

	/*
	 * UpdateTopicExecute executes the request
	 * @return Topic
	 */
	UpdateTopicExecute(r ApiUpdateTopicRequest) (Topic, *_nethttp.Response, error)
}

type DefaultApiMock 

type DefaultApiMock struct {
	// CreateTopicFunc mocks the CreateTopic method.
	CreateTopicFunc func(ctx context.Context) ApiCreateTopicRequest

	// CreateTopicExecuteFunc mocks the CreateTopicExecute method.
	CreateTopicExecuteFunc func(r ApiCreateTopicRequest) (Topic, *http.Response, error)

	// DeleteConsumerGroupByIdFunc mocks the DeleteConsumerGroupById method.
	DeleteConsumerGroupByIdFunc func(ctx context.Context, consumerGroupId string) ApiDeleteConsumerGroupByIdRequest

	// DeleteConsumerGroupByIdExecuteFunc mocks the DeleteConsumerGroupByIdExecute method.
	DeleteConsumerGroupByIdExecuteFunc func(r ApiDeleteConsumerGroupByIdRequest) (*http.Response, error)

	// DeleteTopicFunc mocks the DeleteTopic method.
	DeleteTopicFunc func(ctx context.Context, topicName string) ApiDeleteTopicRequest

	// DeleteTopicExecuteFunc mocks the DeleteTopicExecute method.
	DeleteTopicExecuteFunc func(r ApiDeleteTopicRequest) (*http.Response, error)

	// GetConsumerGroupByIdFunc mocks the GetConsumerGroupById method.
	GetConsumerGroupByIdFunc func(ctx context.Context, consumerGroupId string) ApiGetConsumerGroupByIdRequest

	// GetConsumerGroupByIdExecuteFunc mocks the GetConsumerGroupByIdExecute method.
	GetConsumerGroupByIdExecuteFunc func(r ApiGetConsumerGroupByIdRequest) (ConsumerGroup, *http.Response, error)

	// GetConsumerGroupListFunc mocks the GetConsumerGroupList method.
	GetConsumerGroupListFunc func(ctx context.Context) ApiGetConsumerGroupListRequest

	// GetConsumerGroupListExecuteFunc mocks the GetConsumerGroupListExecute method.
	GetConsumerGroupListExecuteFunc func(r ApiGetConsumerGroupListRequest) (ConsumerGroupList, *http.Response, error)

	// GetTopicFunc mocks the GetTopic method.
	GetTopicFunc func(ctx context.Context, topicName string) ApiGetTopicRequest

	// GetTopicExecuteFunc mocks the GetTopicExecute method.
	GetTopicExecuteFunc func(r ApiGetTopicRequest) (Topic, *http.Response, error)

	// GetTopicsListFunc mocks the GetTopicsList method.
	GetTopicsListFunc func(ctx context.Context) ApiGetTopicsListRequest

	// GetTopicsListExecuteFunc mocks the GetTopicsListExecute method.
	GetTopicsListExecuteFunc func(r ApiGetTopicsListRequest) (TopicsList, *http.Response, error)

	// MetricsFunc mocks the Metrics method.
	MetricsFunc func(ctx context.Context) ApiMetricsRequest

	// MetricsExecuteFunc mocks the MetricsExecute method.
	MetricsExecuteFunc func(r ApiMetricsRequest) (*http.Response, error)

	// OpenApiFunc mocks the OpenApi method.
	OpenApiFunc func(ctx context.Context) ApiOpenApiRequest

	// OpenApiExecuteFunc mocks the OpenApiExecute method.
	OpenApiExecuteFunc func(r ApiOpenApiRequest) (*http.Response, error)

	// UpdateTopicFunc mocks the UpdateTopic method.
	UpdateTopicFunc func(ctx context.Context, topicName string) ApiUpdateTopicRequest

	// UpdateTopicExecuteFunc mocks the UpdateTopicExecute method.
	UpdateTopicExecuteFunc func(r ApiUpdateTopicRequest) (Topic, *http.Response, error)
	// contains filtered or unexported fields
}

DefaultApiMock is a mock implementation of DefaultApi. 

    func TestSomethingThatUsesDefaultApi(t *testing.T) {

        // make and configure a mocked DefaultApi
        mockedDefaultApi := &DefaultApiMock{
            CreateTopicFunc: func(ctx context.Context) ApiCreateTopicRequest {
	               panic("mock out the CreateTopic method")
            },
            CreateTopicExecuteFunc: func(r ApiCreateTopicRequest) (Topic, *http.Response, error) {
	               panic("mock out the CreateTopicExecute method")
            },
            DeleteConsumerGroupByIdFunc: func(ctx context.Context, consumerGroupId string) ApiDeleteConsumerGroupByIdRequest {
	               panic("mock out the DeleteConsumerGroupById method")
            },
            DeleteConsumerGroupByIdExecuteFunc: func(r ApiDeleteConsumerGroupByIdRequest) (*http.Response, error) {
	               panic("mock out the DeleteConsumerGroupByIdExecute method")
            },
            DeleteTopicFunc: func(ctx context.Context, topicName string) ApiDeleteTopicRequest {
	               panic("mock out the DeleteTopic method")
            },
            DeleteTopicExecuteFunc: func(r ApiDeleteTopicRequest) (*http.Response, error) {
	               panic("mock out the DeleteTopicExecute method")
            },
            GetConsumerGroupByIdFunc: func(ctx context.Context, consumerGroupId string) ApiGetConsumerGroupByIdRequest {
	               panic("mock out the GetConsumerGroupById method")
            },
            GetConsumerGroupByIdExecuteFunc: func(r ApiGetConsumerGroupByIdRequest) (ConsumerGroup, *http.Response, error) {
	               panic("mock out the GetConsumerGroupByIdExecute method")
            },
            GetConsumerGroupListFunc: func(ctx context.Context) ApiGetConsumerGroupListRequest {
	               panic("mock out the GetConsumerGroupList method")
            },
            GetConsumerGroupListExecuteFunc: func(r ApiGetConsumerGroupListRequest) (ConsumerGroupList, *http.Response, error) {
	               panic("mock out the GetConsumerGroupListExecute method")
            },
            GetTopicFunc: func(ctx context.Context, topicName string) ApiGetTopicRequest {
	               panic("mock out the GetTopic method")
            },
            GetTopicExecuteFunc: func(r ApiGetTopicRequest) (Topic, *http.Response, error) {
	               panic("mock out the GetTopicExecute method")
            },
            GetTopicsListFunc: func(ctx context.Context) ApiGetTopicsListRequest {
	               panic("mock out the GetTopicsList method")
            },
            GetTopicsListExecuteFunc: func(r ApiGetTopicsListRequest) (TopicsList, *http.Response, error) {
	               panic("mock out the GetTopicsListExecute method")
            },
            MetricsFunc: func(ctx context.Context) ApiMetricsRequest {
	               panic("mock out the Metrics method")
            },
            MetricsExecuteFunc: func(r ApiMetricsRequest) (*http.Response, error) {
	               panic("mock out the MetricsExecute method")
            },
            OpenApiFunc: func(ctx context.Context) ApiOpenApiRequest {
	               panic("mock out the OpenApi method")
            },
            OpenApiExecuteFunc: func(r ApiOpenApiRequest) (*http.Response, error) {
	               panic("mock out the OpenApiExecute method")
            },
            UpdateTopicFunc: func(ctx context.Context, topicName string) ApiUpdateTopicRequest {
	               panic("mock out the UpdateTopic method")
            },
            UpdateTopicExecuteFunc: func(r ApiUpdateTopicRequest) (Topic, *http.Response, error) {
	               panic("mock out the UpdateTopicExecute method")
            },
        }

        // use mockedDefaultApi in code that requires DefaultApi
        // and then make assertions.

    }

func (*DefaultApiMock) CreateTopic 

func (mock *DefaultApiMock) CreateTopic(ctx context.Context) ApiCreateTopicRequest

CreateTopic calls CreateTopicFunc.

func (*DefaultApiMock) CreateTopicCalls 

func (mock *DefaultApiMock) CreateTopicCalls() []struct {
	Ctx context.Context
}

CreateTopicCalls gets all the calls that were made to CreateTopic. Check the length with: 

len(mockedDefaultApi.CreateTopicCalls())

func (*DefaultApiMock) CreateTopicExecute 

func (mock *DefaultApiMock) CreateTopicExecute(r ApiCreateTopicRequest) (Topic, *http.Response, error)

CreateTopicExecute calls CreateTopicExecuteFunc.

func (*DefaultApiMock) CreateTopicExecuteCalls 

func (mock *DefaultApiMock) CreateTopicExecuteCalls() []struct {
	R ApiCreateTopicRequest
}

CreateTopicExecuteCalls gets all the calls that were made to CreateTopicExecute. Check the length with: 

len(mockedDefaultApi.CreateTopicExecuteCalls())

func (*DefaultApiMock) DeleteConsumerGroupById 

func (mock *DefaultApiMock) DeleteConsumerGroupById(ctx context.Context, consumerGroupId string) ApiDeleteConsumerGroupByIdRequest

DeleteConsumerGroupById calls DeleteConsumerGroupByIdFunc.

func (*DefaultApiMock) DeleteConsumerGroupByIdCalls 

func (mock *DefaultApiMock) DeleteConsumerGroupByIdCalls() []struct {
	Ctx             context.Context
	ConsumerGroupId string
}

DeleteConsumerGroupByIdCalls gets all the calls that were made to DeleteConsumerGroupById. Check the length with: 

len(mockedDefaultApi.DeleteConsumerGroupByIdCalls())

func (*DefaultApiMock) DeleteConsumerGroupByIdExecute 

func (mock *DefaultApiMock) DeleteConsumerGroupByIdExecute(r ApiDeleteConsumerGroupByIdRequest) (*http.Response, error)

DeleteConsumerGroupByIdExecute calls DeleteConsumerGroupByIdExecuteFunc.

func (*DefaultApiMock) DeleteConsumerGroupByIdExecuteCalls 

func (mock *DefaultApiMock) DeleteConsumerGroupByIdExecuteCalls() []struct {
	R ApiDeleteConsumerGroupByIdRequest
}

DeleteConsumerGroupByIdExecuteCalls gets all the calls that were made to DeleteConsumerGroupByIdExecute. Check the length with: 

len(mockedDefaultApi.DeleteConsumerGroupByIdExecuteCalls())

func (*DefaultApiMock) DeleteTopic 

func (mock *DefaultApiMock) DeleteTopic(ctx context.Context, topicName string) ApiDeleteTopicRequest

DeleteTopic calls DeleteTopicFunc.

func (*DefaultApiMock) DeleteTopicCalls 

func (mock *DefaultApiMock) DeleteTopicCalls() []struct {
	Ctx       context.Context
	TopicName string
}

DeleteTopicCalls gets all the calls that were made to DeleteTopic. Check the length with: 

len(mockedDefaultApi.DeleteTopicCalls())

func (*DefaultApiMock) DeleteTopicExecute 

func (mock *DefaultApiMock) DeleteTopicExecute(r ApiDeleteTopicRequest) (*http.Response, error)

DeleteTopicExecute calls DeleteTopicExecuteFunc.

func (*DefaultApiMock) DeleteTopicExecuteCalls 

func (mock *DefaultApiMock) DeleteTopicExecuteCalls() []struct {
	R ApiDeleteTopicRequest
}

DeleteTopicExecuteCalls gets all the calls that were made to DeleteTopicExecute. Check the length with: 

len(mockedDefaultApi.DeleteTopicExecuteCalls())

func (*DefaultApiMock) GetConsumerGroupById 

func (mock *DefaultApiMock) GetConsumerGroupById(ctx context.Context, consumerGroupId string) ApiGetConsumerGroupByIdRequest

GetConsumerGroupById calls GetConsumerGroupByIdFunc.

func (*DefaultApiMock) GetConsumerGroupByIdCalls 

func (mock *DefaultApiMock) GetConsumerGroupByIdCalls() []struct {
	Ctx             context.Context
	ConsumerGroupId string
}

GetConsumerGroupByIdCalls gets all the calls that were made to GetConsumerGroupById. Check the length with: 

len(mockedDefaultApi.GetConsumerGroupByIdCalls())

func (*DefaultApiMock) GetConsumerGroupByIdExecute 

func (mock *DefaultApiMock) GetConsumerGroupByIdExecute(r ApiGetConsumerGroupByIdRequest) (ConsumerGroup, *http.Response, error)

GetConsumerGroupByIdExecute calls GetConsumerGroupByIdExecuteFunc.

func (*DefaultApiMock) GetConsumerGroupByIdExecuteCalls 

func (mock *DefaultApiMock) GetConsumerGroupByIdExecuteCalls() []struct {
	R ApiGetConsumerGroupByIdRequest
}

GetConsumerGroupByIdExecuteCalls gets all the calls that were made to GetConsumerGroupByIdExecute. Check the length with: 

len(mockedDefaultApi.GetConsumerGroupByIdExecuteCalls())

func (*DefaultApiMock) GetConsumerGroupList 

func (mock *DefaultApiMock) GetConsumerGroupList(ctx context.Context) ApiGetConsumerGroupListRequest

GetConsumerGroupList calls GetConsumerGroupListFunc.

func (*DefaultApiMock) GetConsumerGroupListCalls 

func (mock *DefaultApiMock) GetConsumerGroupListCalls() []struct {
	Ctx context.Context
}

GetConsumerGroupListCalls gets all the calls that were made to GetConsumerGroupList. Check the length with: 

len(mockedDefaultApi.GetConsumerGroupListCalls())

func (*DefaultApiMock) GetConsumerGroupListExecute 

func (mock *DefaultApiMock) GetConsumerGroupListExecute(r ApiGetConsumerGroupListRequest) (ConsumerGroupList, *http.Response, error)

GetConsumerGroupListExecute calls GetConsumerGroupListExecuteFunc.

func (*DefaultApiMock) GetConsumerGroupListExecuteCalls 

func (mock *DefaultApiMock) GetConsumerGroupListExecuteCalls() []struct {
	R ApiGetConsumerGroupListRequest
}

GetConsumerGroupListExecuteCalls gets all the calls that were made to GetConsumerGroupListExecute. Check the length with: 

len(mockedDefaultApi.GetConsumerGroupListExecuteCalls())

func (*DefaultApiMock) GetTopic 

func (mock *DefaultApiMock) GetTopic(ctx context.Context, topicName string) ApiGetTopicRequest

GetTopic calls GetTopicFunc.

func (*DefaultApiMock) GetTopicCalls 

func (mock *DefaultApiMock) GetTopicCalls() []struct {
	Ctx       context.Context
	TopicName string
}

GetTopicCalls gets all the calls that were made to GetTopic. Check the length with: 

len(mockedDefaultApi.GetTopicCalls())

func (*DefaultApiMock) GetTopicExecute 

func (mock *DefaultApiMock) GetTopicExecute(r ApiGetTopicRequest) (Topic, *http.Response, error)

GetTopicExecute calls GetTopicExecuteFunc.

func (*DefaultApiMock) GetTopicExecuteCalls 

func (mock *DefaultApiMock) GetTopicExecuteCalls() []struct {
	R ApiGetTopicRequest
}

GetTopicExecuteCalls gets all the calls that were made to GetTopicExecute. Check the length with: 

len(mockedDefaultApi.GetTopicExecuteCalls())

func (*DefaultApiMock) GetTopicsList 

func (mock *DefaultApiMock) GetTopicsList(ctx context.Context) ApiGetTopicsListRequest

GetTopicsList calls GetTopicsListFunc.

func (*DefaultApiMock) GetTopicsListCalls 

func (mock *DefaultApiMock) GetTopicsListCalls() []struct {
	Ctx context.Context
}

GetTopicsListCalls gets all the calls that were made to GetTopicsList. Check the length with: 

len(mockedDefaultApi.GetTopicsListCalls())

func (*DefaultApiMock) GetTopicsListExecute 

func (mock *DefaultApiMock) GetTopicsListExecute(r ApiGetTopicsListRequest) (TopicsList, *http.Response, error)

GetTopicsListExecute calls GetTopicsListExecuteFunc.

func (*DefaultApiMock) GetTopicsListExecuteCalls 

func (mock *DefaultApiMock) GetTopicsListExecuteCalls() []struct {
	R ApiGetTopicsListRequest
}

GetTopicsListExecuteCalls gets all the calls that were made to GetTopicsListExecute. Check the length with: 

len(mockedDefaultApi.GetTopicsListExecuteCalls())

func (*DefaultApiMock) Metrics 

func (mock *DefaultApiMock) Metrics(ctx context.Context) ApiMetricsRequest

Metrics calls MetricsFunc.

func (*DefaultApiMock) MetricsCalls 

func (mock *DefaultApiMock) MetricsCalls() []struct {
	Ctx context.Context
}

MetricsCalls gets all the calls that were made to Metrics. Check the length with: 

len(mockedDefaultApi.MetricsCalls())

func (*DefaultApiMock) MetricsExecute 

func (mock *DefaultApiMock) MetricsExecute(r ApiMetricsRequest) (*http.Response, error)

MetricsExecute calls MetricsExecuteFunc.

func (*DefaultApiMock) MetricsExecuteCalls 

func (mock *DefaultApiMock) MetricsExecuteCalls() []struct {
	R ApiMetricsRequest
}

MetricsExecuteCalls gets all the calls that were made to MetricsExecute. Check the length with: 

len(mockedDefaultApi.MetricsExecuteCalls())

func (*DefaultApiMock) OpenApi 

func (mock *DefaultApiMock) OpenApi(ctx context.Context) ApiOpenApiRequest

OpenApi calls OpenApiFunc.

func (*DefaultApiMock) OpenApiCalls 

func (mock *DefaultApiMock) OpenApiCalls() []struct {
	Ctx context.Context
}

OpenApiCalls gets all the calls that were made to OpenApi. Check the length with: 

len(mockedDefaultApi.OpenApiCalls())

func (*DefaultApiMock) OpenApiExecute 

func (mock *DefaultApiMock) OpenApiExecute(r ApiOpenApiRequest) (*http.Response, error)

OpenApiExecute calls OpenApiExecuteFunc.

func (*DefaultApiMock) OpenApiExecuteCalls 

func (mock *DefaultApiMock) OpenApiExecuteCalls() []struct {
	R ApiOpenApiRequest
}

OpenApiExecuteCalls gets all the calls that were made to OpenApiExecute. Check the length with: 

len(mockedDefaultApi.OpenApiExecuteCalls())

func (*DefaultApiMock) UpdateTopic 

func (mock *DefaultApiMock) UpdateTopic(ctx context.Context, topicName string) ApiUpdateTopicRequest

UpdateTopic calls UpdateTopicFunc.

func (*DefaultApiMock) UpdateTopicCalls 

func (mock *DefaultApiMock) UpdateTopicCalls() []struct {
	Ctx       context.Context
	TopicName string
}

UpdateTopicCalls gets all the calls that were made to UpdateTopic. Check the length with: 

len(mockedDefaultApi.UpdateTopicCalls())

func (*DefaultApiMock) UpdateTopicExecute 

func (mock *DefaultApiMock) UpdateTopicExecute(r ApiUpdateTopicRequest) (Topic, *http.Response, error)

UpdateTopicExecute calls UpdateTopicExecuteFunc.

func (*DefaultApiMock) UpdateTopicExecuteCalls 

func (mock *DefaultApiMock) UpdateTopicExecuteCalls() []struct {
	R ApiUpdateTopicRequest
}

UpdateTopicExecuteCalls gets all the calls that were made to UpdateTopicExecute. Check the length with: 

len(mockedDefaultApi.UpdateTopicExecuteCalls())

type DefaultApiService 

type DefaultApiService service

DefaultApiService DefaultApi service

func (*DefaultApiService) CreateTopic 

func (a *DefaultApiService) CreateTopic(ctx _context.Context) ApiCreateTopicRequest

* CreateTopic Creates a new topic * Creates a new topic for Kafka. * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return ApiCreateTopicRequest

func (*DefaultApiService) CreateTopicExecute 

func (a *DefaultApiService) CreateTopicExecute(r ApiCreateTopicRequest) (Topic, *_nethttp.Response, error)

* Execute executes the request * @return Topic

func (*DefaultApiService) DeleteConsumerGroupById 

func (a *DefaultApiService) DeleteConsumerGroupById(ctx _context.Context, consumerGroupId string) ApiDeleteConsumerGroupByIdRequest

* DeleteConsumerGroupById Delete a consumer group. * Delete a consumer group, along with its consumers. * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param consumerGroupId The unique ID of the cobsumer group. * @return ApiDeleteConsumerGroupByIdRequest

func (*DefaultApiService) DeleteConsumerGroupByIdExecute 

func (a *DefaultApiService) DeleteConsumerGroupByIdExecute(r ApiDeleteConsumerGroupByIdRequest) (*_nethttp.Response, error)

* Execute executes the request

func (*DefaultApiService) DeleteTopic 

func (a *DefaultApiService) DeleteTopic(ctx _context.Context, topicName string) ApiDeleteTopicRequest

* DeleteTopic Deletes a topic * Deletes the topic with the specified name. * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param topicName The topic name to delete. * @return ApiDeleteTopicRequest

func (*DefaultApiService) DeleteTopicExecute 

func (a *DefaultApiService) DeleteTopicExecute(r ApiDeleteTopicRequest) (*_nethttp.Response, error)

* Execute executes the request

func (*DefaultApiService) GetConsumerGroupById 

func (a *DefaultApiService) GetConsumerGroupById(ctx _context.Context, consumerGroupId string) ApiGetConsumerGroupByIdRequest

* GetConsumerGroupById Get a single consumer group by its unique ID. * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param consumerGroupId The unique ID of the consumer group * @return ApiGetConsumerGroupByIdRequest

func (*DefaultApiService) GetConsumerGroupByIdExecute 

func (a *DefaultApiService) GetConsumerGroupByIdExecute(r ApiGetConsumerGroupByIdRequest) (ConsumerGroup, *_nethttp.Response, error)

* Execute executes the request * @return ConsumerGroup

func (*DefaultApiService) GetConsumerGroupList 

func (a *DefaultApiService) GetConsumerGroupList(ctx _context.Context) ApiGetConsumerGroupListRequest

* GetConsumerGroupList List of consumer groups in the Kafka instance. * Returns a list of all consumer groups for a particular Kafka instance. * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return ApiGetConsumerGroupListRequest

func (*DefaultApiService) GetConsumerGroupListExecute 

func (a *DefaultApiService) GetConsumerGroupListExecute(r ApiGetConsumerGroupListRequest) (ConsumerGroupList, *_nethttp.Response, error)

* Execute executes the request * @return ConsumerGroupList

func (*DefaultApiService) GetTopic 

func (a *DefaultApiService) GetTopic(ctx _context.Context, topicName string) ApiGetTopicRequest

* GetTopic Retrieves the topic with the specified name. * Topic * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param topicName The topic name to retrieve. * @return ApiGetTopicRequest

func (*DefaultApiService) GetTopicExecute 

func (a *DefaultApiService) GetTopicExecute(r ApiGetTopicRequest) (Topic, *_nethttp.Response, error)

* Execute executes the request * @return Topic

func (*DefaultApiService) GetTopicsList 

func (a *DefaultApiService) GetTopicsList(ctx _context.Context) ApiGetTopicsListRequest

* GetTopicsList List of topics * Returns a list of all of the available topics, or the list of topics that meet the users URL Query Parameters. * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return ApiGetTopicsListRequest

func (*DefaultApiService) GetTopicsListExecute 

func (a *DefaultApiService) GetTopicsListExecute(r ApiGetTopicsListRequest) (TopicsList, *_nethttp.Response, error)

* Execute executes the request * @return TopicsList

func (*DefaultApiService) Metrics 

func (a *DefaultApiService) Metrics(ctx _context.Context) ApiMetricsRequest

* Metrics Admin server metrics * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return ApiMetricsRequest

func (*DefaultApiService) MetricsExecute 

func (a *DefaultApiService) MetricsExecute(r ApiMetricsRequest) (*_nethttp.Response, error)

* Execute executes the request

func (*DefaultApiService) OpenApi 

func (a *DefaultApiService) OpenApi(ctx _context.Context) ApiOpenApiRequest

* OpenApi Method for OpenApi * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return ApiOpenApiRequest

func (*DefaultApiService) OpenApiExecute 

func (a *DefaultApiService) OpenApiExecute(r ApiOpenApiRequest) (*_nethttp.Response, error)

* Execute executes the request

func (*DefaultApiService) UpdateTopic 

func (a *DefaultApiService) UpdateTopic(ctx _context.Context, topicName string) ApiUpdateTopicRequest

* UpdateTopic Updates the topic with the specified name. * updates the topic with the new data. * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param topicName The topic name which is its unique id. * @return ApiUpdateTopicRequest

func (*DefaultApiService) UpdateTopicExecute 

func (a *DefaultApiService) UpdateTopicExecute(r ApiUpdateTopicRequest) (Topic, *_nethttp.Response, error)

* Execute executes the request * @return Topic

type GenericOpenAPIError 

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

GenericOpenAPIError Provides access to the body, error and model on returned errors.

func (GenericOpenAPIError) Body 

func (e GenericOpenAPIError) Body() []byte

Body returns the raw bytes of the response

func (GenericOpenAPIError) Error 

func (e GenericOpenAPIError) Error() string

Error returns non-empty string if there was an error.

func (GenericOpenAPIError) Model 

func (e GenericOpenAPIError) Model() interface{}

Model returns the unpacked model of the error

type NewTopicInput 

type NewTopicInput struct {
	// The topic name, this value must be unique.
	Name     string        `json:"name"`
	Settings TopicSettings `json:"settings"`
}

NewTopicInput Input object to create a new topic.

func NewNewTopicInput 

func NewNewTopicInput(name string, settings TopicSettings) *NewTopicInput

NewNewTopicInput instantiates a new NewTopicInput object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewNewTopicInputWithDefaults 

func NewNewTopicInputWithDefaults() *NewTopicInput

NewNewTopicInputWithDefaults instantiates a new NewTopicInput object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*NewTopicInput) GetName 

func (o *NewTopicInput) GetName() string

GetName returns the Name field value

func (*NewTopicInput) GetNameOk 

func (o *NewTopicInput) GetNameOk() (*string, bool)

GetNameOk returns a tuple with the Name field value and a boolean to check if the value has been set.

func (*NewTopicInput) GetSettings 

func (o *NewTopicInput) GetSettings() TopicSettings

GetSettings returns the Settings field value

func (*NewTopicInput) GetSettingsOk 

func (o *NewTopicInput) GetSettingsOk() (*TopicSettings, bool)

GetSettingsOk returns a tuple with the Settings field value and a boolean to check if the value has been set.

func (NewTopicInput) MarshalJSON 

func (o NewTopicInput) MarshalJSON() ([]byte, error)

func (*NewTopicInput) SetName 

func (o *NewTopicInput) SetName(v string)

SetName sets field value

func (*NewTopicInput) SetSettings 

func (o *NewTopicInput) SetSettings(v TopicSettings)

SetSettings sets field value

type NullableBool 

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

func NewNullableBool 

func NewNullableBool(val *bool) *NullableBool

func (NullableBool) Get 

func (v NullableBool) Get() *bool

func (NullableBool) IsSet 

func (v NullableBool) IsSet() bool

func (NullableBool) MarshalJSON 

func (v NullableBool) MarshalJSON() ([]byte, error)

func (*NullableBool) Set 

func (v *NullableBool) Set(val *bool)

func (*NullableBool) UnmarshalJSON 

func (v *NullableBool) UnmarshalJSON(src []byte) error

func (*NullableBool) Unset 

func (v *NullableBool) Unset()

type NullableConfigEntry 

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

func NewNullableConfigEntry 

func NewNullableConfigEntry(val *ConfigEntry) *NullableConfigEntry

func (NullableConfigEntry) Get 

func (v NullableConfigEntry) Get() *ConfigEntry

func (NullableConfigEntry) IsSet 

func (v NullableConfigEntry) IsSet() bool

func (NullableConfigEntry) MarshalJSON 

func (v NullableConfigEntry) MarshalJSON() ([]byte, error)

func (*NullableConfigEntry) Set 

func (v *NullableConfigEntry) Set(val *ConfigEntry)

func (*NullableConfigEntry) UnmarshalJSON 

func (v *NullableConfigEntry) UnmarshalJSON(src []byte) error

func (*NullableConfigEntry) Unset 

func (v *NullableConfigEntry) Unset()

type NullableConsumer 

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

func NewNullableConsumer 

func NewNullableConsumer(val *Consumer) *NullableConsumer

func (NullableConsumer) Get 

func (v NullableConsumer) Get() *Consumer

func (NullableConsumer) IsSet 

func (v NullableConsumer) IsSet() bool

func (NullableConsumer) MarshalJSON 

func (v NullableConsumer) MarshalJSON() ([]byte, error)

func (*NullableConsumer) Set 

func (v *NullableConsumer) Set(val *Consumer)

func (*NullableConsumer) UnmarshalJSON 

func (v *NullableConsumer) UnmarshalJSON(src []byte) error

func (*NullableConsumer) Unset 

func (v *NullableConsumer) Unset()

type NullableConsumerGroup 

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

func NewNullableConsumerGroup 

func NewNullableConsumerGroup(val *ConsumerGroup) *NullableConsumerGroup

func (NullableConsumerGroup) Get 

func (v NullableConsumerGroup) Get() *ConsumerGroup

func (NullableConsumerGroup) IsSet 

func (v NullableConsumerGroup) IsSet() bool

func (NullableConsumerGroup) MarshalJSON 

func (v NullableConsumerGroup) MarshalJSON() ([]byte, error)

func (*NullableConsumerGroup) Set 

func (v *NullableConsumerGroup) Set(val *ConsumerGroup)

func (*NullableConsumerGroup) UnmarshalJSON 

func (v *NullableConsumerGroup) UnmarshalJSON(src []byte) error

func (*NullableConsumerGroup) Unset 

func (v *NullableConsumerGroup) Unset()

type NullableConsumerGroupList 

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

func NewNullableConsumerGroupList 

func NewNullableConsumerGroupList(val *ConsumerGroupList) *NullableConsumerGroupList

func (NullableConsumerGroupList) Get 

func (v NullableConsumerGroupList) Get() *ConsumerGroupList

func (NullableConsumerGroupList) IsSet 

func (v NullableConsumerGroupList) IsSet() bool

func (NullableConsumerGroupList) MarshalJSON 

func (v NullableConsumerGroupList) MarshalJSON() ([]byte, error)

func (*NullableConsumerGroupList) Set 

func (v *NullableConsumerGroupList) Set(val *ConsumerGroupList)

func (*NullableConsumerGroupList) UnmarshalJSON 

func (v *NullableConsumerGroupList) UnmarshalJSON(src []byte) error

func (*NullableConsumerGroupList) Unset 

func (v *NullableConsumerGroupList) Unset()

type NullableFloat32 

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

func NewNullableFloat32 

func NewNullableFloat32(val *float32) *NullableFloat32

func (NullableFloat32) Get 

func (v NullableFloat32) Get() *float32

func (NullableFloat32) IsSet 

func (v NullableFloat32) IsSet() bool

func (NullableFloat32) MarshalJSON 

func (v NullableFloat32) MarshalJSON() ([]byte, error)

func (*NullableFloat32) Set 

func (v *NullableFloat32) Set(val *float32)

func (*NullableFloat32) UnmarshalJSON 

func (v *NullableFloat32) UnmarshalJSON(src []byte) error

func (*NullableFloat32) Unset 

func (v *NullableFloat32) Unset()

type NullableFloat64 

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

func NewNullableFloat64 

func NewNullableFloat64(val *float64) *NullableFloat64

func (NullableFloat64) Get 

func (v NullableFloat64) Get() *float64

func (NullableFloat64) IsSet 

func (v NullableFloat64) IsSet() bool

func (NullableFloat64) MarshalJSON 

func (v NullableFloat64) MarshalJSON() ([]byte, error)

func (*NullableFloat64) Set 

func (v *NullableFloat64) Set(val *float64)

func (*NullableFloat64) UnmarshalJSON 

func (v *NullableFloat64) UnmarshalJSON(src []byte) error

func (*NullableFloat64) Unset 

func (v *NullableFloat64) Unset()

type NullableInt 

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

func NewNullableInt 

func NewNullableInt(val *int) *NullableInt

func (NullableInt) Get 

func (v NullableInt) Get() *int

func (NullableInt) IsSet 

func (v NullableInt) IsSet() bool

func (NullableInt) MarshalJSON 

func (v NullableInt) MarshalJSON() ([]byte, error)

func (*NullableInt) Set 

func (v *NullableInt) Set(val *int)

func (*NullableInt) UnmarshalJSON 

func (v *NullableInt) UnmarshalJSON(src []byte) error

func (*NullableInt) Unset 

func (v *NullableInt) Unset()

type NullableInt32 

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

func NewNullableInt32 

func NewNullableInt32(val *int32) *NullableInt32

func (NullableInt32) Get 

func (v NullableInt32) Get() *int32

func (NullableInt32) IsSet 

func (v NullableInt32) IsSet() bool

func (NullableInt32) MarshalJSON 

func (v NullableInt32) MarshalJSON() ([]byte, error)

func (*NullableInt32) Set 

func (v *NullableInt32) Set(val *int32)

func (*NullableInt32) UnmarshalJSON 

func (v *NullableInt32) UnmarshalJSON(src []byte) error

func (*NullableInt32) Unset 

func (v *NullableInt32) Unset()

type NullableInt64 

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

func NewNullableInt64 

func NewNullableInt64(val *int64) *NullableInt64

func (NullableInt64) Get 

func (v NullableInt64) Get() *int64

func (NullableInt64) IsSet 

func (v NullableInt64) IsSet() bool

func (NullableInt64) MarshalJSON 

func (v NullableInt64) MarshalJSON() ([]byte, error)

func (*NullableInt64) Set 

func (v *NullableInt64) Set(val *int64)

func (*NullableInt64) UnmarshalJSON 

func (v *NullableInt64) UnmarshalJSON(src []byte) error

func (*NullableInt64) Unset 

func (v *NullableInt64) Unset()

type NullableNewTopicInput 

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

func NewNullableNewTopicInput 

func NewNullableNewTopicInput(val *NewTopicInput) *NullableNewTopicInput

func (NullableNewTopicInput) Get 

func (v NullableNewTopicInput) Get() *NewTopicInput

func (NullableNewTopicInput) IsSet 

func (v NullableNewTopicInput) IsSet() bool

func (NullableNewTopicInput) MarshalJSON 

func (v NullableNewTopicInput) MarshalJSON() ([]byte, error)

func (*NullableNewTopicInput) Set 

func (v *NullableNewTopicInput) Set(val *NewTopicInput)

func (*NullableNewTopicInput) UnmarshalJSON 

func (v *NullableNewTopicInput) UnmarshalJSON(src []byte) error

func (*NullableNewTopicInput) Unset 

func (v *NullableNewTopicInput) Unset()

type NullablePartition 

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

func NewNullablePartition 

func NewNullablePartition(val *Partition) *NullablePartition

func (NullablePartition) Get 

func (v NullablePartition) Get() *Partition

func (NullablePartition) IsSet 

func (v NullablePartition) IsSet() bool

func (NullablePartition) MarshalJSON 

func (v NullablePartition) MarshalJSON() ([]byte, error)

func (*NullablePartition) Set 

func (v *NullablePartition) Set(val *Partition)

func (*NullablePartition) UnmarshalJSON 

func (v *NullablePartition) UnmarshalJSON(src []byte) error

func (*NullablePartition) Unset 

func (v *NullablePartition) Unset()

type NullableString 

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

func NewNullableString 

func NewNullableString(val *string) *NullableString

func (NullableString) Get 

func (v NullableString) Get() *string

func (NullableString) IsSet 

func (v NullableString) IsSet() bool

func (NullableString) MarshalJSON 

func (v NullableString) MarshalJSON() ([]byte, error)

func (*NullableString) Set 

func (v *NullableString) Set(val *string)

func (*NullableString) UnmarshalJSON 

func (v *NullableString) UnmarshalJSON(src []byte) error

func (*NullableString) Unset 

func (v *NullableString) Unset()

type NullableTime 

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

func NewNullableTime 

func NewNullableTime(val *time.Time) *NullableTime

func (NullableTime) Get 

func (v NullableTime) Get() *time.Time

func (NullableTime) IsSet 

func (v NullableTime) IsSet() bool

func (NullableTime) MarshalJSON 

func (v NullableTime) MarshalJSON() ([]byte, error)

func (*NullableTime) Set 

func (v *NullableTime) Set(val *time.Time)

func (*NullableTime) UnmarshalJSON 

func (v *NullableTime) UnmarshalJSON(src []byte) error

func (*NullableTime) Unset 

func (v *NullableTime) Unset()

type NullableTopic 

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

func NewNullableTopic 

func NewNullableTopic(val *Topic) *NullableTopic

func (NullableTopic) Get 

func (v NullableTopic) Get() *Topic

func (NullableTopic) IsSet 

func (v NullableTopic) IsSet() bool

func (NullableTopic) MarshalJSON 

func (v NullableTopic) MarshalJSON() ([]byte, error)

func (*NullableTopic) Set 

func (v *NullableTopic) Set(val *Topic)

func (*NullableTopic) UnmarshalJSON 

func (v *NullableTopic) UnmarshalJSON(src []byte) error

func (*NullableTopic) Unset 

func (v *NullableTopic) Unset()

type NullableTopicSettings 

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

func NewNullableTopicSettings 

func NewNullableTopicSettings(val *TopicSettings) *NullableTopicSettings

func (NullableTopicSettings) Get 

func (v NullableTopicSettings) Get() *TopicSettings

func (NullableTopicSettings) IsSet 

func (v NullableTopicSettings) IsSet() bool

func (NullableTopicSettings) MarshalJSON 

func (v NullableTopicSettings) MarshalJSON() ([]byte, error)

func (*NullableTopicSettings) Set 

func (v *NullableTopicSettings) Set(val *TopicSettings)

func (*NullableTopicSettings) UnmarshalJSON 

func (v *NullableTopicSettings) UnmarshalJSON(src []byte) error

func (*NullableTopicSettings) Unset 

func (v *NullableTopicSettings) Unset()

type NullableTopicsList 

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

func NewNullableTopicsList 

func NewNullableTopicsList(val *TopicsList) *NullableTopicsList

func (NullableTopicsList) Get 

func (v NullableTopicsList) Get() *TopicsList

func (NullableTopicsList) IsSet 

func (v NullableTopicsList) IsSet() bool

func (NullableTopicsList) MarshalJSON 

func (v NullableTopicsList) MarshalJSON() ([]byte, error)

func (*NullableTopicsList) Set 

func (v *NullableTopicsList) Set(val *TopicsList)

func (*NullableTopicsList) UnmarshalJSON 

func (v *NullableTopicsList) UnmarshalJSON(src []byte) error

func (*NullableTopicsList) Unset 

func (v *NullableTopicsList) Unset()

type NullableUpdateTopicInput 

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

func NewNullableUpdateTopicInput 

func NewNullableUpdateTopicInput(val *UpdateTopicInput) *NullableUpdateTopicInput

func (NullableUpdateTopicInput) Get 

func (v NullableUpdateTopicInput) Get() *UpdateTopicInput

func (NullableUpdateTopicInput) IsSet 

func (v NullableUpdateTopicInput) IsSet() bool

func (NullableUpdateTopicInput) MarshalJSON 

func (v NullableUpdateTopicInput) MarshalJSON() ([]byte, error)

func (*NullableUpdateTopicInput) Set 

func (v *NullableUpdateTopicInput) Set(val *UpdateTopicInput)

func (*NullableUpdateTopicInput) UnmarshalJSON 

func (v *NullableUpdateTopicInput) UnmarshalJSON(src []byte) error

func (*NullableUpdateTopicInput) Unset 

func (v *NullableUpdateTopicInput) Unset()

type Partition 

type Partition struct {
	// Uniquie id for the partition
	Id int32 `json:"id"`
	// List of replicas for the partition
	Replicas *[]map[string]interface{} `json:"replicas,omitempty"`
	// List isync-replicas for this partition.
	Isr *[]map[string]interface{} `json:"isr,omitempty"`
	// Kafka server / broker.
	Leader *map[string]interface{} `json:"leader,omitempty"`
}

Partition Kafka topic partition

func NewPartition 

func NewPartition(id int32) *Partition

NewPartition instantiates a new Partition object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewPartitionWithDefaults 

func NewPartitionWithDefaults() *Partition

NewPartitionWithDefaults instantiates a new Partition object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*Partition) GetId 

func (o *Partition) GetId() int32

GetId returns the Id field value

func (*Partition) GetIdOk 

func (o *Partition) GetIdOk() (*int32, bool)

GetIdOk returns a tuple with the Id field value and a boolean to check if the value has been set.

func (*Partition) GetIsr 

func (o *Partition) GetIsr() []map[string]interface{}

GetIsr returns the Isr field value if set, zero value otherwise.

func (*Partition) GetIsrOk 

func (o *Partition) GetIsrOk() (*[]map[string]interface{}, bool)

GetIsrOk returns a tuple with the Isr field value if set, nil otherwise and a boolean to check if the value has been set.

func (*Partition) GetLeader 

func (o *Partition) GetLeader() map[string]interface{}

GetLeader returns the Leader field value if set, zero value otherwise.

func (*Partition) GetLeaderOk 

func (o *Partition) GetLeaderOk() (*map[string]interface{}, bool)

GetLeaderOk returns a tuple with the Leader field value if set, nil otherwise and a boolean to check if the value has been set.

func (*Partition) GetReplicas 

func (o *Partition) GetReplicas() []map[string]interface{}

GetReplicas returns the Replicas field value if set, zero value otherwise.

func (*Partition) GetReplicasOk 

func (o *Partition) GetReplicasOk() (*[]map[string]interface{}, bool)

GetReplicasOk returns a tuple with the Replicas field value if set, nil otherwise and a boolean to check if the value has been set.

func (*Partition) HasIsr 

func (o *Partition) HasIsr() bool

HasIsr returns a boolean if a field has been set.

func (*Partition) HasLeader 

func (o *Partition) HasLeader() bool

HasLeader returns a boolean if a field has been set.

func (*Partition) HasReplicas 

func (o *Partition) HasReplicas() bool

HasReplicas returns a boolean if a field has been set.

func (Partition) MarshalJSON 

func (o Partition) MarshalJSON() ([]byte, error)

func (*Partition) SetId 

func (o *Partition) SetId(v int32)

SetId sets field value

func (*Partition) SetIsr 

func (o *Partition) SetIsr(v []map[string]interface{})

SetIsr gets a reference to the given []map[string]interface{} and assigns it to the Isr field.

func (*Partition) SetLeader 

func (o *Partition) SetLeader(v map[string]interface{})

SetLeader gets a reference to the given map[string]interface{} and assigns it to the Leader field.

func (*Partition) SetReplicas 

func (o *Partition) SetReplicas(v []map[string]interface{})

SetReplicas gets a reference to the given []map[string]interface{} and assigns it to the Replicas field.

type ServerConfiguration 

type ServerConfiguration struct {
	URL         string
	Description string
	Variables   map[string]ServerVariable
}

ServerConfiguration stores the information about a server

type ServerConfigurations 

type ServerConfigurations []ServerConfiguration

ServerConfigurations stores multiple ServerConfiguration items

func (ServerConfigurations) URL 

func (sc ServerConfigurations) URL(index int, variables map[string]string) (string, error)

URL formats template on a index using given variables

type ServerVariable 

type ServerVariable struct {
	Description  string
	DefaultValue string
	EnumValues   []string
}

ServerVariable stores the information about a server variable

type Topic 

type Topic struct {
	// The name of the topic.
	Name *string `json:"name,omitempty"`
	// Topic configuration entry.
	Config *[]ConfigEntry `json:"config,omitempty"`
	// Partitions for this topic.
	Partitions *[]Partition `json:"partitions,omitempty"`
}

Topic Kafka Topic (A feed where records are stored and published)

func NewTopic 

func NewTopic() *Topic

NewTopic instantiates a new Topic object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewTopicWithDefaults 

func NewTopicWithDefaults() *Topic

NewTopicWithDefaults instantiates a new Topic object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*Topic) GetConfig 

func (o *Topic) GetConfig() []ConfigEntry

GetConfig returns the Config field value if set, zero value otherwise.

func (*Topic) GetConfigOk 

func (o *Topic) GetConfigOk() (*[]ConfigEntry, bool)

GetConfigOk returns a tuple with the Config field value if set, nil otherwise and a boolean to check if the value has been set.

func (*Topic) GetName 

func (o *Topic) GetName() string

GetName returns the Name field value if set, zero value otherwise.

func (*Topic) GetNameOk 

func (o *Topic) GetNameOk() (*string, bool)

GetNameOk returns a tuple with the Name field value if set, nil otherwise and a boolean to check if the value has been set.

func (*Topic) GetPartitions 

func (o *Topic) GetPartitions() []Partition

GetPartitions returns the Partitions field value if set, zero value otherwise.

func (*Topic) GetPartitionsOk 

func (o *Topic) GetPartitionsOk() (*[]Partition, bool)

GetPartitionsOk returns a tuple with the Partitions field value if set, nil otherwise and a boolean to check if the value has been set.

func (*Topic) HasConfig 

func (o *Topic) HasConfig() bool

HasConfig returns a boolean if a field has been set.

func (*Topic) HasName 

func (o *Topic) HasName() bool

HasName returns a boolean if a field has been set.

func (*Topic) HasPartitions 

func (o *Topic) HasPartitions() bool

HasPartitions returns a boolean if a field has been set.

func (Topic) MarshalJSON 

func (o Topic) MarshalJSON() ([]byte, error)

func (*Topic) SetConfig 

func (o *Topic) SetConfig(v []ConfigEntry)

SetConfig gets a reference to the given []ConfigEntry and assigns it to the Config field.

func (*Topic) SetName 

func (o *Topic) SetName(v string)

SetName gets a reference to the given string and assigns it to the Name field.

func (*Topic) SetPartitions 

func (o *Topic) SetPartitions(v []Partition)

SetPartitions gets a reference to the given []Partition and assigns it to the Partitions field.

type TopicSettings 

type TopicSettings struct {
	// Number of partitions for this topic.
	NumPartitions int32 `json:"numPartitions"`
	// Topic configuration entry.
	Config *[]ConfigEntry `json:"config,omitempty"`
}

TopicSettings Kafka Topic (A feed where records are stored and published)

func NewTopicSettings 

func NewTopicSettings(numPartitions int32) *TopicSettings

NewTopicSettings instantiates a new TopicSettings object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewTopicSettingsWithDefaults 

func NewTopicSettingsWithDefaults() *TopicSettings

NewTopicSettingsWithDefaults instantiates a new TopicSettings object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*TopicSettings) GetConfig 

func (o *TopicSettings) GetConfig() []ConfigEntry

GetConfig returns the Config field value if set, zero value otherwise.

func (*TopicSettings) GetConfigOk 

func (o *TopicSettings) GetConfigOk() (*[]ConfigEntry, bool)

GetConfigOk returns a tuple with the Config field value if set, nil otherwise and a boolean to check if the value has been set.

func (*TopicSettings) GetNumPartitions 

func (o *TopicSettings) GetNumPartitions() int32

GetNumPartitions returns the NumPartitions field value

func (*TopicSettings) GetNumPartitionsOk 

func (o *TopicSettings) GetNumPartitionsOk() (*int32, bool)

GetNumPartitionsOk returns a tuple with the NumPartitions field value and a boolean to check if the value has been set.

func (*TopicSettings) HasConfig 

func (o *TopicSettings) HasConfig() bool

HasConfig returns a boolean if a field has been set.

func (TopicSettings) MarshalJSON 

func (o TopicSettings) MarshalJSON() ([]byte, error)

func (*TopicSettings) SetConfig 

func (o *TopicSettings) SetConfig(v []ConfigEntry)

SetConfig gets a reference to the given []ConfigEntry and assigns it to the Config field.

func (*TopicSettings) SetNumPartitions 

func (o *TopicSettings) SetNumPartitions(v int32)

SetNumPartitions sets field value

type TopicsList 

type TopicsList struct {
	// The page offset
	Offset int32 `json:"offset"`
	// number of entries per page
	Limit int32 `json:"limit"`
	// Total number of topics
	Count int32 `json:"count"`
	// List of topics
	Items []Topic `json:"items"`
}

TopicsList A list of topics.

func NewTopicsList 

func NewTopicsList(offset int32, limit int32, count int32, items []Topic) *TopicsList

NewTopicsList instantiates a new TopicsList object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewTopicsListWithDefaults 

func NewTopicsListWithDefaults() *TopicsList

NewTopicsListWithDefaults instantiates a new TopicsList object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*TopicsList) GetCount 

func (o *TopicsList) GetCount() int32

GetCount returns the Count field value

func (*TopicsList) GetCountOk 

func (o *TopicsList) GetCountOk() (*int32, bool)

GetCountOk returns a tuple with the Count field value and a boolean to check if the value has been set.

func (*TopicsList) GetItems 

func (o *TopicsList) GetItems() []Topic

GetItems returns the Items field value

func (*TopicsList) GetItemsOk 

func (o *TopicsList) GetItemsOk() (*[]Topic, bool)

GetItemsOk returns a tuple with the Items field value and a boolean to check if the value has been set.

func (*TopicsList) GetLimit 

func (o *TopicsList) GetLimit() int32

GetLimit returns the Limit field value

func (*TopicsList) GetLimitOk 

func (o *TopicsList) GetLimitOk() (*int32, bool)

GetLimitOk returns a tuple with the Limit field value and a boolean to check if the value has been set.

func (*TopicsList) GetOffset 

func (o *TopicsList) GetOffset() int32

GetOffset returns the Offset field value

func (*TopicsList) GetOffsetOk 

func (o *TopicsList) GetOffsetOk() (*int32, bool)

GetOffsetOk returns a tuple with the Offset field value and a boolean to check if the value has been set.

func (TopicsList) MarshalJSON 

func (o TopicsList) MarshalJSON() ([]byte, error)

func (*TopicsList) SetCount 

func (o *TopicsList) SetCount(v int32)

SetCount sets field value

func (*TopicsList) SetItems 

func (o *TopicsList) SetItems(v []Topic)

SetItems sets field value

func (*TopicsList) SetLimit 

func (o *TopicsList) SetLimit(v int32)

SetLimit sets field value

func (*TopicsList) SetOffset 

func (o *TopicsList) SetOffset(v int32)

SetOffset sets field value

type UpdateTopicInput 

type UpdateTopicInput struct {
	// Topic configuration entry.
	Config *[]ConfigEntry `json:"config,omitempty"`
}

UpdateTopicInput Kafka Topic (A feed where records are stored and published)

func NewUpdateTopicInput 

func NewUpdateTopicInput() *UpdateTopicInput

NewUpdateTopicInput instantiates a new UpdateTopicInput object This constructor will assign default values to properties that have it defined, and makes sure properties required by API are set, but the set of arguments will change when the set of required properties is changed

func NewUpdateTopicInputWithDefaults 

func NewUpdateTopicInputWithDefaults() *UpdateTopicInput

NewUpdateTopicInputWithDefaults instantiates a new UpdateTopicInput object This constructor will only assign default values to properties that have it defined, but it doesn't guarantee that properties required by API are set

func (*UpdateTopicInput) GetConfig 

func (o *UpdateTopicInput) GetConfig() []ConfigEntry

GetConfig returns the Config field value if set, zero value otherwise.

func (*UpdateTopicInput) GetConfigOk 

func (o *UpdateTopicInput) GetConfigOk() (*[]ConfigEntry, bool)

GetConfigOk returns a tuple with the Config field value if set, nil otherwise and a boolean to check if the value has been set.

func (*UpdateTopicInput) HasConfig 

func (o *UpdateTopicInput) HasConfig() bool

HasConfig returns a boolean if a field has been set.

func (UpdateTopicInput) MarshalJSON 

func (o UpdateTopicInput) MarshalJSON() ([]byte, error)

func (*UpdateTopicInput) SetConfig 

func (o *UpdateTopicInput) SetConfig(v []ConfigEntry)

SetConfig gets a reference to the given []ConfigEntry and assigns it to the Config field.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.