kafkainstanceclient

package
v0.0.0-...-26f9c4c Latest Latest
Warning

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

Go to latest
Published: Jun 28, 2023 License: Apache-2.0 Imports: 22 Imported by: 17

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 {
	AclsApi AclsApi

	ErrorsApi ErrorsApi

	GroupsApi GroupsApi

	RecordsApi RecordsApi

	TopicsApi TopicsApi
	// contains filtered or unexported fields
}

APIClient manages communication with the Kafka Instance API API v0.14.1-SNAPSHOT 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 APIResponse object.

func NewAPIResponseWithError

func NewAPIResponseWithError(errorMessage string) *APIResponse

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

type AclBinding

type AclBinding struct {
	// Unique identifier for the object. Not supported for all object kinds.
	Id   *string `json:"id,omitempty"`
	Kind *string `json:"kind,omitempty"`
	// Link path to request the object. Not supported for all object kinds.
	Href         *string         `json:"href,omitempty"`
	ResourceType AclResourceType `json:"resourceType"`
	ResourceName string          `json:"resourceName"`
	PatternType  AclPatternType  `json:"patternType"`
	// Identifies the user or service account to which an ACL entry is bound. The literal prefix value of `User:` is required. May be used to specify all users with value `User:*`.
	Principal  string            `json:"principal"`
	Operation  AclOperation      `json:"operation"`
	Permission AclPermissionType `json:"permission"`
}

AclBinding struct for AclBinding

func NewAclBinding

func NewAclBinding(resourceType AclResourceType, resourceName string, patternType AclPatternType, principal string, operation AclOperation, permission AclPermissionType) *AclBinding

NewAclBinding instantiates a new AclBinding 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 NewAclBindingWithDefaults

func NewAclBindingWithDefaults() *AclBinding

NewAclBindingWithDefaults instantiates a new AclBinding 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 (*AclBinding) GetHref

func (o *AclBinding) GetHref() string

GetHref returns the Href field value if set, zero value otherwise.

func (*AclBinding) GetHrefOk

func (o *AclBinding) GetHrefOk() (*string, bool)

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

func (*AclBinding) GetId

func (o *AclBinding) GetId() string

GetId returns the Id field value if set, zero value otherwise.

func (*AclBinding) GetIdOk

func (o *AclBinding) GetIdOk() (*string, bool)

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

func (*AclBinding) GetKind

func (o *AclBinding) GetKind() string

GetKind returns the Kind field value if set, zero value otherwise.

func (*AclBinding) GetKindOk

func (o *AclBinding) GetKindOk() (*string, bool)

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

func (*AclBinding) GetOperation

func (o *AclBinding) GetOperation() AclOperation

GetOperation returns the Operation field value

func (*AclBinding) GetOperationOk

func (o *AclBinding) GetOperationOk() (*AclOperation, bool)

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

func (*AclBinding) GetPatternType

func (o *AclBinding) GetPatternType() AclPatternType

GetPatternType returns the PatternType field value

func (*AclBinding) GetPatternTypeOk

func (o *AclBinding) GetPatternTypeOk() (*AclPatternType, bool)

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

func (*AclBinding) GetPermission

func (o *AclBinding) GetPermission() AclPermissionType

GetPermission returns the Permission field value

func (*AclBinding) GetPermissionOk

func (o *AclBinding) GetPermissionOk() (*AclPermissionType, bool)

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

func (*AclBinding) GetPrincipal

func (o *AclBinding) GetPrincipal() string

GetPrincipal returns the Principal field value

func (*AclBinding) GetPrincipalOk

func (o *AclBinding) GetPrincipalOk() (*string, bool)

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

func (*AclBinding) GetResourceName

func (o *AclBinding) GetResourceName() string

GetResourceName returns the ResourceName field value

func (*AclBinding) GetResourceNameOk

func (o *AclBinding) GetResourceNameOk() (*string, bool)

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

func (*AclBinding) GetResourceType

func (o *AclBinding) GetResourceType() AclResourceType

GetResourceType returns the ResourceType field value

func (*AclBinding) GetResourceTypeOk

func (o *AclBinding) GetResourceTypeOk() (*AclResourceType, bool)

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

func (*AclBinding) HasHref

func (o *AclBinding) HasHref() bool

HasHref returns a boolean if a field has been set.

func (*AclBinding) HasId

func (o *AclBinding) HasId() bool

HasId returns a boolean if a field has been set.

func (*AclBinding) HasKind

func (o *AclBinding) HasKind() bool

HasKind returns a boolean if a field has been set.

func (AclBinding) MarshalJSON

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

func (*AclBinding) SetHref

func (o *AclBinding) SetHref(v string)

SetHref gets a reference to the given string and assigns it to the Href field.

func (*AclBinding) SetId

func (o *AclBinding) SetId(v string)

SetId gets a reference to the given string and assigns it to the Id field.

func (*AclBinding) SetKind

func (o *AclBinding) SetKind(v string)

SetKind gets a reference to the given string and assigns it to the Kind field.

func (*AclBinding) SetOperation

func (o *AclBinding) SetOperation(v AclOperation)

SetOperation sets field value

func (*AclBinding) SetPatternType

func (o *AclBinding) SetPatternType(v AclPatternType)

SetPatternType sets field value

func (*AclBinding) SetPermission

func (o *AclBinding) SetPermission(v AclPermissionType)

SetPermission sets field value

func (*AclBinding) SetPrincipal

func (o *AclBinding) SetPrincipal(v string)

SetPrincipal sets field value

func (*AclBinding) SetResourceName

func (o *AclBinding) SetResourceName(v string)

SetResourceName sets field value

func (*AclBinding) SetResourceType

func (o *AclBinding) SetResourceType(v AclResourceType)

SetResourceType sets field value

type AclBindingAllOf

type AclBindingAllOf struct {
	ResourceType AclResourceType `json:"resourceType"`
	ResourceName string          `json:"resourceName"`
	PatternType  AclPatternType  `json:"patternType"`
	// Identifies the user or service account to which an ACL entry is bound. The literal prefix value of `User:` is required. May be used to specify all users with value `User:*`.
	Principal  string            `json:"principal"`
	Operation  AclOperation      `json:"operation"`
	Permission AclPermissionType `json:"permission"`
}

AclBindingAllOf Represents a binding between a resource pattern and an access control entry

func NewAclBindingAllOf

func NewAclBindingAllOf(resourceType AclResourceType, resourceName string, patternType AclPatternType, principal string, operation AclOperation, permission AclPermissionType) *AclBindingAllOf

NewAclBindingAllOf instantiates a new AclBindingAllOf 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 NewAclBindingAllOfWithDefaults

func NewAclBindingAllOfWithDefaults() *AclBindingAllOf

NewAclBindingAllOfWithDefaults instantiates a new AclBindingAllOf 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 (*AclBindingAllOf) GetOperation

func (o *AclBindingAllOf) GetOperation() AclOperation

GetOperation returns the Operation field value

func (*AclBindingAllOf) GetOperationOk

func (o *AclBindingAllOf) GetOperationOk() (*AclOperation, bool)

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

func (*AclBindingAllOf) GetPatternType

func (o *AclBindingAllOf) GetPatternType() AclPatternType

GetPatternType returns the PatternType field value

func (*AclBindingAllOf) GetPatternTypeOk

func (o *AclBindingAllOf) GetPatternTypeOk() (*AclPatternType, bool)

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

func (*AclBindingAllOf) GetPermission

func (o *AclBindingAllOf) GetPermission() AclPermissionType

GetPermission returns the Permission field value

func (*AclBindingAllOf) GetPermissionOk

func (o *AclBindingAllOf) GetPermissionOk() (*AclPermissionType, bool)

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

func (*AclBindingAllOf) GetPrincipal

func (o *AclBindingAllOf) GetPrincipal() string

GetPrincipal returns the Principal field value

func (*AclBindingAllOf) GetPrincipalOk

func (o *AclBindingAllOf) GetPrincipalOk() (*string, bool)

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

func (*AclBindingAllOf) GetResourceName

func (o *AclBindingAllOf) GetResourceName() string

GetResourceName returns the ResourceName field value

func (*AclBindingAllOf) GetResourceNameOk

func (o *AclBindingAllOf) GetResourceNameOk() (*string, bool)

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

func (*AclBindingAllOf) GetResourceType

func (o *AclBindingAllOf) GetResourceType() AclResourceType

GetResourceType returns the ResourceType field value

func (*AclBindingAllOf) GetResourceTypeOk

func (o *AclBindingAllOf) GetResourceTypeOk() (*AclResourceType, bool)

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

func (AclBindingAllOf) MarshalJSON

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

func (*AclBindingAllOf) SetOperation

func (o *AclBindingAllOf) SetOperation(v AclOperation)

SetOperation sets field value

func (*AclBindingAllOf) SetPatternType

func (o *AclBindingAllOf) SetPatternType(v AclPatternType)

SetPatternType sets field value

func (*AclBindingAllOf) SetPermission

func (o *AclBindingAllOf) SetPermission(v AclPermissionType)

SetPermission sets field value

func (*AclBindingAllOf) SetPrincipal

func (o *AclBindingAllOf) SetPrincipal(v string)

SetPrincipal sets field value

func (*AclBindingAllOf) SetResourceName

func (o *AclBindingAllOf) SetResourceName(v string)

SetResourceName sets field value

func (*AclBindingAllOf) SetResourceType

func (o *AclBindingAllOf) SetResourceType(v AclResourceType)

SetResourceType sets field value

type AclBindingListPage

type AclBindingListPage struct {
	Kind *string `json:"kind,omitempty"`
	// Total number of entries in the full result set
	Total int32 `json:"total"`
	// Number of entries per page (returned for fetch requests)
	Size *int32 `json:"size,omitempty"`
	// Current page number (returned for fetch requests)
	Page  *int32       `json:"page,omitempty"`
	Items []AclBinding `json:"items"`
}

AclBindingListPage struct for AclBindingListPage

func NewAclBindingListPage

func NewAclBindingListPage(total int32, items []AclBinding) *AclBindingListPage

NewAclBindingListPage instantiates a new AclBindingListPage 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 NewAclBindingListPageWithDefaults

func NewAclBindingListPageWithDefaults() *AclBindingListPage

NewAclBindingListPageWithDefaults instantiates a new AclBindingListPage 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 (*AclBindingListPage) GetItems

func (o *AclBindingListPage) GetItems() []AclBinding

GetItems returns the Items field value

func (*AclBindingListPage) GetItemsOk

func (o *AclBindingListPage) GetItemsOk() (*[]AclBinding, bool)

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

func (*AclBindingListPage) GetKind

func (o *AclBindingListPage) GetKind() string

GetKind returns the Kind field value if set, zero value otherwise.

func (*AclBindingListPage) GetKindOk

func (o *AclBindingListPage) GetKindOk() (*string, bool)

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

func (*AclBindingListPage) GetPage

func (o *AclBindingListPage) GetPage() int32

GetPage returns the Page field value if set, zero value otherwise.

func (*AclBindingListPage) GetPageOk

func (o *AclBindingListPage) GetPageOk() (*int32, bool)

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

func (*AclBindingListPage) GetSize

func (o *AclBindingListPage) GetSize() int32

GetSize returns the Size field value if set, zero value otherwise.

func (*AclBindingListPage) GetSizeOk

func (o *AclBindingListPage) GetSizeOk() (*int32, bool)

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

func (*AclBindingListPage) GetTotal

func (o *AclBindingListPage) GetTotal() int32

GetTotal returns the Total field value

func (*AclBindingListPage) GetTotalOk

func (o *AclBindingListPage) GetTotalOk() (*int32, bool)

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

func (*AclBindingListPage) HasKind

func (o *AclBindingListPage) HasKind() bool

HasKind returns a boolean if a field has been set.

func (*AclBindingListPage) HasPage

func (o *AclBindingListPage) HasPage() bool

HasPage returns a boolean if a field has been set.

func (*AclBindingListPage) HasSize

func (o *AclBindingListPage) HasSize() bool

HasSize returns a boolean if a field has been set.

func (AclBindingListPage) MarshalJSON

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

func (*AclBindingListPage) SetItems

func (o *AclBindingListPage) SetItems(v []AclBinding)

SetItems sets field value

func (*AclBindingListPage) SetKind

func (o *AclBindingListPage) SetKind(v string)

SetKind gets a reference to the given string and assigns it to the Kind field.

func (*AclBindingListPage) SetPage

func (o *AclBindingListPage) SetPage(v int32)

SetPage gets a reference to the given int32 and assigns it to the Page field.

func (*AclBindingListPage) SetSize

func (o *AclBindingListPage) SetSize(v int32)

SetSize gets a reference to the given int32 and assigns it to the Size field.

func (*AclBindingListPage) SetTotal

func (o *AclBindingListPage) SetTotal(v int32)

SetTotal sets field value

type AclBindingListPageAllOf

type AclBindingListPageAllOf struct {
	Items []AclBinding `json:"items"`
}

AclBindingListPageAllOf A page of ACL binding entries

func NewAclBindingListPageAllOf

func NewAclBindingListPageAllOf(items []AclBinding) *AclBindingListPageAllOf

NewAclBindingListPageAllOf instantiates a new AclBindingListPageAllOf 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 NewAclBindingListPageAllOfWithDefaults

func NewAclBindingListPageAllOfWithDefaults() *AclBindingListPageAllOf

NewAclBindingListPageAllOfWithDefaults instantiates a new AclBindingListPageAllOf 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 (*AclBindingListPageAllOf) GetItems

func (o *AclBindingListPageAllOf) GetItems() []AclBinding

GetItems returns the Items field value

func (*AclBindingListPageAllOf) GetItemsOk

func (o *AclBindingListPageAllOf) GetItemsOk() (*[]AclBinding, bool)

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

func (AclBindingListPageAllOf) MarshalJSON

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

func (*AclBindingListPageAllOf) SetItems

func (o *AclBindingListPageAllOf) SetItems(v []AclBinding)

SetItems sets field value

type AclBindingOrderKey

type AclBindingOrderKey string

AclBindingOrderKey the model 'AclBindingOrderKey'

const (
	ACLBINDINGORDERKEY_RESOURCE_TYPE AclBindingOrderKey = "resourceType"
	ACLBINDINGORDERKEY_RESOURCE_NAME AclBindingOrderKey = "resourceName"
	ACLBINDINGORDERKEY_PATTERN_TYPE  AclBindingOrderKey = "patternType"
	ACLBINDINGORDERKEY_PRINCIPAL     AclBindingOrderKey = "principal"
	ACLBINDINGORDERKEY_OPERATION     AclBindingOrderKey = "operation"
	ACLBINDINGORDERKEY_PERMISSION    AclBindingOrderKey = "permission"
)

List of AclBindingOrderKey

func NewAclBindingOrderKeyFromValue

func NewAclBindingOrderKeyFromValue(v string) (*AclBindingOrderKey, error)

NewAclBindingOrderKeyFromValue returns a pointer to a valid AclBindingOrderKey for the value passed as argument, or an error if the value passed is not allowed by the enum

func (AclBindingOrderKey) IsValid

func (v AclBindingOrderKey) IsValid() bool

IsValid return true if the value is valid for the enum, false otherwise

func (AclBindingOrderKey) Ptr

Ptr returns reference to AclBindingOrderKey value

func (*AclBindingOrderKey) UnmarshalJSON

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

type AclOperation

type AclOperation string

AclOperation the model 'AclOperation'

const (
	ACLOPERATION_ALL              AclOperation = "ALL"
	ACLOPERATION_READ             AclOperation = "READ"
	ACLOPERATION_WRITE            AclOperation = "WRITE"
	ACLOPERATION_CREATE           AclOperation = "CREATE"
	ACLOPERATION_DELETE           AclOperation = "DELETE"
	ACLOPERATION_ALTER            AclOperation = "ALTER"
	ACLOPERATION_DESCRIBE         AclOperation = "DESCRIBE"
	ACLOPERATION_DESCRIBE_CONFIGS AclOperation = "DESCRIBE_CONFIGS"
	ACLOPERATION_ALTER_CONFIGS    AclOperation = "ALTER_CONFIGS"
)

List of AclOperation

func NewAclOperationFromValue

func NewAclOperationFromValue(v string) (*AclOperation, error)

NewAclOperationFromValue returns a pointer to a valid AclOperation for the value passed as argument, or an error if the value passed is not allowed by the enum

func (AclOperation) IsValid

func (v AclOperation) IsValid() bool

IsValid return true if the value is valid for the enum, false otherwise

func (AclOperation) Ptr

func (v AclOperation) Ptr() *AclOperation

Ptr returns reference to AclOperation value

func (*AclOperation) UnmarshalJSON

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

type AclOperationFilter

type AclOperationFilter string

AclOperationFilter the model 'AclOperationFilter'

const (
	ACLOPERATIONFILTER_ALL              AclOperationFilter = "ALL"
	ACLOPERATIONFILTER_READ             AclOperationFilter = "READ"
	ACLOPERATIONFILTER_WRITE            AclOperationFilter = "WRITE"
	ACLOPERATIONFILTER_CREATE           AclOperationFilter = "CREATE"
	ACLOPERATIONFILTER_DELETE           AclOperationFilter = "DELETE"
	ACLOPERATIONFILTER_ALTER            AclOperationFilter = "ALTER"
	ACLOPERATIONFILTER_DESCRIBE         AclOperationFilter = "DESCRIBE"
	ACLOPERATIONFILTER_DESCRIBE_CONFIGS AclOperationFilter = "DESCRIBE_CONFIGS"
	ACLOPERATIONFILTER_ALTER_CONFIGS    AclOperationFilter = "ALTER_CONFIGS"
	ACLOPERATIONFILTER_ANY              AclOperationFilter = "ANY"
)

List of AclOperationFilter

func NewAclOperationFilterFromValue

func NewAclOperationFilterFromValue(v string) (*AclOperationFilter, error)

NewAclOperationFilterFromValue returns a pointer to a valid AclOperationFilter for the value passed as argument, or an error if the value passed is not allowed by the enum

func (AclOperationFilter) IsValid

func (v AclOperationFilter) IsValid() bool

IsValid return true if the value is valid for the enum, false otherwise

func (AclOperationFilter) Ptr

Ptr returns reference to AclOperationFilter value

func (*AclOperationFilter) UnmarshalJSON

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

type AclPatternType

type AclPatternType string

AclPatternType the model 'AclPatternType'

const (
	ACLPATTERNTYPE_LITERAL  AclPatternType = "LITERAL"
	ACLPATTERNTYPE_PREFIXED AclPatternType = "PREFIXED"
)

List of AclPatternType

func NewAclPatternTypeFromValue

func NewAclPatternTypeFromValue(v string) (*AclPatternType, error)

NewAclPatternTypeFromValue returns a pointer to a valid AclPatternType for the value passed as argument, or an error if the value passed is not allowed by the enum

func (AclPatternType) IsValid

func (v AclPatternType) IsValid() bool

IsValid return true if the value is valid for the enum, false otherwise

func (AclPatternType) Ptr

func (v AclPatternType) Ptr() *AclPatternType

Ptr returns reference to AclPatternType value

func (*AclPatternType) UnmarshalJSON

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

type AclPatternTypeFilter

type AclPatternTypeFilter string

AclPatternTypeFilter Use value 'MATCH' to perform pattern matching.

const (
	ACLPATTERNTYPEFILTER_LITERAL  AclPatternTypeFilter = "LITERAL"
	ACLPATTERNTYPEFILTER_PREFIXED AclPatternTypeFilter = "PREFIXED"
	ACLPATTERNTYPEFILTER_ANY      AclPatternTypeFilter = "ANY"
	ACLPATTERNTYPEFILTER_MATCH    AclPatternTypeFilter = "MATCH"
)

List of AclPatternTypeFilter

func NewAclPatternTypeFilterFromValue

func NewAclPatternTypeFilterFromValue(v string) (*AclPatternTypeFilter, error)

NewAclPatternTypeFilterFromValue returns a pointer to a valid AclPatternTypeFilter for the value passed as argument, or an error if the value passed is not allowed by the enum

func (AclPatternTypeFilter) IsValid

func (v AclPatternTypeFilter) IsValid() bool

IsValid return true if the value is valid for the enum, false otherwise

func (AclPatternTypeFilter) Ptr

Ptr returns reference to AclPatternTypeFilter value

func (*AclPatternTypeFilter) UnmarshalJSON

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

type AclPermissionType

type AclPermissionType string

AclPermissionType the model 'AclPermissionType'

const (
	ACLPERMISSIONTYPE_ALLOW AclPermissionType = "ALLOW"
	ACLPERMISSIONTYPE_DENY  AclPermissionType = "DENY"
)

List of AclPermissionType

func NewAclPermissionTypeFromValue

func NewAclPermissionTypeFromValue(v string) (*AclPermissionType, error)

NewAclPermissionTypeFromValue returns a pointer to a valid AclPermissionType for the value passed as argument, or an error if the value passed is not allowed by the enum

func (AclPermissionType) IsValid

func (v AclPermissionType) IsValid() bool

IsValid return true if the value is valid for the enum, false otherwise

func (AclPermissionType) Ptr

Ptr returns reference to AclPermissionType value

func (*AclPermissionType) UnmarshalJSON

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

type AclPermissionTypeFilter

type AclPermissionTypeFilter string

AclPermissionTypeFilter the model 'AclPermissionTypeFilter'

const (
	ACLPERMISSIONTYPEFILTER_ALLOW AclPermissionTypeFilter = "ALLOW"
	ACLPERMISSIONTYPEFILTER_DENY  AclPermissionTypeFilter = "DENY"
	ACLPERMISSIONTYPEFILTER_ANY   AclPermissionTypeFilter = "ANY"
)

List of AclPermissionTypeFilter

func NewAclPermissionTypeFilterFromValue

func NewAclPermissionTypeFilterFromValue(v string) (*AclPermissionTypeFilter, error)

NewAclPermissionTypeFilterFromValue returns a pointer to a valid AclPermissionTypeFilter for the value passed as argument, or an error if the value passed is not allowed by the enum

func (AclPermissionTypeFilter) IsValid

func (v AclPermissionTypeFilter) IsValid() bool

IsValid return true if the value is valid for the enum, false otherwise

func (AclPermissionTypeFilter) Ptr

Ptr returns reference to AclPermissionTypeFilter value

func (*AclPermissionTypeFilter) UnmarshalJSON

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

type AclResourceType

type AclResourceType string

AclResourceType the model 'AclResourceType'

const (
	ACLRESOURCETYPE_GROUP            AclResourceType = "GROUP"
	ACLRESOURCETYPE_TOPIC            AclResourceType = "TOPIC"
	ACLRESOURCETYPE_CLUSTER          AclResourceType = "CLUSTER"
	ACLRESOURCETYPE_TRANSACTIONAL_ID AclResourceType = "TRANSACTIONAL_ID"
)

List of AclResourceType

func NewAclResourceTypeFromValue

func NewAclResourceTypeFromValue(v string) (*AclResourceType, error)

NewAclResourceTypeFromValue returns a pointer to a valid AclResourceType for the value passed as argument, or an error if the value passed is not allowed by the enum

func (AclResourceType) IsValid

func (v AclResourceType) IsValid() bool

IsValid return true if the value is valid for the enum, false otherwise

func (AclResourceType) Ptr

Ptr returns reference to AclResourceType value

func (*AclResourceType) UnmarshalJSON

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

type AclResourceTypeFilter

type AclResourceTypeFilter string

AclResourceTypeFilter the model 'AclResourceTypeFilter'

const (
	ACLRESOURCETYPEFILTER_ANY              AclResourceTypeFilter = "ANY"
	ACLRESOURCETYPEFILTER_GROUP            AclResourceTypeFilter = "GROUP"
	ACLRESOURCETYPEFILTER_TOPIC            AclResourceTypeFilter = "TOPIC"
	ACLRESOURCETYPEFILTER_CLUSTER          AclResourceTypeFilter = "CLUSTER"
	ACLRESOURCETYPEFILTER_TRANSACTIONAL_ID AclResourceTypeFilter = "TRANSACTIONAL_ID"
)

List of AclResourceTypeFilter

func NewAclResourceTypeFilterFromValue

func NewAclResourceTypeFilterFromValue(v string) (*AclResourceTypeFilter, error)

NewAclResourceTypeFilterFromValue returns a pointer to a valid AclResourceTypeFilter for the value passed as argument, or an error if the value passed is not allowed by the enum

func (AclResourceTypeFilter) IsValid

func (v AclResourceTypeFilter) IsValid() bool

IsValid return true if the value is valid for the enum, false otherwise

func (AclResourceTypeFilter) Ptr

Ptr returns reference to AclResourceTypeFilter value

func (*AclResourceTypeFilter) UnmarshalJSON

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

type AclsApi

type AclsApi interface {

	/*
	 * CreateAcl Create ACL binding
	 * Creates a new ACL binding for a Kafka instance.
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return ApiCreateAclRequest
	 */
	CreateAcl(ctx _context.Context) ApiCreateAclRequest

	/*
	 * CreateAclExecute executes the request
	 */
	CreateAclExecute(r ApiCreateAclRequest) (*_nethttp.Response, error)

	/*
	 * DeleteAcls Delete ACL bindings
	 * Deletes ACL bindings that match the query parameters.
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return ApiDeleteAclsRequest
	 */
	DeleteAcls(ctx _context.Context) ApiDeleteAclsRequest

	/*
	 * DeleteAclsExecute executes the request
	 * @return AclBindingListPage
	 */
	DeleteAclsExecute(r ApiDeleteAclsRequest) (AclBindingListPage, *_nethttp.Response, error)

	/*
	 * GetAclResourceOperations Retrieve allowed ACL resources and operations
	 * Retrieve the resources and associated operations that may have ACLs configured.
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return ApiGetAclResourceOperationsRequest
	 */
	GetAclResourceOperations(ctx _context.Context) ApiGetAclResourceOperationsRequest

	/*
	 * GetAclResourceOperationsExecute executes the request
	 * @return map[string][]string
	 */
	GetAclResourceOperationsExecute(r ApiGetAclResourceOperationsRequest) (map[string][]string, *_nethttp.Response, error)

	/*
	 * GetAcls List ACL bindings
	 * Returns a list of all of the available ACL bindings, or the list of bindings that meet the user's URL query parameters. If no parameters are specified, all ACL bindings known to the system will be returned (with paging).
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return ApiGetAclsRequest
	 */
	GetAcls(ctx _context.Context) ApiGetAclsRequest

	/*
	 * GetAclsExecute executes the request
	 * @return AclBindingListPage
	 */
	GetAclsExecute(r ApiGetAclsRequest) (AclBindingListPage, *_nethttp.Response, error)
}

type AclsApiService

type AclsApiService service

AclsApiService AclsApi service

func (*AclsApiService) CreateAcl

* CreateAcl Create ACL binding * Creates a new ACL binding for a Kafka instance. * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return ApiCreateAclRequest

func (*AclsApiService) CreateAclExecute

func (a *AclsApiService) CreateAclExecute(r ApiCreateAclRequest) (*_nethttp.Response, error)

* Execute executes the request

func (*AclsApiService) DeleteAcls

* DeleteAcls Delete ACL bindings * Deletes ACL bindings that match the query parameters. * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return ApiDeleteAclsRequest

func (*AclsApiService) DeleteAclsExecute

* Execute executes the request * @return AclBindingListPage

func (*AclsApiService) GetAclResourceOperations

func (a *AclsApiService) GetAclResourceOperations(ctx _context.Context) ApiGetAclResourceOperationsRequest

* GetAclResourceOperations Retrieve allowed ACL resources and operations * Retrieve the resources and associated operations that may have ACLs configured. * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return ApiGetAclResourceOperationsRequest

func (*AclsApiService) GetAclResourceOperationsExecute

func (a *AclsApiService) GetAclResourceOperationsExecute(r ApiGetAclResourceOperationsRequest) (map[string][]string, *_nethttp.Response, error)

* Execute executes the request * @return map[string][]string

func (*AclsApiService) GetAcls

* GetAcls List ACL bindings * Returns a list of all of the available ACL bindings, or the list of bindings that meet the user's URL query parameters. If no parameters are specified, all ACL bindings known to the system will be returned (with paging). * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return ApiGetAclsRequest

func (*AclsApiService) GetAclsExecute

* Execute executes the request * @return AclBindingListPage

type ApiConsumeRecordsRequest

type ApiConsumeRecordsRequest struct {
	ApiService RecordsApi
	// contains filtered or unexported fields
}

func (ApiConsumeRecordsRequest) Execute

func (ApiConsumeRecordsRequest) Include

func (ApiConsumeRecordsRequest) Limit

func (ApiConsumeRecordsRequest) MaxValueLength

func (r ApiConsumeRecordsRequest) MaxValueLength(maxValueLength int32) ApiConsumeRecordsRequest

func (ApiConsumeRecordsRequest) Offset

func (ApiConsumeRecordsRequest) Partition

func (ApiConsumeRecordsRequest) Timestamp

func (r ApiConsumeRecordsRequest) Timestamp(timestamp interface{}) ApiConsumeRecordsRequest

type ApiCreateAclRequest

type ApiCreateAclRequest struct {
	ApiService AclsApi
	// contains filtered or unexported fields
}

func (ApiCreateAclRequest) AclBinding

func (r ApiCreateAclRequest) AclBinding(aclBinding AclBinding) ApiCreateAclRequest

func (ApiCreateAclRequest) Execute

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

type ApiCreateTopicRequest

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

func (ApiCreateTopicRequest) Execute

func (ApiCreateTopicRequest) NewTopicInput

func (r ApiCreateTopicRequest) NewTopicInput(newTopicInput NewTopicInput) ApiCreateTopicRequest

type ApiDeleteAclsRequest

type ApiDeleteAclsRequest struct {
	ApiService AclsApi
	// contains filtered or unexported fields
}

func (ApiDeleteAclsRequest) Execute

func (ApiDeleteAclsRequest) Operation

func (ApiDeleteAclsRequest) PatternType

func (ApiDeleteAclsRequest) Permission

func (ApiDeleteAclsRequest) Principal

func (r ApiDeleteAclsRequest) Principal(principal string) ApiDeleteAclsRequest

func (ApiDeleteAclsRequest) ResourceName

func (r ApiDeleteAclsRequest) ResourceName(resourceName string) ApiDeleteAclsRequest

func (ApiDeleteAclsRequest) ResourceType

type ApiDeleteConsumerGroupByIdRequest

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

func (ApiDeleteConsumerGroupByIdRequest) Execute

type ApiDeleteTopicRequest

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

func (ApiDeleteTopicRequest) Execute

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

type ApiGetAclResourceOperationsRequest

type ApiGetAclResourceOperationsRequest struct {
	ApiService AclsApi
	// contains filtered or unexported fields
}

func (ApiGetAclResourceOperationsRequest) Execute

type ApiGetAclsRequest

type ApiGetAclsRequest struct {
	ApiService AclsApi
	// contains filtered or unexported fields
}

func (ApiGetAclsRequest) Execute

func (ApiGetAclsRequest) Operation

func (ApiGetAclsRequest) Order

func (ApiGetAclsRequest) OrderKey

func (ApiGetAclsRequest) Page

func (ApiGetAclsRequest) PatternType

func (r ApiGetAclsRequest) PatternType(patternType AclPatternTypeFilter) ApiGetAclsRequest

func (ApiGetAclsRequest) Permission

func (ApiGetAclsRequest) Principal

func (r ApiGetAclsRequest) Principal(principal string) ApiGetAclsRequest

func (ApiGetAclsRequest) ResourceName

func (r ApiGetAclsRequest) ResourceName(resourceName string) ApiGetAclsRequest

func (ApiGetAclsRequest) ResourceType

func (r ApiGetAclsRequest) ResourceType(resourceType AclResourceTypeFilter) ApiGetAclsRequest

func (ApiGetAclsRequest) Size

type ApiGetConsumerGroupByIdRequest

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

func (ApiGetConsumerGroupByIdRequest) Execute

func (ApiGetConsumerGroupByIdRequest) Order

func (ApiGetConsumerGroupByIdRequest) OrderKey

func (ApiGetConsumerGroupByIdRequest) PartitionFilter

func (r ApiGetConsumerGroupByIdRequest) PartitionFilter(partitionFilter int32) ApiGetConsumerGroupByIdRequest

func (ApiGetConsumerGroupByIdRequest) Topic

type ApiGetConsumerGroupsRequest

type ApiGetConsumerGroupsRequest struct {
	ApiService GroupsApi
	// contains filtered or unexported fields
}

func (ApiGetConsumerGroupsRequest) Execute

func (ApiGetConsumerGroupsRequest) GroupIdFilter

func (r ApiGetConsumerGroupsRequest) GroupIdFilter(groupIdFilter string) ApiGetConsumerGroupsRequest

func (ApiGetConsumerGroupsRequest) Limit

func (ApiGetConsumerGroupsRequest) Offset

func (ApiGetConsumerGroupsRequest) Order

func (ApiGetConsumerGroupsRequest) OrderKey

func (ApiGetConsumerGroupsRequest) Page

func (ApiGetConsumerGroupsRequest) Size

func (ApiGetConsumerGroupsRequest) Topic

type ApiGetErrorRequest

type ApiGetErrorRequest struct {
	ApiService ErrorsApi
	// contains filtered or unexported fields
}

func (ApiGetErrorRequest) Execute

func (r ApiGetErrorRequest) Execute() (Error, *_nethttp.Response, error)

type ApiGetErrorsRequest

type ApiGetErrorsRequest struct {
	ApiService ErrorsApi
	// contains filtered or unexported fields
}

func (ApiGetErrorsRequest) Execute

type ApiGetTopicRequest

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

func (ApiGetTopicRequest) Execute

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

type ApiGetTopicsRequest

type ApiGetTopicsRequest struct {
	ApiService TopicsApi
	// contains filtered or unexported fields
}

func (ApiGetTopicsRequest) Execute

func (ApiGetTopicsRequest) Filter

func (ApiGetTopicsRequest) Limit

func (ApiGetTopicsRequest) Offset

func (ApiGetTopicsRequest) Order

func (ApiGetTopicsRequest) OrderKey

func (ApiGetTopicsRequest) Page

func (ApiGetTopicsRequest) Size

type ApiProduceRecordRequest

type ApiProduceRecordRequest struct {
	ApiService RecordsApi
	// contains filtered or unexported fields
}

func (ApiProduceRecordRequest) Execute

func (ApiProduceRecordRequest) Record

type ApiResetConsumerGroupOffsetRequest

type ApiResetConsumerGroupOffsetRequest struct {
	ApiService GroupsApi
	// contains filtered or unexported fields
}

func (ApiResetConsumerGroupOffsetRequest) ConsumerGroupResetOffsetParameters

func (r ApiResetConsumerGroupOffsetRequest) ConsumerGroupResetOffsetParameters(consumerGroupResetOffsetParameters ConsumerGroupResetOffsetParameters) ApiResetConsumerGroupOffsetRequest

func (ApiResetConsumerGroupOffsetRequest) Execute

type ApiUpdateTopicRequest

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

func (ApiUpdateTopicRequest) Execute

func (ApiUpdateTopicRequest) TopicSettings

func (r ApiUpdateTopicRequest) TopicSettings(topicSettings TopicSettings) 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"`
	// Value to indicate the setting on the topic configuration entry.
	Value string `json:"value"`
}

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

func NewConfigEntry

func NewConfigEntry(key string, value string) *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

func (*ConfigEntry) GetKeyOk

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

GetKeyOk returns a tuple with the Key field value 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

func (*ConfigEntry) GetValueOk

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

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

func (ConfigEntry) MarshalJSON

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

func (*ConfigEntry) SetKey

func (o *ConfigEntry) SetKey(v string)

SetKey sets field value

func (*ConfigEntry) SetValue

func (o *ConfigEntry) SetValue(v string)

SetValue sets field value

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 int64 `json:"offset"`
	// The log end offset is the offset of the last message written to a log.
	LogEndOffset *int64 `json:"logEndOffset,omitempty"`
	// Offset Lag is the delta between the last produced message and the last consumer's committed offset.
	Lag int64 `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 int64, lag int64) *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() int64

GetLag returns the Lag field value

func (*Consumer) GetLagOk

func (o *Consumer) GetLagOk() (*int64, 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() int64

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

func (*Consumer) GetLogEndOffsetOk

func (o *Consumer) GetLogEndOffsetOk() (*int64, 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() int64

GetOffset returns the Offset field value

func (*Consumer) GetOffsetOk

func (o *Consumer) GetOffsetOk() (*int64, 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 int64)

SetLag sets field value

func (*Consumer) SetLogEndOffset

func (o *Consumer) SetLogEndOffset(v int64)

SetLogEndOffset gets a reference to the given int64 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 int64)

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 object. Not supported for all object kinds.
	Id   *string `json:"id,omitempty"`
	Kind *string `json:"kind,omitempty"`
	// Link path to request the object. Not supported for all object kinds.
	Href *string `json:"href,omitempty"`
	// Unique identifier for the consumer group
	GroupId string              `json:"groupId"`
	State   *ConsumerGroupState `json:"state,omitempty"`
	// The list of consumers associated with this consumer group
	Consumers []Consumer            `json:"consumers"`
	Metrics   *ConsumerGroupMetrics `json:"metrics,omitempty"`
}

ConsumerGroup struct for ConsumerGroup

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) GetHref

func (o *ConsumerGroup) GetHref() string

GetHref returns the Href field value if set, zero value otherwise.

func (*ConsumerGroup) GetHrefOk

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

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

func (*ConsumerGroup) GetId

func (o *ConsumerGroup) GetId() string

GetId returns the Id field value if set, zero value otherwise.

func (*ConsumerGroup) GetIdOk

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

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

func (*ConsumerGroup) GetKind

func (o *ConsumerGroup) GetKind() string

GetKind returns the Kind field value if set, zero value otherwise.

func (*ConsumerGroup) GetKindOk

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

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

func (*ConsumerGroup) GetMetrics

func (o *ConsumerGroup) GetMetrics() ConsumerGroupMetrics

GetMetrics returns the Metrics field value if set, zero value otherwise.

func (*ConsumerGroup) GetMetricsOk

func (o *ConsumerGroup) GetMetricsOk() (*ConsumerGroupMetrics, bool)

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

func (*ConsumerGroup) GetState

func (o *ConsumerGroup) GetState() ConsumerGroupState

GetState returns the State field value if set, zero value otherwise.

func (*ConsumerGroup) GetStateOk

func (o *ConsumerGroup) GetStateOk() (*ConsumerGroupState, bool)

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

func (*ConsumerGroup) HasHref

func (o *ConsumerGroup) HasHref() bool

HasHref returns a boolean if a field has been set.

func (*ConsumerGroup) HasId

func (o *ConsumerGroup) HasId() bool

HasId returns a boolean if a field has been set.

func (*ConsumerGroup) HasKind

func (o *ConsumerGroup) HasKind() bool

HasKind returns a boolean if a field has been set.

func (*ConsumerGroup) HasMetrics

func (o *ConsumerGroup) HasMetrics() bool

HasMetrics returns a boolean if a field has been set.

func (*ConsumerGroup) HasState

func (o *ConsumerGroup) HasState() bool

HasState returns a boolean if a field 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

func (*ConsumerGroup) SetHref

func (o *ConsumerGroup) SetHref(v string)

SetHref gets a reference to the given string and assigns it to the Href field.

func (*ConsumerGroup) SetId

func (o *ConsumerGroup) SetId(v string)

SetId gets a reference to the given string and assigns it to the Id field.

func (*ConsumerGroup) SetKind

func (o *ConsumerGroup) SetKind(v string)

SetKind gets a reference to the given string and assigns it to the Kind field.

func (*ConsumerGroup) SetMetrics

func (o *ConsumerGroup) SetMetrics(v ConsumerGroupMetrics)

SetMetrics gets a reference to the given ConsumerGroupMetrics and assigns it to the Metrics field.

func (*ConsumerGroup) SetState

func (o *ConsumerGroup) SetState(v ConsumerGroupState)

SetState gets a reference to the given ConsumerGroupState and assigns it to the State field.

type ConsumerGroupAllOf

type ConsumerGroupAllOf struct {
	// Unique identifier for the consumer group
	GroupId string              `json:"groupId"`
	State   *ConsumerGroupState `json:"state,omitempty"`
	// The list of consumers associated with this consumer group
	Consumers []Consumer            `json:"consumers"`
	Metrics   *ConsumerGroupMetrics `json:"metrics,omitempty"`
}

ConsumerGroupAllOf A group of Kafka consumers

func NewConsumerGroupAllOf

func NewConsumerGroupAllOf(groupId string, consumers []Consumer) *ConsumerGroupAllOf

NewConsumerGroupAllOf instantiates a new ConsumerGroupAllOf 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 NewConsumerGroupAllOfWithDefaults

func NewConsumerGroupAllOfWithDefaults() *ConsumerGroupAllOf

NewConsumerGroupAllOfWithDefaults instantiates a new ConsumerGroupAllOf 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 (*ConsumerGroupAllOf) GetConsumers

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

GetConsumers returns the Consumers field value

func (*ConsumerGroupAllOf) GetConsumersOk

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

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

func (*ConsumerGroupAllOf) GetGroupId

func (o *ConsumerGroupAllOf) GetGroupId() string

GetGroupId returns the GroupId field value

func (*ConsumerGroupAllOf) GetGroupIdOk

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

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

func (*ConsumerGroupAllOf) GetMetrics

func (o *ConsumerGroupAllOf) GetMetrics() ConsumerGroupMetrics

GetMetrics returns the Metrics field value if set, zero value otherwise.

func (*ConsumerGroupAllOf) GetMetricsOk

func (o *ConsumerGroupAllOf) GetMetricsOk() (*ConsumerGroupMetrics, bool)

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

func (*ConsumerGroupAllOf) GetState

func (o *ConsumerGroupAllOf) GetState() ConsumerGroupState

GetState returns the State field value if set, zero value otherwise.

func (*ConsumerGroupAllOf) GetStateOk

func (o *ConsumerGroupAllOf) GetStateOk() (*ConsumerGroupState, bool)

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

func (*ConsumerGroupAllOf) HasMetrics

func (o *ConsumerGroupAllOf) HasMetrics() bool

HasMetrics returns a boolean if a field has been set.

func (*ConsumerGroupAllOf) HasState

func (o *ConsumerGroupAllOf) HasState() bool

HasState returns a boolean if a field has been set.

func (ConsumerGroupAllOf) MarshalJSON

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

func (*ConsumerGroupAllOf) SetConsumers

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

SetConsumers sets field value

func (*ConsumerGroupAllOf) SetGroupId

func (o *ConsumerGroupAllOf) SetGroupId(v string)

SetGroupId sets field value

func (*ConsumerGroupAllOf) SetMetrics

func (o *ConsumerGroupAllOf) SetMetrics(v ConsumerGroupMetrics)

SetMetrics gets a reference to the given ConsumerGroupMetrics and assigns it to the Metrics field.

func (*ConsumerGroupAllOf) SetState

func (o *ConsumerGroupAllOf) SetState(v ConsumerGroupState)

SetState gets a reference to the given ConsumerGroupState and assigns it to the State field.

type ConsumerGroupDescriptionOrderKey

type ConsumerGroupDescriptionOrderKey string

ConsumerGroupDescriptionOrderKey the model 'ConsumerGroupDescriptionOrderKey'

const (
	CONSUMERGROUPDESCRIPTIONORDERKEY_OFFSET     ConsumerGroupDescriptionOrderKey = "offset"
	CONSUMERGROUPDESCRIPTIONORDERKEY_END_OFFSET ConsumerGroupDescriptionOrderKey = "endOffset"
	CONSUMERGROUPDESCRIPTIONORDERKEY_LAG        ConsumerGroupDescriptionOrderKey = "lag"
	CONSUMERGROUPDESCRIPTIONORDERKEY_PARTITION  ConsumerGroupDescriptionOrderKey = "partition"
)

List of ConsumerGroupDescriptionOrderKey

func NewConsumerGroupDescriptionOrderKeyFromValue

func NewConsumerGroupDescriptionOrderKeyFromValue(v string) (*ConsumerGroupDescriptionOrderKey, error)

NewConsumerGroupDescriptionOrderKeyFromValue returns a pointer to a valid ConsumerGroupDescriptionOrderKey for the value passed as argument, or an error if the value passed is not allowed by the enum

func (ConsumerGroupDescriptionOrderKey) IsValid

IsValid return true if the value is valid for the enum, false otherwise

func (ConsumerGroupDescriptionOrderKey) Ptr

Ptr returns reference to ConsumerGroupDescriptionOrderKey value

func (*ConsumerGroupDescriptionOrderKey) UnmarshalJSON

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

type ConsumerGroupList

type ConsumerGroupList struct {
	Kind *string `json:"kind,omitempty"`
	// Total number of entries in the full result set
	Total int32 `json:"total"`
	// Number of entries per page (returned for fetch requests)
	Size *int32 `json:"size,omitempty"`
	// Current page number (returned for fetch requests)
	Page *int32 `json:"page,omitempty"`
	// Offset of the first record returned, zero-based
	Offset *int32 `json:"offset,omitempty"`
	// Maximum number of records to return, from request
	Limit *int32 `json:"limit,omitempty"`
	// Total number of entries in the full result set
	Count *int32          `json:"count,omitempty"`
	Items []ConsumerGroup `json:"items"`
}

ConsumerGroupList struct for ConsumerGroupList

func NewConsumerGroupList

func NewConsumerGroupList(total int32, items []ConsumerGroup) *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() int32

GetCount returns the Count field value if set, zero value otherwise.

func (*ConsumerGroupList) GetCountOk

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

GetCountOk returns a tuple with the Count field value if set, nil otherwise 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) GetKind

func (o *ConsumerGroupList) GetKind() string

GetKind returns the Kind field value if set, zero value otherwise.

func (*ConsumerGroupList) GetKindOk

func (o *ConsumerGroupList) GetKindOk() (*string, bool)

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

func (*ConsumerGroupList) GetLimit

func (o *ConsumerGroupList) GetLimit() int32

GetLimit returns the Limit field value if set, zero value otherwise.

func (*ConsumerGroupList) GetLimitOk

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

GetLimitOk returns a tuple with the Limit field value if set, nil otherwise 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 if set, zero value otherwise.

func (*ConsumerGroupList) GetOffsetOk

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

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

func (*ConsumerGroupList) GetPage

func (o *ConsumerGroupList) GetPage() int32

GetPage returns the Page field value if set, zero value otherwise.

func (*ConsumerGroupList) GetPageOk

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

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

func (*ConsumerGroupList) GetSize

func (o *ConsumerGroupList) GetSize() int32

GetSize returns the Size field value if set, zero value otherwise.

func (*ConsumerGroupList) GetSizeOk

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

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

func (*ConsumerGroupList) GetTotal

func (o *ConsumerGroupList) GetTotal() int32

GetTotal returns the Total field value

func (*ConsumerGroupList) GetTotalOk

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

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

func (*ConsumerGroupList) HasCount

func (o *ConsumerGroupList) HasCount() bool

HasCount returns a boolean if a field has been set.

func (*ConsumerGroupList) HasKind

func (o *ConsumerGroupList) HasKind() bool

HasKind returns a boolean if a field has been set.

func (*ConsumerGroupList) HasLimit

func (o *ConsumerGroupList) HasLimit() bool

HasLimit returns a boolean if a field has been set.

func (*ConsumerGroupList) HasOffset

func (o *ConsumerGroupList) HasOffset() bool

HasOffset returns a boolean if a field has been set.

func (*ConsumerGroupList) HasPage

func (o *ConsumerGroupList) HasPage() bool

HasPage returns a boolean if a field has been set.

func (*ConsumerGroupList) HasSize

func (o *ConsumerGroupList) HasSize() bool

HasSize returns a boolean if a field has been set.

func (ConsumerGroupList) MarshalJSON

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

func (*ConsumerGroupList) SetCount

func (o *ConsumerGroupList) SetCount(v int32)

SetCount gets a reference to the given int32 and assigns it to the Count field.

func (*ConsumerGroupList) SetItems

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

SetItems sets field value

func (*ConsumerGroupList) SetKind

func (o *ConsumerGroupList) SetKind(v string)

SetKind gets a reference to the given string and assigns it to the Kind field.

func (*ConsumerGroupList) SetLimit

func (o *ConsumerGroupList) SetLimit(v int32)

SetLimit gets a reference to the given int32 and assigns it to the Limit field.

func (*ConsumerGroupList) SetOffset

func (o *ConsumerGroupList) SetOffset(v int32)

SetOffset gets a reference to the given int32 and assigns it to the Offset field.

func (*ConsumerGroupList) SetPage

func (o *ConsumerGroupList) SetPage(v int32)

SetPage gets a reference to the given int32 and assigns it to the Page field.

func (*ConsumerGroupList) SetSize

func (o *ConsumerGroupList) SetSize(v int32)

SetSize gets a reference to the given int32 and assigns it to the Size field.

func (*ConsumerGroupList) SetTotal

func (o *ConsumerGroupList) SetTotal(v int32)

SetTotal sets field value

type ConsumerGroupListAllOf

type ConsumerGroupListAllOf struct {
	Items []ConsumerGroup `json:"items"`
}

ConsumerGroupListAllOf A list of consumer groups

func NewConsumerGroupListAllOf

func NewConsumerGroupListAllOf(items []ConsumerGroup) *ConsumerGroupListAllOf

NewConsumerGroupListAllOf instantiates a new ConsumerGroupListAllOf 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 NewConsumerGroupListAllOfWithDefaults

func NewConsumerGroupListAllOfWithDefaults() *ConsumerGroupListAllOf

NewConsumerGroupListAllOfWithDefaults instantiates a new ConsumerGroupListAllOf 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 (*ConsumerGroupListAllOf) GetItems

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

GetItems returns the Items field value

func (*ConsumerGroupListAllOf) GetItemsOk

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

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

func (ConsumerGroupListAllOf) MarshalJSON

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

func (*ConsumerGroupListAllOf) SetItems

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

SetItems sets field value

type ConsumerGroupMetrics

type ConsumerGroupMetrics struct {
	LaggingPartitions    *int32 `json:"laggingPartitions,omitempty"`
	ActiveConsumers      *int32 `json:"activeConsumers,omitempty"`
	UnassignedPartitions *int32 `json:"unassignedPartitions,omitempty"`
}

ConsumerGroupMetrics struct for ConsumerGroupMetrics

func NewConsumerGroupMetrics

func NewConsumerGroupMetrics() *ConsumerGroupMetrics

NewConsumerGroupMetrics instantiates a new ConsumerGroupMetrics 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 NewConsumerGroupMetricsWithDefaults

func NewConsumerGroupMetricsWithDefaults() *ConsumerGroupMetrics

NewConsumerGroupMetricsWithDefaults instantiates a new ConsumerGroupMetrics 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 (*ConsumerGroupMetrics) GetActiveConsumers

func (o *ConsumerGroupMetrics) GetActiveConsumers() int32

GetActiveConsumers returns the ActiveConsumers field value if set, zero value otherwise.

func (*ConsumerGroupMetrics) GetActiveConsumersOk

func (o *ConsumerGroupMetrics) GetActiveConsumersOk() (*int32, bool)

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

func (*ConsumerGroupMetrics) GetLaggingPartitions

func (o *ConsumerGroupMetrics) GetLaggingPartitions() int32

GetLaggingPartitions returns the LaggingPartitions field value if set, zero value otherwise.

func (*ConsumerGroupMetrics) GetLaggingPartitionsOk

func (o *ConsumerGroupMetrics) GetLaggingPartitionsOk() (*int32, bool)

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

func (*ConsumerGroupMetrics) GetUnassignedPartitions

func (o *ConsumerGroupMetrics) GetUnassignedPartitions() int32

GetUnassignedPartitions returns the UnassignedPartitions field value if set, zero value otherwise.

func (*ConsumerGroupMetrics) GetUnassignedPartitionsOk

func (o *ConsumerGroupMetrics) GetUnassignedPartitionsOk() (*int32, bool)

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

func (*ConsumerGroupMetrics) HasActiveConsumers

func (o *ConsumerGroupMetrics) HasActiveConsumers() bool

HasActiveConsumers returns a boolean if a field has been set.

func (*ConsumerGroupMetrics) HasLaggingPartitions

func (o *ConsumerGroupMetrics) HasLaggingPartitions() bool

HasLaggingPartitions returns a boolean if a field has been set.

func (*ConsumerGroupMetrics) HasUnassignedPartitions

func (o *ConsumerGroupMetrics) HasUnassignedPartitions() bool

HasUnassignedPartitions returns a boolean if a field has been set.

func (ConsumerGroupMetrics) MarshalJSON

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

func (*ConsumerGroupMetrics) SetActiveConsumers

func (o *ConsumerGroupMetrics) SetActiveConsumers(v int32)

SetActiveConsumers gets a reference to the given int32 and assigns it to the ActiveConsumers field.

func (*ConsumerGroupMetrics) SetLaggingPartitions

func (o *ConsumerGroupMetrics) SetLaggingPartitions(v int32)

SetLaggingPartitions gets a reference to the given int32 and assigns it to the LaggingPartitions field.

func (*ConsumerGroupMetrics) SetUnassignedPartitions

func (o *ConsumerGroupMetrics) SetUnassignedPartitions(v int32)

SetUnassignedPartitions gets a reference to the given int32 and assigns it to the UnassignedPartitions field.

type ConsumerGroupOrderKey

type ConsumerGroupOrderKey string

ConsumerGroupOrderKey the model 'ConsumerGroupOrderKey'

const (
	CONSUMERGROUPORDERKEY_NAME ConsumerGroupOrderKey = "name"
)

List of ConsumerGroupOrderKey

func NewConsumerGroupOrderKeyFromValue

func NewConsumerGroupOrderKeyFromValue(v string) (*ConsumerGroupOrderKey, error)

NewConsumerGroupOrderKeyFromValue returns a pointer to a valid ConsumerGroupOrderKey for the value passed as argument, or an error if the value passed is not allowed by the enum

func (ConsumerGroupOrderKey) IsValid

func (v ConsumerGroupOrderKey) IsValid() bool

IsValid return true if the value is valid for the enum, false otherwise

func (ConsumerGroupOrderKey) Ptr

Ptr returns reference to ConsumerGroupOrderKey value

func (*ConsumerGroupOrderKey) UnmarshalJSON

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

type ConsumerGroupResetOffsetParameters

type ConsumerGroupResetOffsetParameters struct {
	Offset OffsetType `json:"offset"`
	// Value associated with the given `offset`. Not used for `offset` values `earliest` and `latest`. When `offset` is `timestamp` then `value` must be a valid timestamp representing the point in time to reset the consumer group. When `offset` is `absolute` then `value` must be the integer offset to which the consumer group will be reset.
	Value  *string                `json:"value,omitempty"`
	Topics *[]TopicsToResetOffset `json:"topics,omitempty"`
}

ConsumerGroupResetOffsetParameters struct for ConsumerGroupResetOffsetParameters

func NewConsumerGroupResetOffsetParameters

func NewConsumerGroupResetOffsetParameters(offset OffsetType) *ConsumerGroupResetOffsetParameters

NewConsumerGroupResetOffsetParameters instantiates a new ConsumerGroupResetOffsetParameters 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 NewConsumerGroupResetOffsetParametersWithDefaults

func NewConsumerGroupResetOffsetParametersWithDefaults() *ConsumerGroupResetOffsetParameters

NewConsumerGroupResetOffsetParametersWithDefaults instantiates a new ConsumerGroupResetOffsetParameters 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 (*ConsumerGroupResetOffsetParameters) GetOffset

GetOffset returns the Offset field value

func (*ConsumerGroupResetOffsetParameters) GetOffsetOk

func (o *ConsumerGroupResetOffsetParameters) GetOffsetOk() (*OffsetType, bool)

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

func (*ConsumerGroupResetOffsetParameters) GetTopics

GetTopics returns the Topics field value if set, zero value otherwise.

func (*ConsumerGroupResetOffsetParameters) GetTopicsOk

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

func (*ConsumerGroupResetOffsetParameters) GetValue

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

func (*ConsumerGroupResetOffsetParameters) GetValueOk

func (o *ConsumerGroupResetOffsetParameters) 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 (*ConsumerGroupResetOffsetParameters) HasTopics

HasTopics returns a boolean if a field has been set.

func (*ConsumerGroupResetOffsetParameters) HasValue

HasValue returns a boolean if a field has been set.

func (ConsumerGroupResetOffsetParameters) MarshalJSON

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

func (*ConsumerGroupResetOffsetParameters) SetOffset

SetOffset sets field value

func (*ConsumerGroupResetOffsetParameters) SetTopics

SetTopics gets a reference to the given []TopicsToResetOffset and assigns it to the Topics field.

func (*ConsumerGroupResetOffsetParameters) SetValue

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

type ConsumerGroupResetOffsetResult

type ConsumerGroupResetOffsetResult struct {
	Kind *string `json:"kind,omitempty"`
	// Total number of entries in the full result set
	Total int32 `json:"total"`
	// Number of entries per page (returned for fetch requests)
	Size *int32 `json:"size,omitempty"`
	// Current page number (returned for fetch requests)
	Page  *int32                               `json:"page,omitempty"`
	Items []ConsumerGroupResetOffsetResultItem `json:"items"`
}

ConsumerGroupResetOffsetResult struct for ConsumerGroupResetOffsetResult

func NewConsumerGroupResetOffsetResult

func NewConsumerGroupResetOffsetResult(total int32, items []ConsumerGroupResetOffsetResultItem) *ConsumerGroupResetOffsetResult

NewConsumerGroupResetOffsetResult instantiates a new ConsumerGroupResetOffsetResult 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 NewConsumerGroupResetOffsetResultWithDefaults

func NewConsumerGroupResetOffsetResultWithDefaults() *ConsumerGroupResetOffsetResult

NewConsumerGroupResetOffsetResultWithDefaults instantiates a new ConsumerGroupResetOffsetResult 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 (*ConsumerGroupResetOffsetResult) GetItems

GetItems returns the Items field value

func (*ConsumerGroupResetOffsetResult) GetItemsOk

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

func (*ConsumerGroupResetOffsetResult) GetKind

GetKind returns the Kind field value if set, zero value otherwise.

func (*ConsumerGroupResetOffsetResult) GetKindOk

func (o *ConsumerGroupResetOffsetResult) GetKindOk() (*string, bool)

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

func (*ConsumerGroupResetOffsetResult) GetPage

GetPage returns the Page field value if set, zero value otherwise.

func (*ConsumerGroupResetOffsetResult) GetPageOk

func (o *ConsumerGroupResetOffsetResult) GetPageOk() (*int32, bool)

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

func (*ConsumerGroupResetOffsetResult) GetSize

GetSize returns the Size field value if set, zero value otherwise.

func (*ConsumerGroupResetOffsetResult) GetSizeOk

func (o *ConsumerGroupResetOffsetResult) GetSizeOk() (*int32, bool)

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

func (*ConsumerGroupResetOffsetResult) GetTotal

func (o *ConsumerGroupResetOffsetResult) GetTotal() int32

GetTotal returns the Total field value

func (*ConsumerGroupResetOffsetResult) GetTotalOk

func (o *ConsumerGroupResetOffsetResult) GetTotalOk() (*int32, bool)

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

func (*ConsumerGroupResetOffsetResult) HasKind

func (o *ConsumerGroupResetOffsetResult) HasKind() bool

HasKind returns a boolean if a field has been set.

func (*ConsumerGroupResetOffsetResult) HasPage

func (o *ConsumerGroupResetOffsetResult) HasPage() bool

HasPage returns a boolean if a field has been set.

func (*ConsumerGroupResetOffsetResult) HasSize

func (o *ConsumerGroupResetOffsetResult) HasSize() bool

HasSize returns a boolean if a field has been set.

func (ConsumerGroupResetOffsetResult) MarshalJSON

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

func (*ConsumerGroupResetOffsetResult) SetItems

SetItems sets field value

func (*ConsumerGroupResetOffsetResult) SetKind

func (o *ConsumerGroupResetOffsetResult) SetKind(v string)

SetKind gets a reference to the given string and assigns it to the Kind field.

func (*ConsumerGroupResetOffsetResult) SetPage

func (o *ConsumerGroupResetOffsetResult) SetPage(v int32)

SetPage gets a reference to the given int32 and assigns it to the Page field.

func (*ConsumerGroupResetOffsetResult) SetSize

func (o *ConsumerGroupResetOffsetResult) SetSize(v int32)

SetSize gets a reference to the given int32 and assigns it to the Size field.

func (*ConsumerGroupResetOffsetResult) SetTotal

func (o *ConsumerGroupResetOffsetResult) SetTotal(v int32)

SetTotal sets field value

type ConsumerGroupResetOffsetResultAllOf

type ConsumerGroupResetOffsetResultAllOf struct {
	Items []ConsumerGroupResetOffsetResultItem `json:"items"`
}

ConsumerGroupResetOffsetResultAllOf struct for ConsumerGroupResetOffsetResultAllOf

func NewConsumerGroupResetOffsetResultAllOf

func NewConsumerGroupResetOffsetResultAllOf(items []ConsumerGroupResetOffsetResultItem) *ConsumerGroupResetOffsetResultAllOf

NewConsumerGroupResetOffsetResultAllOf instantiates a new ConsumerGroupResetOffsetResultAllOf 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 NewConsumerGroupResetOffsetResultAllOfWithDefaults

func NewConsumerGroupResetOffsetResultAllOfWithDefaults() *ConsumerGroupResetOffsetResultAllOf

NewConsumerGroupResetOffsetResultAllOfWithDefaults instantiates a new ConsumerGroupResetOffsetResultAllOf 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 (*ConsumerGroupResetOffsetResultAllOf) GetItems

GetItems returns the Items field value

func (*ConsumerGroupResetOffsetResultAllOf) GetItemsOk

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

func (ConsumerGroupResetOffsetResultAllOf) MarshalJSON

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

func (*ConsumerGroupResetOffsetResultAllOf) SetItems

SetItems sets field value

type ConsumerGroupResetOffsetResultItem

type ConsumerGroupResetOffsetResultItem struct {
	Topic     *string `json:"topic,omitempty"`
	Partition *int32  `json:"partition,omitempty"`
	Offset    *int64  `json:"offset,omitempty"`
}

ConsumerGroupResetOffsetResultItem struct for ConsumerGroupResetOffsetResultItem

func NewConsumerGroupResetOffsetResultItem

func NewConsumerGroupResetOffsetResultItem() *ConsumerGroupResetOffsetResultItem

NewConsumerGroupResetOffsetResultItem instantiates a new ConsumerGroupResetOffsetResultItem 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 NewConsumerGroupResetOffsetResultItemWithDefaults

func NewConsumerGroupResetOffsetResultItemWithDefaults() *ConsumerGroupResetOffsetResultItem

NewConsumerGroupResetOffsetResultItemWithDefaults instantiates a new ConsumerGroupResetOffsetResultItem 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 (*ConsumerGroupResetOffsetResultItem) GetOffset

GetOffset returns the Offset field value if set, zero value otherwise.

func (*ConsumerGroupResetOffsetResultItem) GetOffsetOk

func (o *ConsumerGroupResetOffsetResultItem) GetOffsetOk() (*int64, bool)

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

func (*ConsumerGroupResetOffsetResultItem) GetPartition

func (o *ConsumerGroupResetOffsetResultItem) GetPartition() int32

GetPartition returns the Partition field value if set, zero value otherwise.

func (*ConsumerGroupResetOffsetResultItem) GetPartitionOk

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

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

func (*ConsumerGroupResetOffsetResultItem) GetTopic

GetTopic returns the Topic field value if set, zero value otherwise.

func (*ConsumerGroupResetOffsetResultItem) GetTopicOk

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

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

func (*ConsumerGroupResetOffsetResultItem) HasOffset

HasOffset returns a boolean if a field has been set.

func (*ConsumerGroupResetOffsetResultItem) HasPartition

func (o *ConsumerGroupResetOffsetResultItem) HasPartition() bool

HasPartition returns a boolean if a field has been set.

func (*ConsumerGroupResetOffsetResultItem) HasTopic

HasTopic returns a boolean if a field has been set.

func (ConsumerGroupResetOffsetResultItem) MarshalJSON

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

func (*ConsumerGroupResetOffsetResultItem) SetOffset

func (o *ConsumerGroupResetOffsetResultItem) SetOffset(v int64)

SetOffset gets a reference to the given int64 and assigns it to the Offset field.

func (*ConsumerGroupResetOffsetResultItem) SetPartition

func (o *ConsumerGroupResetOffsetResultItem) SetPartition(v int32)

SetPartition gets a reference to the given int32 and assigns it to the Partition field.

func (*ConsumerGroupResetOffsetResultItem) SetTopic

SetTopic gets a reference to the given string and assigns it to the Topic field.

type ConsumerGroupState

type ConsumerGroupState string

ConsumerGroupState the model 'ConsumerGroupState'

const (
	CONSUMERGROUPSTATE_UNKNOWN              ConsumerGroupState = "UNKNOWN"
	CONSUMERGROUPSTATE_PREPARING_REBALANCE  ConsumerGroupState = "PREPARING_REBALANCE"
	CONSUMERGROUPSTATE_COMPLETING_REBALANCE ConsumerGroupState = "COMPLETING_REBALANCE"
	CONSUMERGROUPSTATE_STABLE               ConsumerGroupState = "STABLE"
	CONSUMERGROUPSTATE_DEAD                 ConsumerGroupState = "DEAD"
	CONSUMERGROUPSTATE_EMPTY                ConsumerGroupState = "EMPTY"
)

List of ConsumerGroupState

func NewConsumerGroupStateFromValue

func NewConsumerGroupStateFromValue(v string) (*ConsumerGroupState, error)

NewConsumerGroupStateFromValue returns a pointer to a valid ConsumerGroupState for the value passed as argument, or an error if the value passed is not allowed by the enum

func (ConsumerGroupState) IsValid

func (v ConsumerGroupState) IsValid() bool

IsValid return true if the value is valid for the enum, false otherwise

func (ConsumerGroupState) Ptr

Ptr returns reference to ConsumerGroupState value

func (*ConsumerGroupState) UnmarshalJSON

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

type Error

type Error struct {
	// Unique identifier for the object. Not supported for all object kinds.
	Id   *string `json:"id,omitempty"`
	Kind *string `json:"kind,omitempty"`
	// Link path to request the object. Not supported for all object kinds.
	Href *string `json:"href,omitempty"`
	// General reason for the error. Does not change between specific occurrences.
	Reason *string `json:"reason,omitempty"`
	// Detail specific to an error occurrence. May be different depending on the condition(s) that trigger the error.
	Detail       *string `json:"detail,omitempty"`
	Code         *int32  `json:"code,omitempty"`
	ErrorMessage *string `json:"error_message,omitempty"`
	Class        *string `json:"class,omitempty"`
}

Error struct for Error

func NewError

func NewError() *Error

NewError instantiates a new Error 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 NewErrorWithDefaults

func NewErrorWithDefaults() *Error

NewErrorWithDefaults instantiates a new Error 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 (*Error) GetClass

func (o *Error) GetClass() string

GetClass returns the Class field value if set, zero value otherwise.

func (*Error) GetClassOk

func (o *Error) GetClassOk() (*string, bool)

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

func (*Error) GetCode

func (o *Error) GetCode() int32

GetCode returns the Code field value if set, zero value otherwise.

func (*Error) GetCodeOk

func (o *Error) GetCodeOk() (*int32, bool)

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

func (*Error) GetDetail

func (o *Error) GetDetail() string

GetDetail returns the Detail field value if set, zero value otherwise.

func (*Error) GetDetailOk

func (o *Error) GetDetailOk() (*string, bool)

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

func (*Error) GetErrorMessage

func (o *Error) GetErrorMessage() string

GetErrorMessage returns the ErrorMessage field value if set, zero value otherwise.

func (*Error) GetErrorMessageOk

func (o *Error) GetErrorMessageOk() (*string, bool)

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

func (*Error) GetHref

func (o *Error) GetHref() string

GetHref returns the Href field value if set, zero value otherwise.

func (*Error) GetHrefOk

func (o *Error) GetHrefOk() (*string, bool)

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

func (*Error) GetId

func (o *Error) GetId() string

GetId returns the Id field value if set, zero value otherwise.

func (*Error) GetIdOk

func (o *Error) GetIdOk() (*string, bool)

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

func (*Error) GetKind

func (o *Error) GetKind() string

GetKind returns the Kind field value if set, zero value otherwise.

func (*Error) GetKindOk

func (o *Error) GetKindOk() (*string, bool)

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

func (*Error) GetReason

func (o *Error) GetReason() string

GetReason returns the Reason field value if set, zero value otherwise.

func (*Error) GetReasonOk

func (o *Error) GetReasonOk() (*string, bool)

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

func (*Error) HasClass

func (o *Error) HasClass() bool

HasClass returns a boolean if a field has been set.

func (*Error) HasCode

func (o *Error) HasCode() bool

HasCode returns a boolean if a field has been set.

func (*Error) HasDetail

func (o *Error) HasDetail() bool

HasDetail returns a boolean if a field has been set.

func (*Error) HasErrorMessage

func (o *Error) HasErrorMessage() bool

HasErrorMessage returns a boolean if a field has been set.

func (*Error) HasHref

func (o *Error) HasHref() bool

HasHref returns a boolean if a field has been set.

func (*Error) HasId

func (o *Error) HasId() bool

HasId returns a boolean if a field has been set.

func (*Error) HasKind

func (o *Error) HasKind() bool

HasKind returns a boolean if a field has been set.

func (*Error) HasReason

func (o *Error) HasReason() bool

HasReason returns a boolean if a field has been set.

func (Error) MarshalJSON

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

func (*Error) SetClass

func (o *Error) SetClass(v string)

SetClass gets a reference to the given string and assigns it to the Class field.

func (*Error) SetCode

func (o *Error) SetCode(v int32)

SetCode gets a reference to the given int32 and assigns it to the Code field.

func (*Error) SetDetail

func (o *Error) SetDetail(v string)

SetDetail gets a reference to the given string and assigns it to the Detail field.

func (*Error) SetErrorMessage

func (o *Error) SetErrorMessage(v string)

SetErrorMessage gets a reference to the given string and assigns it to the ErrorMessage field.

func (*Error) SetHref

func (o *Error) SetHref(v string)

SetHref gets a reference to the given string and assigns it to the Href field.

func (*Error) SetId

func (o *Error) SetId(v string)

SetId gets a reference to the given string and assigns it to the Id field.

func (*Error) SetKind

func (o *Error) SetKind(v string)

SetKind gets a reference to the given string and assigns it to the Kind field.

func (*Error) SetReason

func (o *Error) SetReason(v string)

SetReason gets a reference to the given string and assigns it to the Reason field.

type ErrorAllOf

type ErrorAllOf struct {
	// General reason for the error. Does not change between specific occurrences.
	Reason *string `json:"reason,omitempty"`
	// Detail specific to an error occurrence. May be different depending on the condition(s) that trigger the error.
	Detail       *string `json:"detail,omitempty"`
	Code         *int32  `json:"code,omitempty"`
	ErrorMessage *string `json:"error_message,omitempty"`
	Class        *string `json:"class,omitempty"`
}

ErrorAllOf General error response

func NewErrorAllOf

func NewErrorAllOf() *ErrorAllOf

NewErrorAllOf instantiates a new ErrorAllOf 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 NewErrorAllOfWithDefaults

func NewErrorAllOfWithDefaults() *ErrorAllOf

NewErrorAllOfWithDefaults instantiates a new ErrorAllOf 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 (*ErrorAllOf) GetClass

func (o *ErrorAllOf) GetClass() string

GetClass returns the Class field value if set, zero value otherwise.

func (*ErrorAllOf) GetClassOk

func (o *ErrorAllOf) GetClassOk() (*string, bool)

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

func (*ErrorAllOf) GetCode

func (o *ErrorAllOf) GetCode() int32

GetCode returns the Code field value if set, zero value otherwise.

func (*ErrorAllOf) GetCodeOk

func (o *ErrorAllOf) GetCodeOk() (*int32, bool)

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

func (*ErrorAllOf) GetDetail

func (o *ErrorAllOf) GetDetail() string

GetDetail returns the Detail field value if set, zero value otherwise.

func (*ErrorAllOf) GetDetailOk

func (o *ErrorAllOf) GetDetailOk() (*string, bool)

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

func (*ErrorAllOf) GetErrorMessage

func (o *ErrorAllOf) GetErrorMessage() string

GetErrorMessage returns the ErrorMessage field value if set, zero value otherwise.

func (*ErrorAllOf) GetErrorMessageOk

func (o *ErrorAllOf) GetErrorMessageOk() (*string, bool)

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

func (*ErrorAllOf) GetReason

func (o *ErrorAllOf) GetReason() string

GetReason returns the Reason field value if set, zero value otherwise.

func (*ErrorAllOf) GetReasonOk

func (o *ErrorAllOf) GetReasonOk() (*string, bool)

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

func (*ErrorAllOf) HasClass

func (o *ErrorAllOf) HasClass() bool

HasClass returns a boolean if a field has been set.

func (*ErrorAllOf) HasCode

func (o *ErrorAllOf) HasCode() bool

HasCode returns a boolean if a field has been set.

func (*ErrorAllOf) HasDetail

func (o *ErrorAllOf) HasDetail() bool

HasDetail returns a boolean if a field has been set.

func (*ErrorAllOf) HasErrorMessage

func (o *ErrorAllOf) HasErrorMessage() bool

HasErrorMessage returns a boolean if a field has been set.

func (*ErrorAllOf) HasReason

func (o *ErrorAllOf) HasReason() bool

HasReason returns a boolean if a field has been set.

func (ErrorAllOf) MarshalJSON

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

func (*ErrorAllOf) SetClass

func (o *ErrorAllOf) SetClass(v string)

SetClass gets a reference to the given string and assigns it to the Class field.

func (*ErrorAllOf) SetCode

func (o *ErrorAllOf) SetCode(v int32)

SetCode gets a reference to the given int32 and assigns it to the Code field.

func (*ErrorAllOf) SetDetail

func (o *ErrorAllOf) SetDetail(v string)

SetDetail gets a reference to the given string and assigns it to the Detail field.

func (*ErrorAllOf) SetErrorMessage

func (o *ErrorAllOf) SetErrorMessage(v string)

SetErrorMessage gets a reference to the given string and assigns it to the ErrorMessage field.

func (*ErrorAllOf) SetReason

func (o *ErrorAllOf) SetReason(v string)

SetReason gets a reference to the given string and assigns it to the Reason field.

type ErrorList

type ErrorList struct {
	Kind *string `json:"kind,omitempty"`
	// Total number of errors returned in this request
	Total int32 `json:"total"`
	// Number of entries per page (returned for fetch requests)
	Size *int32 `json:"size,omitempty"`
	// Current page number (returned for fetch requests)
	Page  *int32  `json:"page,omitempty"`
	Items []Error `json:"items"`
}

ErrorList struct for ErrorList

func NewErrorList

func NewErrorList(total int32, items []Error) *ErrorList

NewErrorList instantiates a new ErrorList 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 NewErrorListWithDefaults

func NewErrorListWithDefaults() *ErrorList

NewErrorListWithDefaults instantiates a new ErrorList 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 (*ErrorList) GetItems

func (o *ErrorList) GetItems() []Error

GetItems returns the Items field value

func (*ErrorList) GetItemsOk

func (o *ErrorList) GetItemsOk() (*[]Error, bool)

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

func (*ErrorList) GetKind

func (o *ErrorList) GetKind() string

GetKind returns the Kind field value if set, zero value otherwise.

func (*ErrorList) GetKindOk

func (o *ErrorList) GetKindOk() (*string, bool)

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

func (*ErrorList) GetPage

func (o *ErrorList) GetPage() int32

GetPage returns the Page field value if set, zero value otherwise.

func (*ErrorList) GetPageOk

func (o *ErrorList) GetPageOk() (*int32, bool)

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

func (*ErrorList) GetSize

func (o *ErrorList) GetSize() int32

GetSize returns the Size field value if set, zero value otherwise.

func (*ErrorList) GetSizeOk

func (o *ErrorList) GetSizeOk() (*int32, bool)

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

func (*ErrorList) GetTotal

func (o *ErrorList) GetTotal() int32

GetTotal returns the Total field value

func (*ErrorList) GetTotalOk

func (o *ErrorList) GetTotalOk() (*int32, bool)

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

func (*ErrorList) HasKind

func (o *ErrorList) HasKind() bool

HasKind returns a boolean if a field has been set.

func (*ErrorList) HasPage

func (o *ErrorList) HasPage() bool

HasPage returns a boolean if a field has been set.

func (*ErrorList) HasSize

func (o *ErrorList) HasSize() bool

HasSize returns a boolean if a field has been set.

func (ErrorList) MarshalJSON

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

func (*ErrorList) SetItems

func (o *ErrorList) SetItems(v []Error)

SetItems sets field value

func (*ErrorList) SetKind

func (o *ErrorList) SetKind(v string)

SetKind gets a reference to the given string and assigns it to the Kind field.

func (*ErrorList) SetPage

func (o *ErrorList) SetPage(v int32)

SetPage gets a reference to the given int32 and assigns it to the Page field.

func (*ErrorList) SetSize

func (o *ErrorList) SetSize(v int32)

SetSize gets a reference to the given int32 and assigns it to the Size field.

func (*ErrorList) SetTotal

func (o *ErrorList) SetTotal(v int32)

SetTotal sets field value

type ErrorListAllOf

type ErrorListAllOf struct {
	Items []Error `json:"items"`
	// Total number of errors returned in this request
	Total *int32 `json:"total,omitempty"`
}

ErrorListAllOf List of errors

func NewErrorListAllOf

func NewErrorListAllOf(items []Error) *ErrorListAllOf

NewErrorListAllOf instantiates a new ErrorListAllOf 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 NewErrorListAllOfWithDefaults

func NewErrorListAllOfWithDefaults() *ErrorListAllOf

NewErrorListAllOfWithDefaults instantiates a new ErrorListAllOf 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 (*ErrorListAllOf) GetItems

func (o *ErrorListAllOf) GetItems() []Error

GetItems returns the Items field value

func (*ErrorListAllOf) GetItemsOk

func (o *ErrorListAllOf) GetItemsOk() (*[]Error, bool)

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

func (*ErrorListAllOf) GetTotal

func (o *ErrorListAllOf) GetTotal() int32

GetTotal returns the Total field value if set, zero value otherwise.

func (*ErrorListAllOf) GetTotalOk

func (o *ErrorListAllOf) GetTotalOk() (*int32, bool)

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

func (*ErrorListAllOf) HasTotal

func (o *ErrorListAllOf) HasTotal() bool

HasTotal returns a boolean if a field has been set.

func (ErrorListAllOf) MarshalJSON

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

func (*ErrorListAllOf) SetItems

func (o *ErrorListAllOf) SetItems(v []Error)

SetItems sets field value

func (*ErrorListAllOf) SetTotal

func (o *ErrorListAllOf) SetTotal(v int32)

SetTotal gets a reference to the given int32 and assigns it to the Total field.

type ErrorsApi

type ErrorsApi interface {

	/*
	 * GetError Get an error by its unique ID
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param errorId Error identifier
	 * @return ApiGetErrorRequest
	 */
	GetError(ctx _context.Context, errorId string) ApiGetErrorRequest

	/*
	 * GetErrorExecute executes the request
	 * @return Error
	 */
	GetErrorExecute(r ApiGetErrorRequest) (Error, *_nethttp.Response, error)

	/*
	 * GetErrors Get list of errors
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return ApiGetErrorsRequest
	 */
	GetErrors(ctx _context.Context) ApiGetErrorsRequest

	/*
	 * GetErrorsExecute executes the request
	 * @return ErrorList
	 */
	GetErrorsExecute(r ApiGetErrorsRequest) (ErrorList, *_nethttp.Response, error)
}

type ErrorsApiService

type ErrorsApiService service

ErrorsApiService ErrorsApi service

func (*ErrorsApiService) GetError

func (a *ErrorsApiService) GetError(ctx _context.Context, errorId string) ApiGetErrorRequest

* GetError Get an error by its unique ID * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param errorId Error identifier * @return ApiGetErrorRequest

func (*ErrorsApiService) GetErrorExecute

func (a *ErrorsApiService) GetErrorExecute(r ApiGetErrorRequest) (Error, *_nethttp.Response, error)

* Execute executes the request * @return Error

func (*ErrorsApiService) GetErrors

* GetErrors Get list of errors * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return ApiGetErrorsRequest

func (*ErrorsApiService) GetErrorsExecute

* Execute executes the request * @return ErrorList

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 GroupsApi

type GroupsApi interface {

	/*
	 * 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 Consumer group identifier
	 * @return ApiDeleteConsumerGroupByIdRequest
	 */
	DeleteConsumerGroupById(ctx _context.Context, consumerGroupId string) ApiDeleteConsumerGroupByIdRequest

	/*
	 * DeleteConsumerGroupByIdExecute executes the request
	 */
	DeleteConsumerGroupByIdExecute(r ApiDeleteConsumerGroupByIdRequest) (*_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 Consumer group identifier
	 * @return ApiGetConsumerGroupByIdRequest
	 */
	GetConsumerGroupById(ctx _context.Context, consumerGroupId string) ApiGetConsumerGroupByIdRequest

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

	/*
	 * GetConsumerGroups List of consumer groups in the Kafka instance.
	 * Returns a list of all consumer groups for a particular Kafka instance. The consumer groups returned are limited to those records the requestor is authorized to view.
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return ApiGetConsumerGroupsRequest
	 */
	GetConsumerGroups(ctx _context.Context) ApiGetConsumerGroupsRequest

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

	/*
	 * ResetConsumerGroupOffset Reset the offset for a consumer group.
	 * Reset the offset for a particular consumer group.
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param consumerGroupId Consumer group identifier
	 * @return ApiResetConsumerGroupOffsetRequest
	 */
	ResetConsumerGroupOffset(ctx _context.Context, consumerGroupId string) ApiResetConsumerGroupOffsetRequest

	/*
	 * ResetConsumerGroupOffsetExecute executes the request
	 * @return ConsumerGroupResetOffsetResult
	 */
	ResetConsumerGroupOffsetExecute(r ApiResetConsumerGroupOffsetRequest) (ConsumerGroupResetOffsetResult, *_nethttp.Response, error)
}

type GroupsApiService

type GroupsApiService service

GroupsApiService GroupsApi service

func (*GroupsApiService) DeleteConsumerGroupById

func (a *GroupsApiService) 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 Consumer group identifier * @return ApiDeleteConsumerGroupByIdRequest

func (*GroupsApiService) DeleteConsumerGroupByIdExecute

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

* Execute executes the request

func (*GroupsApiService) GetConsumerGroupById

func (a *GroupsApiService) 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 Consumer group identifier * @return ApiGetConsumerGroupByIdRequest

func (*GroupsApiService) GetConsumerGroupByIdExecute

* Execute executes the request * @return ConsumerGroup

func (*GroupsApiService) GetConsumerGroups

* GetConsumerGroups List of consumer groups in the Kafka instance. * Returns a list of all consumer groups for a particular Kafka instance. The consumer groups returned are limited to those records the requestor is authorized to view. * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return ApiGetConsumerGroupsRequest

func (*GroupsApiService) GetConsumerGroupsExecute

* Execute executes the request * @return ConsumerGroupList

func (*GroupsApiService) ResetConsumerGroupOffset

func (a *GroupsApiService) ResetConsumerGroupOffset(ctx _context.Context, consumerGroupId string) ApiResetConsumerGroupOffsetRequest

* ResetConsumerGroupOffset Reset the offset for a consumer group. * Reset the offset for a particular consumer group. * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param consumerGroupId Consumer group identifier * @return ApiResetConsumerGroupOffsetRequest

func (*GroupsApiService) ResetConsumerGroupOffsetExecute

* Execute executes the request * @return ConsumerGroupResetOffsetResult

type List

type List struct {
	Kind *string `json:"kind,omitempty"`
	// Total number of entries in the full result set
	Total int32 `json:"total"`
	// Number of entries per page (returned for fetch requests)
	Size *int32 `json:"size,omitempty"`
	// Current page number (returned for fetch requests)
	Page *int32 `json:"page,omitempty"`
}

List struct for List

func NewList

func NewList(total int32) *List

NewList instantiates a new List 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 NewListWithDefaults

func NewListWithDefaults() *List

NewListWithDefaults instantiates a new List 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 (*List) GetKind

func (o *List) GetKind() string

GetKind returns the Kind field value if set, zero value otherwise.

func (*List) GetKindOk

func (o *List) GetKindOk() (*string, bool)

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

func (*List) GetPage

func (o *List) GetPage() int32

GetPage returns the Page field value if set, zero value otherwise.

func (*List) GetPageOk

func (o *List) GetPageOk() (*int32, bool)

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

func (*List) GetSize

func (o *List) GetSize() int32

GetSize returns the Size field value if set, zero value otherwise.

func (*List) GetSizeOk

func (o *List) GetSizeOk() (*int32, bool)

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

func (*List) GetTotal

func (o *List) GetTotal() int32

GetTotal returns the Total field value

func (*List) GetTotalOk

func (o *List) GetTotalOk() (*int32, bool)

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

func (*List) HasKind

func (o *List) HasKind() bool

HasKind returns a boolean if a field has been set.

func (*List) HasPage

func (o *List) HasPage() bool

HasPage returns a boolean if a field has been set.

func (*List) HasSize

func (o *List) HasSize() bool

HasSize returns a boolean if a field has been set.

func (List) MarshalJSON

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

func (*List) SetKind

func (o *List) SetKind(v string)

SetKind gets a reference to the given string and assigns it to the Kind field.

func (*List) SetPage

func (o *List) SetPage(v int32)

SetPage gets a reference to the given int32 and assigns it to the Page field.

func (*List) SetSize

func (o *List) SetSize(v int32)

SetSize gets a reference to the given int32 and assigns it to the Size field.

func (*List) SetTotal

func (o *List) SetTotal(v int32)

SetTotal sets field value

type ListDeprecated

type ListDeprecated struct {
	Kind *string `json:"kind,omitempty"`
	// Total number of entries in the full result set
	Total int32 `json:"total"`
	// Number of entries per page (returned for fetch requests)
	Size *int32 `json:"size,omitempty"`
	// Current page number (returned for fetch requests)
	Page *int32 `json:"page,omitempty"`
	// Offset of the first record returned, zero-based
	Offset *int32 `json:"offset,omitempty"`
	// Maximum number of records to return, from request
	Limit *int32 `json:"limit,omitempty"`
	// Total number of entries in the full result set
	Count *int32 `json:"count,omitempty"`
}

ListDeprecated struct for ListDeprecated

func NewListDeprecated

func NewListDeprecated(total int32) *ListDeprecated

NewListDeprecated instantiates a new ListDeprecated 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 NewListDeprecatedWithDefaults

func NewListDeprecatedWithDefaults() *ListDeprecated

NewListDeprecatedWithDefaults instantiates a new ListDeprecated 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 (*ListDeprecated) GetCount

func (o *ListDeprecated) GetCount() int32

GetCount returns the Count field value if set, zero value otherwise.

func (*ListDeprecated) GetCountOk

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

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

func (*ListDeprecated) GetKind

func (o *ListDeprecated) GetKind() string

GetKind returns the Kind field value if set, zero value otherwise.

func (*ListDeprecated) GetKindOk

func (o *ListDeprecated) GetKindOk() (*string, bool)

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

func (*ListDeprecated) GetLimit

func (o *ListDeprecated) GetLimit() int32

GetLimit returns the Limit field value if set, zero value otherwise.

func (*ListDeprecated) GetLimitOk

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

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

func (*ListDeprecated) GetOffset

func (o *ListDeprecated) GetOffset() int32

GetOffset returns the Offset field value if set, zero value otherwise.

func (*ListDeprecated) GetOffsetOk

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

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

func (*ListDeprecated) GetPage

func (o *ListDeprecated) GetPage() int32

GetPage returns the Page field value if set, zero value otherwise.

func (*ListDeprecated) GetPageOk

func (o *ListDeprecated) GetPageOk() (*int32, bool)

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

func (*ListDeprecated) GetSize

func (o *ListDeprecated) GetSize() int32

GetSize returns the Size field value if set, zero value otherwise.

func (*ListDeprecated) GetSizeOk

func (o *ListDeprecated) GetSizeOk() (*int32, bool)

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

func (*ListDeprecated) GetTotal

func (o *ListDeprecated) GetTotal() int32

GetTotal returns the Total field value

func (*ListDeprecated) GetTotalOk

func (o *ListDeprecated) GetTotalOk() (*int32, bool)

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

func (*ListDeprecated) HasCount

func (o *ListDeprecated) HasCount() bool

HasCount returns a boolean if a field has been set.

func (*ListDeprecated) HasKind

func (o *ListDeprecated) HasKind() bool

HasKind returns a boolean if a field has been set.

func (*ListDeprecated) HasLimit

func (o *ListDeprecated) HasLimit() bool

HasLimit returns a boolean if a field has been set.

func (*ListDeprecated) HasOffset

func (o *ListDeprecated) HasOffset() bool

HasOffset returns a boolean if a field has been set.

func (*ListDeprecated) HasPage

func (o *ListDeprecated) HasPage() bool

HasPage returns a boolean if a field has been set.

func (*ListDeprecated) HasSize

func (o *ListDeprecated) HasSize() bool

HasSize returns a boolean if a field has been set.

func (ListDeprecated) MarshalJSON

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

func (*ListDeprecated) SetCount

func (o *ListDeprecated) SetCount(v int32)

SetCount gets a reference to the given int32 and assigns it to the Count field.

func (*ListDeprecated) SetKind

func (o *ListDeprecated) SetKind(v string)

SetKind gets a reference to the given string and assigns it to the Kind field.

func (*ListDeprecated) SetLimit

func (o *ListDeprecated) SetLimit(v int32)

SetLimit gets a reference to the given int32 and assigns it to the Limit field.

func (*ListDeprecated) SetOffset

func (o *ListDeprecated) SetOffset(v int32)

SetOffset gets a reference to the given int32 and assigns it to the Offset field.

func (*ListDeprecated) SetPage

func (o *ListDeprecated) SetPage(v int32)

SetPage gets a reference to the given int32 and assigns it to the Page field.

func (*ListDeprecated) SetSize

func (o *ListDeprecated) SetSize(v int32)

SetSize gets a reference to the given int32 and assigns it to the Size field.

func (*ListDeprecated) SetTotal

func (o *ListDeprecated) SetTotal(v int32)

SetTotal sets field value

type ListDeprecatedAllOf

type ListDeprecatedAllOf struct {
	// Offset of the first record returned, zero-based
	Offset *int32 `json:"offset,omitempty"`
	// Maximum number of records to return, from request
	Limit *int32 `json:"limit,omitempty"`
	// Total number of entries in the full result set
	Count *int32 `json:"count,omitempty"`
}

ListDeprecatedAllOf struct for ListDeprecatedAllOf

func NewListDeprecatedAllOf

func NewListDeprecatedAllOf() *ListDeprecatedAllOf

NewListDeprecatedAllOf instantiates a new ListDeprecatedAllOf 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 NewListDeprecatedAllOfWithDefaults

func NewListDeprecatedAllOfWithDefaults() *ListDeprecatedAllOf

NewListDeprecatedAllOfWithDefaults instantiates a new ListDeprecatedAllOf 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 (*ListDeprecatedAllOf) GetCount

func (o *ListDeprecatedAllOf) GetCount() int32

GetCount returns the Count field value if set, zero value otherwise.

func (*ListDeprecatedAllOf) GetCountOk

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

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

func (*ListDeprecatedAllOf) GetLimit

func (o *ListDeprecatedAllOf) GetLimit() int32

GetLimit returns the Limit field value if set, zero value otherwise.

func (*ListDeprecatedAllOf) GetLimitOk

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

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

func (*ListDeprecatedAllOf) GetOffset

func (o *ListDeprecatedAllOf) GetOffset() int32

GetOffset returns the Offset field value if set, zero value otherwise.

func (*ListDeprecatedAllOf) GetOffsetOk

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

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

func (*ListDeprecatedAllOf) HasCount

func (o *ListDeprecatedAllOf) HasCount() bool

HasCount returns a boolean if a field has been set.

func (*ListDeprecatedAllOf) HasLimit

func (o *ListDeprecatedAllOf) HasLimit() bool

HasLimit returns a boolean if a field has been set.

func (*ListDeprecatedAllOf) HasOffset

func (o *ListDeprecatedAllOf) HasOffset() bool

HasOffset returns a boolean if a field has been set.

func (ListDeprecatedAllOf) MarshalJSON

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

func (*ListDeprecatedAllOf) SetCount

func (o *ListDeprecatedAllOf) SetCount(v int32)

SetCount gets a reference to the given int32 and assigns it to the Count field.

func (*ListDeprecatedAllOf) SetLimit

func (o *ListDeprecatedAllOf) SetLimit(v int32)

SetLimit gets a reference to the given int32 and assigns it to the Limit field.

func (*ListDeprecatedAllOf) SetOffset

func (o *ListDeprecatedAllOf) SetOffset(v int32)

SetOffset gets a reference to the given int32 and assigns it to the Offset field.

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 Node

type Node struct {
	Id *int32 `json:"id,omitempty"`
}

Node Identifier for a Kafka server / broker.

func NewNode

func NewNode() *Node

NewNode instantiates a new Node 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 NewNodeWithDefaults

func NewNodeWithDefaults() *Node

NewNodeWithDefaults instantiates a new Node 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 (*Node) GetId

func (o *Node) GetId() int32

GetId returns the Id field value if set, zero value otherwise.

func (*Node) GetIdOk

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

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

func (*Node) HasId

func (o *Node) HasId() bool

HasId returns a boolean if a field has been set.

func (Node) MarshalJSON

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

func (*Node) SetId

func (o *Node) SetId(v int32)

SetId gets a reference to the given int32 and assigns it to the Id field.

type NullableAclBinding

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

func NewNullableAclBinding

func NewNullableAclBinding(val *AclBinding) *NullableAclBinding

func (NullableAclBinding) Get

func (v NullableAclBinding) Get() *AclBinding

func (NullableAclBinding) IsSet

func (v NullableAclBinding) IsSet() bool

func (NullableAclBinding) MarshalJSON

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

func (*NullableAclBinding) Set

func (v *NullableAclBinding) Set(val *AclBinding)

func (*NullableAclBinding) UnmarshalJSON

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

func (*NullableAclBinding) Unset

func (v *NullableAclBinding) Unset()

type NullableAclBindingAllOf

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

func NewNullableAclBindingAllOf

func NewNullableAclBindingAllOf(val *AclBindingAllOf) *NullableAclBindingAllOf

func (NullableAclBindingAllOf) Get

func (NullableAclBindingAllOf) IsSet

func (v NullableAclBindingAllOf) IsSet() bool

func (NullableAclBindingAllOf) MarshalJSON

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

func (*NullableAclBindingAllOf) Set

func (*NullableAclBindingAllOf) UnmarshalJSON

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

func (*NullableAclBindingAllOf) Unset

func (v *NullableAclBindingAllOf) Unset()

type NullableAclBindingListPage

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

func NewNullableAclBindingListPage

func NewNullableAclBindingListPage(val *AclBindingListPage) *NullableAclBindingListPage

func (NullableAclBindingListPage) Get

func (NullableAclBindingListPage) IsSet

func (v NullableAclBindingListPage) IsSet() bool

func (NullableAclBindingListPage) MarshalJSON

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

func (*NullableAclBindingListPage) Set

func (*NullableAclBindingListPage) UnmarshalJSON

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

func (*NullableAclBindingListPage) Unset

func (v *NullableAclBindingListPage) Unset()

type NullableAclBindingListPageAllOf

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

func (NullableAclBindingListPageAllOf) Get

func (NullableAclBindingListPageAllOf) IsSet

func (NullableAclBindingListPageAllOf) MarshalJSON

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

func (*NullableAclBindingListPageAllOf) Set

func (*NullableAclBindingListPageAllOf) UnmarshalJSON

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

func (*NullableAclBindingListPageAllOf) Unset

type NullableAclBindingOrderKey

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

func NewNullableAclBindingOrderKey

func NewNullableAclBindingOrderKey(val *AclBindingOrderKey) *NullableAclBindingOrderKey

func (NullableAclBindingOrderKey) Get

func (NullableAclBindingOrderKey) IsSet

func (v NullableAclBindingOrderKey) IsSet() bool

func (NullableAclBindingOrderKey) MarshalJSON

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

func (*NullableAclBindingOrderKey) Set

func (*NullableAclBindingOrderKey) UnmarshalJSON

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

func (*NullableAclBindingOrderKey) Unset

func (v *NullableAclBindingOrderKey) Unset()

type NullableAclOperation

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

func NewNullableAclOperation

func NewNullableAclOperation(val *AclOperation) *NullableAclOperation

func (NullableAclOperation) Get

func (NullableAclOperation) IsSet

func (v NullableAclOperation) IsSet() bool

func (NullableAclOperation) MarshalJSON

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

func (*NullableAclOperation) Set

func (v *NullableAclOperation) Set(val *AclOperation)

func (*NullableAclOperation) UnmarshalJSON

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

func (*NullableAclOperation) Unset

func (v *NullableAclOperation) Unset()

type NullableAclOperationFilter

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

func NewNullableAclOperationFilter

func NewNullableAclOperationFilter(val *AclOperationFilter) *NullableAclOperationFilter

func (NullableAclOperationFilter) Get

func (NullableAclOperationFilter) IsSet

func (v NullableAclOperationFilter) IsSet() bool

func (NullableAclOperationFilter) MarshalJSON

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

func (*NullableAclOperationFilter) Set

func (*NullableAclOperationFilter) UnmarshalJSON

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

func (*NullableAclOperationFilter) Unset

func (v *NullableAclOperationFilter) Unset()

type NullableAclPatternType

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

func NewNullableAclPatternType

func NewNullableAclPatternType(val *AclPatternType) *NullableAclPatternType

func (NullableAclPatternType) Get

func (NullableAclPatternType) IsSet

func (v NullableAclPatternType) IsSet() bool

func (NullableAclPatternType) MarshalJSON

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

func (*NullableAclPatternType) Set

func (*NullableAclPatternType) UnmarshalJSON

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

func (*NullableAclPatternType) Unset

func (v *NullableAclPatternType) Unset()

type NullableAclPatternTypeFilter

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

func NewNullableAclPatternTypeFilter

func NewNullableAclPatternTypeFilter(val *AclPatternTypeFilter) *NullableAclPatternTypeFilter

func (NullableAclPatternTypeFilter) Get

func (NullableAclPatternTypeFilter) IsSet

func (NullableAclPatternTypeFilter) MarshalJSON

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

func (*NullableAclPatternTypeFilter) Set

func (*NullableAclPatternTypeFilter) UnmarshalJSON

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

func (*NullableAclPatternTypeFilter) Unset

func (v *NullableAclPatternTypeFilter) Unset()

type NullableAclPermissionType

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

func NewNullableAclPermissionType

func NewNullableAclPermissionType(val *AclPermissionType) *NullableAclPermissionType

func (NullableAclPermissionType) Get

func (NullableAclPermissionType) IsSet

func (v NullableAclPermissionType) IsSet() bool

func (NullableAclPermissionType) MarshalJSON

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

func (*NullableAclPermissionType) Set

func (*NullableAclPermissionType) UnmarshalJSON

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

func (*NullableAclPermissionType) Unset

func (v *NullableAclPermissionType) Unset()

type NullableAclPermissionTypeFilter

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

func (NullableAclPermissionTypeFilter) Get

func (NullableAclPermissionTypeFilter) IsSet

func (NullableAclPermissionTypeFilter) MarshalJSON

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

func (*NullableAclPermissionTypeFilter) Set

func (*NullableAclPermissionTypeFilter) UnmarshalJSON

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

func (*NullableAclPermissionTypeFilter) Unset

type NullableAclResourceType

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

func NewNullableAclResourceType

func NewNullableAclResourceType(val *AclResourceType) *NullableAclResourceType

func (NullableAclResourceType) Get

func (NullableAclResourceType) IsSet

func (v NullableAclResourceType) IsSet() bool

func (NullableAclResourceType) MarshalJSON

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

func (*NullableAclResourceType) Set

func (*NullableAclResourceType) UnmarshalJSON

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

func (*NullableAclResourceType) Unset

func (v *NullableAclResourceType) Unset()

type NullableAclResourceTypeFilter

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

func (NullableAclResourceTypeFilter) Get

func (NullableAclResourceTypeFilter) IsSet

func (NullableAclResourceTypeFilter) MarshalJSON

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

func (*NullableAclResourceTypeFilter) Set

func (*NullableAclResourceTypeFilter) UnmarshalJSON

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

func (*NullableAclResourceTypeFilter) Unset

func (v *NullableAclResourceTypeFilter) Unset()

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 (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 (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 NullableConsumerGroupAllOf

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

func NewNullableConsumerGroupAllOf

func NewNullableConsumerGroupAllOf(val *ConsumerGroupAllOf) *NullableConsumerGroupAllOf

func (NullableConsumerGroupAllOf) Get

func (NullableConsumerGroupAllOf) IsSet

func (v NullableConsumerGroupAllOf) IsSet() bool

func (NullableConsumerGroupAllOf) MarshalJSON

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

func (*NullableConsumerGroupAllOf) Set

func (*NullableConsumerGroupAllOf) UnmarshalJSON

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

func (*NullableConsumerGroupAllOf) Unset

func (v *NullableConsumerGroupAllOf) Unset()

type NullableConsumerGroupDescriptionOrderKey

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

func (NullableConsumerGroupDescriptionOrderKey) Get

func (NullableConsumerGroupDescriptionOrderKey) IsSet

func (NullableConsumerGroupDescriptionOrderKey) MarshalJSON

func (*NullableConsumerGroupDescriptionOrderKey) Set

func (*NullableConsumerGroupDescriptionOrderKey) UnmarshalJSON

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

func (*NullableConsumerGroupDescriptionOrderKey) Unset

type NullableConsumerGroupList

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

func NewNullableConsumerGroupList

func NewNullableConsumerGroupList(val *ConsumerGroupList) *NullableConsumerGroupList

func (NullableConsumerGroupList) Get

func (NullableConsumerGroupList) IsSet

func (v NullableConsumerGroupList) IsSet() bool

func (NullableConsumerGroupList) MarshalJSON

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

func (*NullableConsumerGroupList) Set

func (*NullableConsumerGroupList) UnmarshalJSON

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

func (*NullableConsumerGroupList) Unset

func (v *NullableConsumerGroupList) Unset()

type NullableConsumerGroupListAllOf

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

func (NullableConsumerGroupListAllOf) Get

func (NullableConsumerGroupListAllOf) IsSet

func (NullableConsumerGroupListAllOf) MarshalJSON

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

func (*NullableConsumerGroupListAllOf) Set

func (*NullableConsumerGroupListAllOf) UnmarshalJSON

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

func (*NullableConsumerGroupListAllOf) Unset

func (v *NullableConsumerGroupListAllOf) Unset()

type NullableConsumerGroupMetrics

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

func NewNullableConsumerGroupMetrics

func NewNullableConsumerGroupMetrics(val *ConsumerGroupMetrics) *NullableConsumerGroupMetrics

func (NullableConsumerGroupMetrics) Get

func (NullableConsumerGroupMetrics) IsSet

func (NullableConsumerGroupMetrics) MarshalJSON

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

func (*NullableConsumerGroupMetrics) Set

func (*NullableConsumerGroupMetrics) UnmarshalJSON

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

func (*NullableConsumerGroupMetrics) Unset

func (v *NullableConsumerGroupMetrics) Unset()

type NullableConsumerGroupOrderKey

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

func (NullableConsumerGroupOrderKey) Get

func (NullableConsumerGroupOrderKey) IsSet

func (NullableConsumerGroupOrderKey) MarshalJSON

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

func (*NullableConsumerGroupOrderKey) Set

func (*NullableConsumerGroupOrderKey) UnmarshalJSON

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

func (*NullableConsumerGroupOrderKey) Unset

func (v *NullableConsumerGroupOrderKey) Unset()

type NullableConsumerGroupResetOffsetParameters

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

func (NullableConsumerGroupResetOffsetParameters) Get

func (NullableConsumerGroupResetOffsetParameters) IsSet

func (NullableConsumerGroupResetOffsetParameters) MarshalJSON

func (*NullableConsumerGroupResetOffsetParameters) Set

func (*NullableConsumerGroupResetOffsetParameters) UnmarshalJSON

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

func (*NullableConsumerGroupResetOffsetParameters) Unset

type NullableConsumerGroupResetOffsetResult

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

func (NullableConsumerGroupResetOffsetResult) Get

func (NullableConsumerGroupResetOffsetResult) IsSet

func (NullableConsumerGroupResetOffsetResult) MarshalJSON

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

func (*NullableConsumerGroupResetOffsetResult) Set

func (*NullableConsumerGroupResetOffsetResult) UnmarshalJSON

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

func (*NullableConsumerGroupResetOffsetResult) Unset

type NullableConsumerGroupResetOffsetResultAllOf

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

func (NullableConsumerGroupResetOffsetResultAllOf) Get

func (NullableConsumerGroupResetOffsetResultAllOf) IsSet

func (NullableConsumerGroupResetOffsetResultAllOf) MarshalJSON

func (*NullableConsumerGroupResetOffsetResultAllOf) Set

func (*NullableConsumerGroupResetOffsetResultAllOf) UnmarshalJSON

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

func (*NullableConsumerGroupResetOffsetResultAllOf) Unset

type NullableConsumerGroupResetOffsetResultItem

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

func (NullableConsumerGroupResetOffsetResultItem) Get

func (NullableConsumerGroupResetOffsetResultItem) IsSet

func (NullableConsumerGroupResetOffsetResultItem) MarshalJSON

func (*NullableConsumerGroupResetOffsetResultItem) Set

func (*NullableConsumerGroupResetOffsetResultItem) UnmarshalJSON

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

func (*NullableConsumerGroupResetOffsetResultItem) Unset

type NullableConsumerGroupState

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

func NewNullableConsumerGroupState

func NewNullableConsumerGroupState(val *ConsumerGroupState) *NullableConsumerGroupState

func (NullableConsumerGroupState) Get

func (NullableConsumerGroupState) IsSet

func (v NullableConsumerGroupState) IsSet() bool

func (NullableConsumerGroupState) MarshalJSON

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

func (*NullableConsumerGroupState) Set

func (*NullableConsumerGroupState) UnmarshalJSON

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

func (*NullableConsumerGroupState) Unset

func (v *NullableConsumerGroupState) Unset()

type NullableError

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

func NewNullableError

func NewNullableError(val *Error) *NullableError

func (NullableError) Get

func (v NullableError) Get() *Error

func (NullableError) IsSet

func (v NullableError) IsSet() bool

func (NullableError) MarshalJSON

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

func (*NullableError) Set

func (v *NullableError) Set(val *Error)

func (*NullableError) UnmarshalJSON

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

func (*NullableError) Unset

func (v *NullableError) Unset()

type NullableErrorAllOf

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

func NewNullableErrorAllOf

func NewNullableErrorAllOf(val *ErrorAllOf) *NullableErrorAllOf

func (NullableErrorAllOf) Get

func (v NullableErrorAllOf) Get() *ErrorAllOf

func (NullableErrorAllOf) IsSet

func (v NullableErrorAllOf) IsSet() bool

func (NullableErrorAllOf) MarshalJSON

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

func (*NullableErrorAllOf) Set

func (v *NullableErrorAllOf) Set(val *ErrorAllOf)

func (*NullableErrorAllOf) UnmarshalJSON

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

func (*NullableErrorAllOf) Unset

func (v *NullableErrorAllOf) Unset()

type NullableErrorList

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

func NewNullableErrorList

func NewNullableErrorList(val *ErrorList) *NullableErrorList

func (NullableErrorList) Get

func (v NullableErrorList) Get() *ErrorList

func (NullableErrorList) IsSet

func (v NullableErrorList) IsSet() bool

func (NullableErrorList) MarshalJSON

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

func (*NullableErrorList) Set

func (v *NullableErrorList) Set(val *ErrorList)

func (*NullableErrorList) UnmarshalJSON

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

func (*NullableErrorList) Unset

func (v *NullableErrorList) Unset()

type NullableErrorListAllOf

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

func NewNullableErrorListAllOf

func NewNullableErrorListAllOf(val *ErrorListAllOf) *NullableErrorListAllOf

func (NullableErrorListAllOf) Get

func (NullableErrorListAllOf) IsSet

func (v NullableErrorListAllOf) IsSet() bool

func (NullableErrorListAllOf) MarshalJSON

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

func (*NullableErrorListAllOf) Set

func (*NullableErrorListAllOf) UnmarshalJSON

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

func (*NullableErrorListAllOf) Unset

func (v *NullableErrorListAllOf) 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 NullableList

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

func NewNullableList

func NewNullableList(val *List) *NullableList

func (NullableList) Get

func (v NullableList) Get() *List

func (NullableList) IsSet

func (v NullableList) IsSet() bool

func (NullableList) MarshalJSON

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

func (*NullableList) Set

func (v *NullableList) Set(val *List)

func (*NullableList) UnmarshalJSON

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

func (*NullableList) Unset

func (v *NullableList) Unset()

type NullableListDeprecated

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

func NewNullableListDeprecated

func NewNullableListDeprecated(val *ListDeprecated) *NullableListDeprecated

func (NullableListDeprecated) Get

func (NullableListDeprecated) IsSet

func (v NullableListDeprecated) IsSet() bool

func (NullableListDeprecated) MarshalJSON

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

func (*NullableListDeprecated) Set

func (*NullableListDeprecated) UnmarshalJSON

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

func (*NullableListDeprecated) Unset

func (v *NullableListDeprecated) Unset()

type NullableListDeprecatedAllOf

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

func NewNullableListDeprecatedAllOf

func NewNullableListDeprecatedAllOf(val *ListDeprecatedAllOf) *NullableListDeprecatedAllOf

func (NullableListDeprecatedAllOf) Get

func (NullableListDeprecatedAllOf) IsSet

func (NullableListDeprecatedAllOf) MarshalJSON

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

func (*NullableListDeprecatedAllOf) Set

func (*NullableListDeprecatedAllOf) UnmarshalJSON

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

func (*NullableListDeprecatedAllOf) Unset

func (v *NullableListDeprecatedAllOf) Unset()

type NullableNewTopicInput

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

func NewNullableNewTopicInput

func NewNullableNewTopicInput(val *NewTopicInput) *NullableNewTopicInput

func (NullableNewTopicInput) Get

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 NullableNode

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

func NewNullableNode

func NewNullableNode(val *Node) *NullableNode

func (NullableNode) Get

func (v NullableNode) Get() *Node

func (NullableNode) IsSet

func (v NullableNode) IsSet() bool

func (NullableNode) MarshalJSON

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

func (*NullableNode) Set

func (v *NullableNode) Set(val *Node)

func (*NullableNode) UnmarshalJSON

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

func (*NullableNode) Unset

func (v *NullableNode) Unset()

type NullableObjectReference

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

func NewNullableObjectReference

func NewNullableObjectReference(val *ObjectReference) *NullableObjectReference

func (NullableObjectReference) Get

func (NullableObjectReference) IsSet

func (v NullableObjectReference) IsSet() bool

func (NullableObjectReference) MarshalJSON

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

func (*NullableObjectReference) Set

func (*NullableObjectReference) UnmarshalJSON

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

func (*NullableObjectReference) Unset

func (v *NullableObjectReference) Unset()

type NullableOffsetType

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

func NewNullableOffsetType

func NewNullableOffsetType(val *OffsetType) *NullableOffsetType

func (NullableOffsetType) Get

func (v NullableOffsetType) Get() *OffsetType

func (NullableOffsetType) IsSet

func (v NullableOffsetType) IsSet() bool

func (NullableOffsetType) MarshalJSON

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

func (*NullableOffsetType) Set

func (v *NullableOffsetType) Set(val *OffsetType)

func (*NullableOffsetType) UnmarshalJSON

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

func (*NullableOffsetType) Unset

func (v *NullableOffsetType) 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 NullableRecord

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

func NewNullableRecord

func NewNullableRecord(val *Record) *NullableRecord

func (NullableRecord) Get

func (v NullableRecord) Get() *Record

func (NullableRecord) IsSet

func (v NullableRecord) IsSet() bool

func (NullableRecord) MarshalJSON

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

func (*NullableRecord) Set

func (v *NullableRecord) Set(val *Record)

func (*NullableRecord) UnmarshalJSON

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

func (*NullableRecord) Unset

func (v *NullableRecord) Unset()

type NullableRecordAllOf

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

func NewNullableRecordAllOf

func NewNullableRecordAllOf(val *RecordAllOf) *NullableRecordAllOf

func (NullableRecordAllOf) Get

func (NullableRecordAllOf) IsSet

func (v NullableRecordAllOf) IsSet() bool

func (NullableRecordAllOf) MarshalJSON

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

func (*NullableRecordAllOf) Set

func (v *NullableRecordAllOf) Set(val *RecordAllOf)

func (*NullableRecordAllOf) UnmarshalJSON

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

func (*NullableRecordAllOf) Unset

func (v *NullableRecordAllOf) Unset()

type NullableRecordIncludedProperty

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

func (NullableRecordIncludedProperty) Get

func (NullableRecordIncludedProperty) IsSet

func (NullableRecordIncludedProperty) MarshalJSON

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

func (*NullableRecordIncludedProperty) Set

func (*NullableRecordIncludedProperty) UnmarshalJSON

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

func (*NullableRecordIncludedProperty) Unset

func (v *NullableRecordIncludedProperty) Unset()

type NullableRecordList

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

func NewNullableRecordList

func NewNullableRecordList(val *RecordList) *NullableRecordList

func (NullableRecordList) Get

func (v NullableRecordList) Get() *RecordList

func (NullableRecordList) IsSet

func (v NullableRecordList) IsSet() bool

func (NullableRecordList) MarshalJSON

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

func (*NullableRecordList) Set

func (v *NullableRecordList) Set(val *RecordList)

func (*NullableRecordList) UnmarshalJSON

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

func (*NullableRecordList) Unset

func (v *NullableRecordList) Unset()

type NullableRecordListAllOf

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

func NewNullableRecordListAllOf

func NewNullableRecordListAllOf(val *RecordListAllOf) *NullableRecordListAllOf

func (NullableRecordListAllOf) Get

func (NullableRecordListAllOf) IsSet

func (v NullableRecordListAllOf) IsSet() bool

func (NullableRecordListAllOf) MarshalJSON

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

func (*NullableRecordListAllOf) Set

func (*NullableRecordListAllOf) UnmarshalJSON

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

func (*NullableRecordListAllOf) Unset

func (v *NullableRecordListAllOf) Unset()

type NullableSortDirection

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

func NewNullableSortDirection

func NewNullableSortDirection(val *SortDirection) *NullableSortDirection

func (NullableSortDirection) Get

func (NullableSortDirection) IsSet

func (v NullableSortDirection) IsSet() bool

func (NullableSortDirection) MarshalJSON

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

func (*NullableSortDirection) Set

func (v *NullableSortDirection) Set(val *SortDirection)

func (*NullableSortDirection) UnmarshalJSON

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

func (*NullableSortDirection) Unset

func (v *NullableSortDirection) 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 NullableTopicAllOf

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

func NewNullableTopicAllOf

func NewNullableTopicAllOf(val *TopicAllOf) *NullableTopicAllOf

func (NullableTopicAllOf) Get

func (v NullableTopicAllOf) Get() *TopicAllOf

func (NullableTopicAllOf) IsSet

func (v NullableTopicAllOf) IsSet() bool

func (NullableTopicAllOf) MarshalJSON

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

func (*NullableTopicAllOf) Set

func (v *NullableTopicAllOf) Set(val *TopicAllOf)

func (*NullableTopicAllOf) UnmarshalJSON

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

func (*NullableTopicAllOf) Unset

func (v *NullableTopicAllOf) Unset()

type NullableTopicOrderKey

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

func NewNullableTopicOrderKey

func NewNullableTopicOrderKey(val *TopicOrderKey) *NullableTopicOrderKey

func (NullableTopicOrderKey) Get

func (NullableTopicOrderKey) IsSet

func (v NullableTopicOrderKey) IsSet() bool

func (NullableTopicOrderKey) MarshalJSON

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

func (*NullableTopicOrderKey) Set

func (v *NullableTopicOrderKey) Set(val *TopicOrderKey)

func (*NullableTopicOrderKey) UnmarshalJSON

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

func (*NullableTopicOrderKey) Unset

func (v *NullableTopicOrderKey) Unset()

type NullableTopicSettings

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

func NewNullableTopicSettings

func NewNullableTopicSettings(val *TopicSettings) *NullableTopicSettings

func (NullableTopicSettings) Get

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 NullableTopicsListAllOf

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

func NewNullableTopicsListAllOf

func NewNullableTopicsListAllOf(val *TopicsListAllOf) *NullableTopicsListAllOf

func (NullableTopicsListAllOf) Get

func (NullableTopicsListAllOf) IsSet

func (v NullableTopicsListAllOf) IsSet() bool

func (NullableTopicsListAllOf) MarshalJSON

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

func (*NullableTopicsListAllOf) Set

func (*NullableTopicsListAllOf) UnmarshalJSON

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

func (*NullableTopicsListAllOf) Unset

func (v *NullableTopicsListAllOf) Unset()

type NullableTopicsToResetOffset

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

func NewNullableTopicsToResetOffset

func NewNullableTopicsToResetOffset(val *TopicsToResetOffset) *NullableTopicsToResetOffset

func (NullableTopicsToResetOffset) Get

func (NullableTopicsToResetOffset) IsSet

func (NullableTopicsToResetOffset) MarshalJSON

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

func (*NullableTopicsToResetOffset) Set

func (*NullableTopicsToResetOffset) UnmarshalJSON

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

func (*NullableTopicsToResetOffset) Unset

func (v *NullableTopicsToResetOffset) Unset()

type ObjectReference

type ObjectReference struct {
	// Unique identifier for the object. Not supported for all object kinds.
	Id   *string `json:"id,omitempty"`
	Kind *string `json:"kind,omitempty"`
	// Link path to request the object. Not supported for all object kinds.
	Href *string `json:"href,omitempty"`
}

ObjectReference struct for ObjectReference

func NewObjectReference

func NewObjectReference() *ObjectReference

NewObjectReference instantiates a new ObjectReference 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 NewObjectReferenceWithDefaults

func NewObjectReferenceWithDefaults() *ObjectReference

NewObjectReferenceWithDefaults instantiates a new ObjectReference 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 (*ObjectReference) GetHref

func (o *ObjectReference) GetHref() string

GetHref returns the Href field value if set, zero value otherwise.

func (*ObjectReference) GetHrefOk

func (o *ObjectReference) GetHrefOk() (*string, bool)

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

func (*ObjectReference) GetId

func (o *ObjectReference) GetId() string

GetId returns the Id field value if set, zero value otherwise.

func (*ObjectReference) GetIdOk

func (o *ObjectReference) GetIdOk() (*string, bool)

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

func (*ObjectReference) GetKind

func (o *ObjectReference) GetKind() string

GetKind returns the Kind field value if set, zero value otherwise.

func (*ObjectReference) GetKindOk

func (o *ObjectReference) GetKindOk() (*string, bool)

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

func (*ObjectReference) HasHref

func (o *ObjectReference) HasHref() bool

HasHref returns a boolean if a field has been set.

func (*ObjectReference) HasId

func (o *ObjectReference) HasId() bool

HasId returns a boolean if a field has been set.

func (*ObjectReference) HasKind

func (o *ObjectReference) HasKind() bool

HasKind returns a boolean if a field has been set.

func (ObjectReference) MarshalJSON

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

func (*ObjectReference) SetHref

func (o *ObjectReference) SetHref(v string)

SetHref gets a reference to the given string and assigns it to the Href field.

func (*ObjectReference) SetId

func (o *ObjectReference) SetId(v string)

SetId gets a reference to the given string and assigns it to the Id field.

func (*ObjectReference) SetKind

func (o *ObjectReference) SetKind(v string)

SetKind gets a reference to the given string and assigns it to the Kind field.

type OffsetType

type OffsetType string

OffsetType the model 'OffsetType'

const (
	OFFSETTYPE_TIMESTAMP OffsetType = "timestamp"
	OFFSETTYPE_ABSOLUTE  OffsetType = "absolute"
	OFFSETTYPE_LATEST    OffsetType = "latest"
	OFFSETTYPE_EARLIEST  OffsetType = "earliest"
)

List of OffsetType

func NewOffsetTypeFromValue

func NewOffsetTypeFromValue(v string) (*OffsetType, error)

NewOffsetTypeFromValue returns a pointer to a valid OffsetType for the value passed as argument, or an error if the value passed is not allowed by the enum

func (OffsetType) IsValid

func (v OffsetType) IsValid() bool

IsValid return true if the value is valid for the enum, false otherwise

func (OffsetType) Ptr

func (v OffsetType) Ptr() *OffsetType

Ptr returns reference to OffsetType value

func (*OffsetType) UnmarshalJSON

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

type Partition

type Partition struct {
	// The partition id, unique among partitions of the same topic
	Partition int32 `json:"partition"`
	// List of replicas for the partition
	Replicas *[]Node `json:"replicas,omitempty"`
	// List in-sync replicas for this partition.
	Isr    *[]Node `json:"isr,omitempty"`
	Leader *Node   `json:"leader,omitempty"`
	// Unique id for the partition (deprecated, use `partition` instead)
	Id *int32 `json:"id,omitempty"`
}

Partition Kafka topic partition

func NewPartition

func NewPartition(partition 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 if set, zero value otherwise.

func (*Partition) GetIdOk

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

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

func (*Partition) GetIsr

func (o *Partition) GetIsr() []Node

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

func (*Partition) GetIsrOk

func (o *Partition) GetIsrOk() (*[]Node, 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() Node

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

func (*Partition) GetLeaderOk

func (o *Partition) GetLeaderOk() (*Node, 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) GetPartition

func (o *Partition) GetPartition() int32

GetPartition returns the Partition field value

func (*Partition) GetPartitionOk

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

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

func (*Partition) GetReplicas

func (o *Partition) GetReplicas() []Node

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

func (*Partition) GetReplicasOk

func (o *Partition) GetReplicasOk() (*[]Node, 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) HasId

func (o *Partition) HasId() bool

HasId returns a boolean if a field 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 gets a reference to the given int32 and assigns it to the Id field.

func (*Partition) SetIsr

func (o *Partition) SetIsr(v []Node)

SetIsr gets a reference to the given []Node and assigns it to the Isr field.

func (*Partition) SetLeader

func (o *Partition) SetLeader(v Node)

SetLeader gets a reference to the given Node and assigns it to the Leader field.

func (*Partition) SetPartition

func (o *Partition) SetPartition(v int32)

SetPartition sets field value

func (*Partition) SetReplicas

func (o *Partition) SetReplicas(v []Node)

SetReplicas gets a reference to the given []Node and assigns it to the Replicas field.

type Record

type Record struct {
	// Unique identifier for the object. Not supported for all object kinds.
	Id   *string `json:"id,omitempty"`
	Kind *string `json:"kind,omitempty"`
	// Link path to request the object. Not supported for all object kinds.
	Href *string `json:"href,omitempty"`
	// The record's partition within the topic
	Partition *int32 `json:"partition,omitempty"`
	// The record's offset within the topic partition
	Offset *int64 `json:"offset,omitempty"`
	// Timestamp associated with the record. The type is indicated by `timestampType`. When producing a record, this value will be used as the record's `CREATE_TIME`.
	Timestamp *time.Time `json:"timestamp,omitempty"`
	// Type of timestamp associated with the record
	TimestampType *string `json:"timestampType,omitempty"`
	// Record headers, key/value pairs
	Headers *map[string]string `json:"headers,omitempty"`
	// Record key
	Key *string `json:"key,omitempty"`
	// Record value
	Value string `json:"value"`
}

Record struct for Record

func NewRecord

func NewRecord(value string) *Record

NewRecord instantiates a new Record 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 NewRecordWithDefaults

func NewRecordWithDefaults() *Record

NewRecordWithDefaults instantiates a new Record 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 (*Record) GetHeaders

func (o *Record) GetHeaders() map[string]string

GetHeaders returns the Headers field value if set, zero value otherwise.

func (*Record) GetHeadersOk

func (o *Record) GetHeadersOk() (*map[string]string, bool)

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

func (*Record) GetHref

func (o *Record) GetHref() string

GetHref returns the Href field value if set, zero value otherwise.

func (*Record) GetHrefOk

func (o *Record) GetHrefOk() (*string, bool)

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

func (*Record) GetId

func (o *Record) GetId() string

GetId returns the Id field value if set, zero value otherwise.

func (*Record) GetIdOk

func (o *Record) GetIdOk() (*string, bool)

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

func (*Record) GetKey

func (o *Record) GetKey() string

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

func (*Record) GetKeyOk

func (o *Record) 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 (*Record) GetKind

func (o *Record) GetKind() string

GetKind returns the Kind field value if set, zero value otherwise.

func (*Record) GetKindOk

func (o *Record) GetKindOk() (*string, bool)

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

func (*Record) GetOffset

func (o *Record) GetOffset() int64

GetOffset returns the Offset field value if set, zero value otherwise.

func (*Record) GetOffsetOk

func (o *Record) GetOffsetOk() (*int64, bool)

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

func (*Record) GetPartition

func (o *Record) GetPartition() int32

GetPartition returns the Partition field value if set, zero value otherwise.

func (*Record) GetPartitionOk

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

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

func (*Record) GetTimestamp

func (o *Record) GetTimestamp() time.Time

GetTimestamp returns the Timestamp field value if set, zero value otherwise.

func (*Record) GetTimestampOk

func (o *Record) GetTimestampOk() (*time.Time, bool)

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

func (*Record) GetTimestampType

func (o *Record) GetTimestampType() string

GetTimestampType returns the TimestampType field value if set, zero value otherwise.

func (*Record) GetTimestampTypeOk

func (o *Record) GetTimestampTypeOk() (*string, bool)

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

func (*Record) GetValue

func (o *Record) GetValue() string

GetValue returns the Value field value

func (*Record) GetValueOk

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

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

func (*Record) HasHeaders

func (o *Record) HasHeaders() bool

HasHeaders returns a boolean if a field has been set.

func (*Record) HasHref

func (o *Record) HasHref() bool

HasHref returns a boolean if a field has been set.

func (*Record) HasId

func (o *Record) HasId() bool

HasId returns a boolean if a field has been set.

func (*Record) HasKey

func (o *Record) HasKey() bool

HasKey returns a boolean if a field has been set.

func (*Record) HasKind

func (o *Record) HasKind() bool

HasKind returns a boolean if a field has been set.

func (*Record) HasOffset

func (o *Record) HasOffset() bool

HasOffset returns a boolean if a field has been set.

func (*Record) HasPartition

func (o *Record) HasPartition() bool

HasPartition returns a boolean if a field has been set.

func (*Record) HasTimestamp

func (o *Record) HasTimestamp() bool

HasTimestamp returns a boolean if a field has been set.

func (*Record) HasTimestampType

func (o *Record) HasTimestampType() bool

HasTimestampType returns a boolean if a field has been set.

func (Record) MarshalJSON

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

func (*Record) SetHeaders

func (o *Record) SetHeaders(v map[string]string)

SetHeaders gets a reference to the given map[string]string and assigns it to the Headers field.

func (*Record) SetHref

func (o *Record) SetHref(v string)

SetHref gets a reference to the given string and assigns it to the Href field.

func (*Record) SetId

func (o *Record) SetId(v string)

SetId gets a reference to the given string and assigns it to the Id field.

func (*Record) SetKey

func (o *Record) SetKey(v string)

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

func (*Record) SetKind

func (o *Record) SetKind(v string)

SetKind gets a reference to the given string and assigns it to the Kind field.

func (*Record) SetOffset

func (o *Record) SetOffset(v int64)

SetOffset gets a reference to the given int64 and assigns it to the Offset field.

func (*Record) SetPartition

func (o *Record) SetPartition(v int32)

SetPartition gets a reference to the given int32 and assigns it to the Partition field.

func (*Record) SetTimestamp

func (o *Record) SetTimestamp(v time.Time)

SetTimestamp gets a reference to the given time.Time and assigns it to the Timestamp field.

func (*Record) SetTimestampType

func (o *Record) SetTimestampType(v string)

SetTimestampType gets a reference to the given string and assigns it to the TimestampType field.

func (*Record) SetValue

func (o *Record) SetValue(v string)

SetValue sets field value

type RecordAllOf

type RecordAllOf struct {
	// The record's partition within the topic
	Partition *int32 `json:"partition,omitempty"`
	// The record's offset within the topic partition
	Offset *int64 `json:"offset,omitempty"`
	// Timestamp associated with the record. The type is indicated by `timestampType`. When producing a record, this value will be used as the record's `CREATE_TIME`.
	Timestamp *time.Time `json:"timestamp,omitempty"`
	// Type of timestamp associated with the record
	TimestampType *string `json:"timestampType,omitempty"`
	// Record headers, key/value pairs
	Headers *map[string]string `json:"headers,omitempty"`
	// Record key
	Key *string `json:"key,omitempty"`
	// Record value
	Value string `json:"value"`
}

RecordAllOf An individual record consumed from a topic or produced to a topic

func NewRecordAllOf

func NewRecordAllOf(value string) *RecordAllOf

NewRecordAllOf instantiates a new RecordAllOf 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 NewRecordAllOfWithDefaults

func NewRecordAllOfWithDefaults() *RecordAllOf

NewRecordAllOfWithDefaults instantiates a new RecordAllOf 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 (*RecordAllOf) GetHeaders

func (o *RecordAllOf) GetHeaders() map[string]string

GetHeaders returns the Headers field value if set, zero value otherwise.

func (*RecordAllOf) GetHeadersOk

func (o *RecordAllOf) GetHeadersOk() (*map[string]string, bool)

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

func (*RecordAllOf) GetKey

func (o *RecordAllOf) GetKey() string

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

func (*RecordAllOf) GetKeyOk

func (o *RecordAllOf) 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 (*RecordAllOf) GetOffset

func (o *RecordAllOf) GetOffset() int64

GetOffset returns the Offset field value if set, zero value otherwise.

func (*RecordAllOf) GetOffsetOk

func (o *RecordAllOf) GetOffsetOk() (*int64, bool)

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

func (*RecordAllOf) GetPartition

func (o *RecordAllOf) GetPartition() int32

GetPartition returns the Partition field value if set, zero value otherwise.

func (*RecordAllOf) GetPartitionOk

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

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

func (*RecordAllOf) GetTimestamp

func (o *RecordAllOf) GetTimestamp() time.Time

GetTimestamp returns the Timestamp field value if set, zero value otherwise.

func (*RecordAllOf) GetTimestampOk

func (o *RecordAllOf) GetTimestampOk() (*time.Time, bool)

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

func (*RecordAllOf) GetTimestampType

func (o *RecordAllOf) GetTimestampType() string

GetTimestampType returns the TimestampType field value if set, zero value otherwise.

func (*RecordAllOf) GetTimestampTypeOk

func (o *RecordAllOf) GetTimestampTypeOk() (*string, bool)

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

func (*RecordAllOf) GetValue

func (o *RecordAllOf) GetValue() string

GetValue returns the Value field value

func (*RecordAllOf) GetValueOk

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

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

func (*RecordAllOf) HasHeaders

func (o *RecordAllOf) HasHeaders() bool

HasHeaders returns a boolean if a field has been set.

func (*RecordAllOf) HasKey

func (o *RecordAllOf) HasKey() bool

HasKey returns a boolean if a field has been set.

func (*RecordAllOf) HasOffset

func (o *RecordAllOf) HasOffset() bool

HasOffset returns a boolean if a field has been set.

func (*RecordAllOf) HasPartition

func (o *RecordAllOf) HasPartition() bool

HasPartition returns a boolean if a field has been set.

func (*RecordAllOf) HasTimestamp

func (o *RecordAllOf) HasTimestamp() bool

HasTimestamp returns a boolean if a field has been set.

func (*RecordAllOf) HasTimestampType

func (o *RecordAllOf) HasTimestampType() bool

HasTimestampType returns a boolean if a field has been set.

func (RecordAllOf) MarshalJSON

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

func (*RecordAllOf) SetHeaders

func (o *RecordAllOf) SetHeaders(v map[string]string)

SetHeaders gets a reference to the given map[string]string and assigns it to the Headers field.

func (*RecordAllOf) SetKey

func (o *RecordAllOf) SetKey(v string)

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

func (*RecordAllOf) SetOffset

func (o *RecordAllOf) SetOffset(v int64)

SetOffset gets a reference to the given int64 and assigns it to the Offset field.

func (*RecordAllOf) SetPartition

func (o *RecordAllOf) SetPartition(v int32)

SetPartition gets a reference to the given int32 and assigns it to the Partition field.

func (*RecordAllOf) SetTimestamp

func (o *RecordAllOf) SetTimestamp(v time.Time)

SetTimestamp gets a reference to the given time.Time and assigns it to the Timestamp field.

func (*RecordAllOf) SetTimestampType

func (o *RecordAllOf) SetTimestampType(v string)

SetTimestampType gets a reference to the given string and assigns it to the TimestampType field.

func (*RecordAllOf) SetValue

func (o *RecordAllOf) SetValue(v string)

SetValue sets field value

type RecordIncludedProperty

type RecordIncludedProperty string

RecordIncludedProperty the model 'RecordIncludedProperty'

const (
	RECORDINCLUDEDPROPERTY_PARTITION      RecordIncludedProperty = "partition"
	RECORDINCLUDEDPROPERTY_OFFSET         RecordIncludedProperty = "offset"
	RECORDINCLUDEDPROPERTY_TIMESTAMP      RecordIncludedProperty = "timestamp"
	RECORDINCLUDEDPROPERTY_TIMESTAMP_TYPE RecordIncludedProperty = "timestampType"
	RECORDINCLUDEDPROPERTY_HEADERS        RecordIncludedProperty = "headers"
	RECORDINCLUDEDPROPERTY_KEY            RecordIncludedProperty = "key"
	RECORDINCLUDEDPROPERTY_VALUE          RecordIncludedProperty = "value"
)

List of RecordIncludedProperty

func NewRecordIncludedPropertyFromValue

func NewRecordIncludedPropertyFromValue(v string) (*RecordIncludedProperty, error)

NewRecordIncludedPropertyFromValue returns a pointer to a valid RecordIncludedProperty for the value passed as argument, or an error if the value passed is not allowed by the enum

func (RecordIncludedProperty) IsValid

func (v RecordIncludedProperty) IsValid() bool

IsValid return true if the value is valid for the enum, false otherwise

func (RecordIncludedProperty) Ptr

Ptr returns reference to RecordIncludedProperty value

func (*RecordIncludedProperty) UnmarshalJSON

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

type RecordList

type RecordList struct {
	Kind *string `json:"kind,omitempty"`
	// Total number of records returned in this request. This value does not indicate the total number of records in the topic.
	Total int32 `json:"total"`
	// Not used
	Size *int32 `json:"size,omitempty"`
	// Not used
	Page  *int32   `json:"page,omitempty"`
	Items []Record `json:"items"`
}

RecordList struct for RecordList

func NewRecordList

func NewRecordList(total int32, items []Record) *RecordList

NewRecordList instantiates a new RecordList 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 NewRecordListWithDefaults

func NewRecordListWithDefaults() *RecordList

NewRecordListWithDefaults instantiates a new RecordList 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 (*RecordList) GetItems

func (o *RecordList) GetItems() []Record

GetItems returns the Items field value

func (*RecordList) GetItemsOk

func (o *RecordList) GetItemsOk() (*[]Record, bool)

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

func (*RecordList) GetKind

func (o *RecordList) GetKind() string

GetKind returns the Kind field value if set, zero value otherwise.

func (*RecordList) GetKindOk

func (o *RecordList) GetKindOk() (*string, bool)

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

func (*RecordList) GetPage

func (o *RecordList) GetPage() int32

GetPage returns the Page field value if set, zero value otherwise.

func (*RecordList) GetPageOk

func (o *RecordList) GetPageOk() (*int32, bool)

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

func (*RecordList) GetSize

func (o *RecordList) GetSize() int32

GetSize returns the Size field value if set, zero value otherwise.

func (*RecordList) GetSizeOk

func (o *RecordList) GetSizeOk() (*int32, bool)

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

func (*RecordList) GetTotal

func (o *RecordList) GetTotal() int32

GetTotal returns the Total field value

func (*RecordList) GetTotalOk

func (o *RecordList) GetTotalOk() (*int32, bool)

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

func (*RecordList) HasKind

func (o *RecordList) HasKind() bool

HasKind returns a boolean if a field has been set.

func (*RecordList) HasPage

func (o *RecordList) HasPage() bool

HasPage returns a boolean if a field has been set.

func (*RecordList) HasSize

func (o *RecordList) HasSize() bool

HasSize returns a boolean if a field has been set.

func (RecordList) MarshalJSON

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

func (*RecordList) SetItems

func (o *RecordList) SetItems(v []Record)

SetItems sets field value

func (*RecordList) SetKind

func (o *RecordList) SetKind(v string)

SetKind gets a reference to the given string and assigns it to the Kind field.

func (*RecordList) SetPage

func (o *RecordList) SetPage(v int32)

SetPage gets a reference to the given int32 and assigns it to the Page field.

func (*RecordList) SetSize

func (o *RecordList) SetSize(v int32)

SetSize gets a reference to the given int32 and assigns it to the Size field.

func (*RecordList) SetTotal

func (o *RecordList) SetTotal(v int32)

SetTotal sets field value

type RecordListAllOf

type RecordListAllOf struct {
	Items []Record `json:"items"`
	// Total number of records returned in this request. This value does not indicate the total number of records in the topic.
	Total *int32 `json:"total,omitempty"`
	// Not used
	Size *int32 `json:"size,omitempty"`
	// Not used
	Page *int32 `json:"page,omitempty"`
}

RecordListAllOf A page of records consumed from a topic

func NewRecordListAllOf

func NewRecordListAllOf(items []Record) *RecordListAllOf

NewRecordListAllOf instantiates a new RecordListAllOf 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 NewRecordListAllOfWithDefaults

func NewRecordListAllOfWithDefaults() *RecordListAllOf

NewRecordListAllOfWithDefaults instantiates a new RecordListAllOf 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 (*RecordListAllOf) GetItems

func (o *RecordListAllOf) GetItems() []Record

GetItems returns the Items field value

func (*RecordListAllOf) GetItemsOk

func (o *RecordListAllOf) GetItemsOk() (*[]Record, bool)

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

func (*RecordListAllOf) GetPage

func (o *RecordListAllOf) GetPage() int32

GetPage returns the Page field value if set, zero value otherwise.

func (*RecordListAllOf) GetPageOk

func (o *RecordListAllOf) GetPageOk() (*int32, bool)

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

func (*RecordListAllOf) GetSize

func (o *RecordListAllOf) GetSize() int32

GetSize returns the Size field value if set, zero value otherwise.

func (*RecordListAllOf) GetSizeOk

func (o *RecordListAllOf) GetSizeOk() (*int32, bool)

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

func (*RecordListAllOf) GetTotal

func (o *RecordListAllOf) GetTotal() int32

GetTotal returns the Total field value if set, zero value otherwise.

func (*RecordListAllOf) GetTotalOk

func (o *RecordListAllOf) GetTotalOk() (*int32, bool)

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

func (*RecordListAllOf) HasPage

func (o *RecordListAllOf) HasPage() bool

HasPage returns a boolean if a field has been set.

func (*RecordListAllOf) HasSize

func (o *RecordListAllOf) HasSize() bool

HasSize returns a boolean if a field has been set.

func (*RecordListAllOf) HasTotal

func (o *RecordListAllOf) HasTotal() bool

HasTotal returns a boolean if a field has been set.

func (RecordListAllOf) MarshalJSON

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

func (*RecordListAllOf) SetItems

func (o *RecordListAllOf) SetItems(v []Record)

SetItems sets field value

func (*RecordListAllOf) SetPage

func (o *RecordListAllOf) SetPage(v int32)

SetPage gets a reference to the given int32 and assigns it to the Page field.

func (*RecordListAllOf) SetSize

func (o *RecordListAllOf) SetSize(v int32)

SetSize gets a reference to the given int32 and assigns it to the Size field.

func (*RecordListAllOf) SetTotal

func (o *RecordListAllOf) SetTotal(v int32)

SetTotal gets a reference to the given int32 and assigns it to the Total field.

type RecordsApi

type RecordsApi interface {

	/*
	 * ConsumeRecords Consume records from a topic
	 * Consume a limited number of records from a topic, optionally specifying a partition and an absolute offset or timestamp as the starting point for message retrieval.
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param topicName Topic name
	 * @return ApiConsumeRecordsRequest
	 */
	ConsumeRecords(ctx _context.Context, topicName string) ApiConsumeRecordsRequest

	/*
	 * ConsumeRecordsExecute executes the request
	 * @return RecordList
	 */
	ConsumeRecordsExecute(r ApiConsumeRecordsRequest) (RecordList, *_nethttp.Response, error)

	/*
	 * ProduceRecord Send a record to a topic
	 * Produce (write) a single record to a topic.
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param topicName Topic name
	 * @return ApiProduceRecordRequest
	 */
	ProduceRecord(ctx _context.Context, topicName string) ApiProduceRecordRequest

	/*
	 * ProduceRecordExecute executes the request
	 * @return Record
	 */
	ProduceRecordExecute(r ApiProduceRecordRequest) (Record, *_nethttp.Response, error)
}

type RecordsApiService

type RecordsApiService service

RecordsApiService RecordsApi service

func (*RecordsApiService) ConsumeRecords

func (a *RecordsApiService) ConsumeRecords(ctx _context.Context, topicName string) ApiConsumeRecordsRequest

* ConsumeRecords Consume records from a topic * Consume a limited number of records from a topic, optionally specifying a partition and an absolute offset or timestamp as the starting point for message retrieval. * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param topicName Topic name * @return ApiConsumeRecordsRequest

func (*RecordsApiService) ConsumeRecordsExecute

* Execute executes the request * @return RecordList

func (*RecordsApiService) ProduceRecord

func (a *RecordsApiService) ProduceRecord(ctx _context.Context, topicName string) ApiProduceRecordRequest

* ProduceRecord Send a record to a topic * Produce (write) a single record to a topic. * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param topicName Topic name * @return ApiProduceRecordRequest

func (*RecordsApiService) ProduceRecordExecute

func (a *RecordsApiService) ProduceRecordExecute(r ApiProduceRecordRequest) (Record, *_nethttp.Response, error)

* Execute executes the request * @return Record

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 SortDirection

type SortDirection string

SortDirection the model 'SortDirection'

const (
	SORTDIRECTION_ASC  SortDirection = "asc"
	SORTDIRECTION_DESC SortDirection = "desc"
)

List of SortDirection

func NewSortDirectionFromValue

func NewSortDirectionFromValue(v string) (*SortDirection, error)

NewSortDirectionFromValue returns a pointer to a valid SortDirection for the value passed as argument, or an error if the value passed is not allowed by the enum

func (SortDirection) IsValid

func (v SortDirection) IsValid() bool

IsValid return true if the value is valid for the enum, false otherwise

func (SortDirection) Ptr

func (v SortDirection) Ptr() *SortDirection

Ptr returns reference to SortDirection value

func (*SortDirection) UnmarshalJSON

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

type Topic

type Topic struct {
	// Unique identifier for the object. Not supported for all object kinds.
	Id   *string `json:"id,omitempty"`
	Kind *string `json:"kind,omitempty"`
	// Link path to request the object. Not supported for all object kinds.
	Href *string `json:"href,omitempty"`
	// The name of the topic.
	Name       *string `json:"name,omitempty"`
	IsInternal *bool   `json:"isInternal,omitempty"`
	// Partitions for this topic.
	Partitions *[]Partition `json:"partitions,omitempty"`
	// Topic configuration entry.
	Config *[]ConfigEntry `json:"config,omitempty"`
}

Topic struct for Topic

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) GetHref

func (o *Topic) GetHref() string

GetHref returns the Href field value if set, zero value otherwise.

func (*Topic) GetHrefOk

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

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

func (*Topic) GetId

func (o *Topic) GetId() string

GetId returns the Id field value if set, zero value otherwise.

func (*Topic) GetIdOk

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

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

func (*Topic) GetIsInternal

func (o *Topic) GetIsInternal() bool

GetIsInternal returns the IsInternal field value if set, zero value otherwise.

func (*Topic) GetIsInternalOk

func (o *Topic) GetIsInternalOk() (*bool, bool)

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

func (*Topic) GetKind

func (o *Topic) GetKind() string

GetKind returns the Kind field value if set, zero value otherwise.

func (*Topic) GetKindOk

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

GetKindOk returns a tuple with the Kind 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) HasHref

func (o *Topic) HasHref() bool

HasHref returns a boolean if a field has been set.

func (*Topic) HasId

func (o *Topic) HasId() bool

HasId returns a boolean if a field has been set.

func (*Topic) HasIsInternal

func (o *Topic) HasIsInternal() bool

HasIsInternal returns a boolean if a field has been set.

func (*Topic) HasKind

func (o *Topic) HasKind() bool

HasKind 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) SetHref

func (o *Topic) SetHref(v string)

SetHref gets a reference to the given string and assigns it to the Href field.

func (*Topic) SetId

func (o *Topic) SetId(v string)

SetId gets a reference to the given string and assigns it to the Id field.

func (*Topic) SetIsInternal

func (o *Topic) SetIsInternal(v bool)

SetIsInternal gets a reference to the given bool and assigns it to the IsInternal field.

func (*Topic) SetKind

func (o *Topic) SetKind(v string)

SetKind gets a reference to the given string and assigns it to the Kind 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 TopicAllOf

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

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

func NewTopicAllOf

func NewTopicAllOf() *TopicAllOf

NewTopicAllOf instantiates a new TopicAllOf 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 NewTopicAllOfWithDefaults

func NewTopicAllOfWithDefaults() *TopicAllOf

NewTopicAllOfWithDefaults instantiates a new TopicAllOf 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 (*TopicAllOf) GetConfig

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

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

func (*TopicAllOf) GetConfigOk

func (o *TopicAllOf) 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 (*TopicAllOf) GetIsInternal

func (o *TopicAllOf) GetIsInternal() bool

GetIsInternal returns the IsInternal field value if set, zero value otherwise.

func (*TopicAllOf) GetIsInternalOk

func (o *TopicAllOf) GetIsInternalOk() (*bool, bool)

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

func (*TopicAllOf) GetName

func (o *TopicAllOf) GetName() string

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

func (*TopicAllOf) GetNameOk

func (o *TopicAllOf) 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 (*TopicAllOf) GetPartitions

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

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

func (*TopicAllOf) GetPartitionsOk

func (o *TopicAllOf) 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 (*TopicAllOf) HasConfig

func (o *TopicAllOf) HasConfig() bool

HasConfig returns a boolean if a field has been set.

func (*TopicAllOf) HasIsInternal

func (o *TopicAllOf) HasIsInternal() bool

HasIsInternal returns a boolean if a field has been set.

func (*TopicAllOf) HasName

func (o *TopicAllOf) HasName() bool

HasName returns a boolean if a field has been set.

func (*TopicAllOf) HasPartitions

func (o *TopicAllOf) HasPartitions() bool

HasPartitions returns a boolean if a field has been set.

func (TopicAllOf) MarshalJSON

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

func (*TopicAllOf) SetConfig

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

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

func (*TopicAllOf) SetIsInternal

func (o *TopicAllOf) SetIsInternal(v bool)

SetIsInternal gets a reference to the given bool and assigns it to the IsInternal field.

func (*TopicAllOf) SetName

func (o *TopicAllOf) SetName(v string)

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

func (*TopicAllOf) SetPartitions

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

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

type TopicOrderKey

type TopicOrderKey string

TopicOrderKey the model 'TopicOrderKey'

const (
	TOPICORDERKEY_NAME            TopicOrderKey = "name"
	TOPICORDERKEY_PARTITIONS      TopicOrderKey = "partitions"
	TOPICORDERKEY_RETENTION_MS    TopicOrderKey = "retention.ms"
	TOPICORDERKEY_RETENTION_BYTES TopicOrderKey = "retention.bytes"
)

List of TopicOrderKey

func NewTopicOrderKeyFromValue

func NewTopicOrderKeyFromValue(v string) (*TopicOrderKey, error)

NewTopicOrderKeyFromValue returns a pointer to a valid TopicOrderKey for the value passed as argument, or an error if the value passed is not allowed by the enum

func (TopicOrderKey) IsValid

func (v TopicOrderKey) IsValid() bool

IsValid return true if the value is valid for the enum, false otherwise

func (TopicOrderKey) Ptr

func (v TopicOrderKey) Ptr() *TopicOrderKey

Ptr returns reference to TopicOrderKey value

func (*TopicOrderKey) UnmarshalJSON

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

type TopicSettings

type TopicSettings struct {
	// Number of partitions for this topic. If not specified, the default for new topics is `1`. Number of partitions may not be reduced when updating existing topics
	NumPartitions *int32 `json:"numPartitions,omitempty"`
	// Topic configuration entries.
	Config *[]ConfigEntry `json:"config,omitempty"`
}

TopicSettings The settings that are applicable to this topic. This includes partitions, configuration information, and number of replicas.

func NewTopicSettings

func NewTopicSettings() *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 if set, zero value otherwise.

func (*TopicSettings) GetNumPartitionsOk

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

GetNumPartitionsOk returns a tuple with the NumPartitions field value if set, nil otherwise 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) HasNumPartitions

func (o *TopicSettings) HasNumPartitions() bool

HasNumPartitions 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 gets a reference to the given int32 and assigns it to the NumPartitions field.

type TopicsApi

type TopicsApi 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)

	/*
	 * 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 Name of the topic to delete
	 * @return ApiDeleteTopicRequest
	 */
	DeleteTopic(ctx _context.Context, topicName string) ApiDeleteTopicRequest

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

	/*
	 * GetTopic Retrieves a single topic
	 * Topic
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param topicName Name of the topic to describe
	 * @return ApiGetTopicRequest
	 */
	GetTopic(ctx _context.Context, topicName string) ApiGetTopicRequest

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

	/*
	 * GetTopics Retrieves a list of topics
	 * Returns a list of all of the available topics, or the list of topics that meet the request query parameters. The topics returned are limited to those records the requestor is authorized to view.
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @return ApiGetTopicsRequest
	 */
	GetTopics(ctx _context.Context) ApiGetTopicsRequest

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

	/*
	 * UpdateTopic Updates a single topic
	 * Update the configuration settings for a topic.
	 * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
	 * @param topicName Name of the topic to update
	 * @return ApiUpdateTopicRequest
	 */
	UpdateTopic(ctx _context.Context, topicName string) ApiUpdateTopicRequest

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

type TopicsApiService

type TopicsApiService service

TopicsApiService TopicsApi service

func (*TopicsApiService) CreateTopic

* 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 (*TopicsApiService) CreateTopicExecute

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

* Execute executes the request * @return Topic

func (*TopicsApiService) DeleteTopic

func (a *TopicsApiService) 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 Name of the topic to delete * @return ApiDeleteTopicRequest

func (*TopicsApiService) DeleteTopicExecute

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

* Execute executes the request

func (*TopicsApiService) GetTopic

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

* GetTopic Retrieves a single topic * Topic * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param topicName Name of the topic to describe * @return ApiGetTopicRequest

func (*TopicsApiService) GetTopicExecute

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

* Execute executes the request * @return Topic

func (*TopicsApiService) GetTopics

* GetTopics Retrieves a list of topics * Returns a list of all of the available topics, or the list of topics that meet the request query parameters. The topics returned are limited to those records the requestor is authorized to view. * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return ApiGetTopicsRequest

func (*TopicsApiService) GetTopicsExecute

* Execute executes the request * @return TopicsList

func (*TopicsApiService) UpdateTopic

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

* UpdateTopic Updates a single topic * Update the configuration settings for a topic. * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param topicName Name of the topic to update * @return ApiUpdateTopicRequest

func (*TopicsApiService) UpdateTopicExecute

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

* Execute executes the request * @return Topic

type TopicsList

type TopicsList struct {
	Kind *string `json:"kind,omitempty"`
	// Total number of entries in the full result set
	Total int32 `json:"total"`
	// Number of entries per page (returned for fetch requests)
	Size *int32 `json:"size,omitempty"`
	// Current page number (returned for fetch requests)
	Page *int32 `json:"page,omitempty"`
	// Offset of the first record returned, zero-based
	Offset *int32 `json:"offset,omitempty"`
	// Maximum number of records to return, from request
	Limit *int32 `json:"limit,omitempty"`
	// Total number of entries in the full result set
	Count *int32  `json:"count,omitempty"`
	Items []Topic `json:"items"`
}

TopicsList struct for TopicsList

func NewTopicsList

func NewTopicsList(total 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 if set, zero value otherwise.

func (*TopicsList) GetCountOk

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

GetCountOk returns a tuple with the Count field value if set, nil otherwise 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) GetKind

func (o *TopicsList) GetKind() string

GetKind returns the Kind field value if set, zero value otherwise.

func (*TopicsList) GetKindOk

func (o *TopicsList) GetKindOk() (*string, bool)

GetKindOk returns a tuple with the Kind field value if set, nil otherwise 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 if set, zero value otherwise.

func (*TopicsList) GetLimitOk

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

GetLimitOk returns a tuple with the Limit field value if set, nil otherwise 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 if set, zero value otherwise.

func (*TopicsList) GetOffsetOk

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

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

func (*TopicsList) GetPage

func (o *TopicsList) GetPage() int32

GetPage returns the Page field value if set, zero value otherwise.

func (*TopicsList) GetPageOk

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

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

func (*TopicsList) GetSize

func (o *TopicsList) GetSize() int32

GetSize returns the Size field value if set, zero value otherwise.

func (*TopicsList) GetSizeOk

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

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

func (*TopicsList) GetTotal

func (o *TopicsList) GetTotal() int32

GetTotal returns the Total field value

func (*TopicsList) GetTotalOk

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

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

func (*TopicsList) HasCount

func (o *TopicsList) HasCount() bool

HasCount returns a boolean if a field has been set.

func (*TopicsList) HasKind

func (o *TopicsList) HasKind() bool

HasKind returns a boolean if a field has been set.

func (*TopicsList) HasLimit

func (o *TopicsList) HasLimit() bool

HasLimit returns a boolean if a field has been set.

func (*TopicsList) HasOffset

func (o *TopicsList) HasOffset() bool

HasOffset returns a boolean if a field has been set.

func (*TopicsList) HasPage

func (o *TopicsList) HasPage() bool

HasPage returns a boolean if a field has been set.

func (*TopicsList) HasSize

func (o *TopicsList) HasSize() bool

HasSize returns a boolean if a field has been set.

func (TopicsList) MarshalJSON

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

func (*TopicsList) SetCount

func (o *TopicsList) SetCount(v int32)

SetCount gets a reference to the given int32 and assigns it to the Count field.

func (*TopicsList) SetItems

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

SetItems sets field value

func (*TopicsList) SetKind

func (o *TopicsList) SetKind(v string)

SetKind gets a reference to the given string and assigns it to the Kind field.

func (*TopicsList) SetLimit

func (o *TopicsList) SetLimit(v int32)

SetLimit gets a reference to the given int32 and assigns it to the Limit field.

func (*TopicsList) SetOffset

func (o *TopicsList) SetOffset(v int32)

SetOffset gets a reference to the given int32 and assigns it to the Offset field.

func (*TopicsList) SetPage

func (o *TopicsList) SetPage(v int32)

SetPage gets a reference to the given int32 and assigns it to the Page field.

func (*TopicsList) SetSize

func (o *TopicsList) SetSize(v int32)

SetSize gets a reference to the given int32 and assigns it to the Size field.

func (*TopicsList) SetTotal

func (o *TopicsList) SetTotal(v int32)

SetTotal sets field value

type TopicsListAllOf

type TopicsListAllOf struct {
	Items []Topic `json:"items"`
}

TopicsListAllOf A list of topics.

func NewTopicsListAllOf

func NewTopicsListAllOf(items []Topic) *TopicsListAllOf

NewTopicsListAllOf instantiates a new TopicsListAllOf 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 NewTopicsListAllOfWithDefaults

func NewTopicsListAllOfWithDefaults() *TopicsListAllOf

NewTopicsListAllOfWithDefaults instantiates a new TopicsListAllOf 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 (*TopicsListAllOf) GetItems

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

GetItems returns the Items field value

func (*TopicsListAllOf) GetItemsOk

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

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

func (TopicsListAllOf) MarshalJSON

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

func (*TopicsListAllOf) SetItems

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

SetItems sets field value

type TopicsToResetOffset

type TopicsToResetOffset struct {
	Topic      string   `json:"topic"`
	Partitions *[]int32 `json:"partitions,omitempty"`
}

TopicsToResetOffset struct for TopicsToResetOffset

func NewTopicsToResetOffset

func NewTopicsToResetOffset(topic string) *TopicsToResetOffset

NewTopicsToResetOffset instantiates a new TopicsToResetOffset 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 NewTopicsToResetOffsetWithDefaults

func NewTopicsToResetOffsetWithDefaults() *TopicsToResetOffset

NewTopicsToResetOffsetWithDefaults instantiates a new TopicsToResetOffset 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 (*TopicsToResetOffset) GetPartitions

func (o *TopicsToResetOffset) GetPartitions() []int32

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

func (*TopicsToResetOffset) GetPartitionsOk

func (o *TopicsToResetOffset) GetPartitionsOk() (*[]int32, 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 (*TopicsToResetOffset) GetTopic

func (o *TopicsToResetOffset) GetTopic() string

GetTopic returns the Topic field value

func (*TopicsToResetOffset) GetTopicOk

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

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

func (*TopicsToResetOffset) HasPartitions

func (o *TopicsToResetOffset) HasPartitions() bool

HasPartitions returns a boolean if a field has been set.

func (TopicsToResetOffset) MarshalJSON

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

func (*TopicsToResetOffset) SetPartitions

func (o *TopicsToResetOffset) SetPartitions(v []int32)

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

func (*TopicsToResetOffset) SetTopic

func (o *TopicsToResetOffset) SetTopic(v string)

SetTopic sets field value

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL