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 

func (v AclBindingOrderKey) Ptr() *AclBindingOrderKey

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 

func (v AclOperationFilter) Ptr() *AclOperationFilter

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 

func (v AclPatternTypeFilter) Ptr() *AclPatternTypeFilter

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 

func (v AclPermissionType) Ptr() *AclPermissionType

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 

func (v AclPermissionTypeFilter) Ptr() *AclPermissionTypeFilter

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 

func (v AclResourceType) Ptr() *AclResourceType

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 

func (v AclResourceTypeFilter) Ptr() *AclResourceTypeFilter

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 

func (a *AclsApiService) CreateAcl(ctx _context.Context) ApiCreateAclRequest

* 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 

func (a *AclsApiService) DeleteAcls(ctx _context.Context) ApiDeleteAclsRequest

* 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 

func (a *AclsApiService) DeleteAclsExecute(r ApiDeleteAclsRequest) (AclBindingListPage, *_nethttp.Response, error)

* 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 

func (a *AclsApiService) GetAcls(ctx _context.Context) ApiGetAclsRequest

* 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 

func (a *AclsApiService) GetAclsExecute(r ApiGetAclsRequest) (AclBindingListPage, *_nethttp.Response, error)

* Execute executes the request * @return AclBindingListPage

type ApiConsumeRecordsRequest 

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

func (ApiConsumeRecordsRequest) Execute 

func (r ApiConsumeRecordsRequest) Execute() (RecordList, *_nethttp.Response, error)

func (ApiConsumeRecordsRequest) Include 

func (r ApiConsumeRecordsRequest) Include(include []RecordIncludedProperty) ApiConsumeRecordsRequest

func (ApiConsumeRecordsRequest) Limit 

func (r ApiConsumeRecordsRequest) Limit(limit int32) ApiConsumeRecordsRequest

func (ApiConsumeRecordsRequest) MaxValueLength 

func (r ApiConsumeRecordsRequest) MaxValueLength(maxValueLength int32) ApiConsumeRecordsRequest

func (ApiConsumeRecordsRequest) Offset 

func (r ApiConsumeRecordsRequest) Offset(offset int32) ApiConsumeRecordsRequest

func (ApiConsumeRecordsRequest) Partition 

func (r ApiConsumeRecordsRequest) Partition(partition int32) ApiConsumeRecordsRequest

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 (r ApiCreateTopicRequest) Execute() (Topic, *_nethttp.Response, error)

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 (r ApiDeleteAclsRequest) Execute() (AclBindingListPage, *_nethttp.Response, error)

func (ApiDeleteAclsRequest) Operation 

func (r ApiDeleteAclsRequest) Operation(operation AclOperationFilter) ApiDeleteAclsRequest

func (ApiDeleteAclsRequest) PatternType 

func (r ApiDeleteAclsRequest) PatternType(patternType AclPatternTypeFilter) ApiDeleteAclsRequest

func (ApiDeleteAclsRequest) Permission 

func (r ApiDeleteAclsRequest) Permission(permission AclPermissionTypeFilter) ApiDeleteAclsRequest

func (ApiDeleteAclsRequest) Principal 

func (r ApiDeleteAclsRequest) Principal(principal string) ApiDeleteAclsRequest

func (ApiDeleteAclsRequest) ResourceName 

func (r ApiDeleteAclsRequest) ResourceName(resourceName string) ApiDeleteAclsRequest

func (ApiDeleteAclsRequest) ResourceType 

func (r ApiDeleteAclsRequest) ResourceType(resourceType AclResourceTypeFilter) ApiDeleteAclsRequest

type ApiDeleteConsumerGroupByIdRequest 

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

func (ApiDeleteConsumerGroupByIdRequest) Execute 

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

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 

func (r ApiGetAclResourceOperationsRequest) Execute() (map[string][]string, *_nethttp.Response, error)

type ApiGetAclsRequest 

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

func (ApiGetAclsRequest) Execute 

func (r ApiGetAclsRequest) Execute() (AclBindingListPage, *_nethttp.Response, error)

func (ApiGetAclsRequest) Operation 

func (r ApiGetAclsRequest) Operation(operation AclOperationFilter) ApiGetAclsRequest

func (ApiGetAclsRequest) Order 

func (r ApiGetAclsRequest) Order(order SortDirection) ApiGetAclsRequest

func (ApiGetAclsRequest) OrderKey 

func (r ApiGetAclsRequest) OrderKey(orderKey AclBindingOrderKey) ApiGetAclsRequest

func (ApiGetAclsRequest) Page 

func (r ApiGetAclsRequest) Page(page int32) ApiGetAclsRequest

func (ApiGetAclsRequest) PatternType 

func (r ApiGetAclsRequest) PatternType(patternType AclPatternTypeFilter) ApiGetAclsRequest

func (ApiGetAclsRequest) Permission 

func (r ApiGetAclsRequest) Permission(permission AclPermissionTypeFilter) ApiGetAclsRequest

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 

func (r ApiGetAclsRequest) Size(size int32) ApiGetAclsRequest

type ApiGetConsumerGroupByIdRequest 

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

func (ApiGetConsumerGroupByIdRequest) Execute 

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

func (ApiGetConsumerGroupByIdRequest) Order 

func (r ApiGetConsumerGroupByIdRequest) Order(order SortDirection) ApiGetConsumerGroupByIdRequest

func (ApiGetConsumerGroupByIdRequest) OrderKey 

func (r ApiGetConsumerGroupByIdRequest) OrderKey(orderKey ConsumerGroupDescriptionOrderKey) ApiGetConsumerGroupByIdRequest

func (ApiGetConsumerGroupByIdRequest) PartitionFilter 

func (r ApiGetConsumerGroupByIdRequest) PartitionFilter(partitionFilter int32) ApiGetConsumerGroupByIdRequest

func (ApiGetConsumerGroupByIdRequest) Topic 

func (r ApiGetConsumerGroupByIdRequest) Topic(topic string) ApiGetConsumerGroupByIdRequest

type ApiGetConsumerGroupsRequest 

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

func (ApiGetConsumerGroupsRequest) Execute 

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

func (ApiGetConsumerGroupsRequest) GroupIdFilter 

func (r ApiGetConsumerGroupsRequest) GroupIdFilter(groupIdFilter string) ApiGetConsumerGroupsRequest

func (ApiGetConsumerGroupsRequest) Limit 

func (r ApiGetConsumerGroupsRequest) Limit(limit int32) ApiGetConsumerGroupsRequest

func (ApiGetConsumerGroupsRequest) Offset 

func (r ApiGetConsumerGroupsRequest) Offset(offset int32) ApiGetConsumerGroupsRequest

func (ApiGetConsumerGroupsRequest) Order 

func (r ApiGetConsumerGroupsRequest) Order(order SortDirection) ApiGetConsumerGroupsRequest

func (ApiGetConsumerGroupsRequest) OrderKey 

func (r ApiGetConsumerGroupsRequest) OrderKey(orderKey ConsumerGroupOrderKey) ApiGetConsumerGroupsRequest

func (ApiGetConsumerGroupsRequest) Page 

func (r ApiGetConsumerGroupsRequest) Page(page int32) ApiGetConsumerGroupsRequest

func (ApiGetConsumerGroupsRequest) Size 

func (r ApiGetConsumerGroupsRequest) Size(size int32) ApiGetConsumerGroupsRequest

func (ApiGetConsumerGroupsRequest) Topic 

func (r ApiGetConsumerGroupsRequest) Topic(topic string) ApiGetConsumerGroupsRequest

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 

func (r ApiGetErrorsRequest) Execute() (ErrorList, *_nethttp.Response, error)

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 (r ApiGetTopicsRequest) Execute() (TopicsList, *_nethttp.Response, error)

func (ApiGetTopicsRequest) Filter 

func (r ApiGetTopicsRequest) Filter(filter string) ApiGetTopicsRequest

func (ApiGetTopicsRequest) Limit 

func (r ApiGetTopicsRequest) Limit(limit int32) ApiGetTopicsRequest

func (ApiGetTopicsRequest) Offset 

func (r ApiGetTopicsRequest) Offset(offset int32) ApiGetTopicsRequest

func (ApiGetTopicsRequest) Order 

func (r ApiGetTopicsRequest) Order(order SortDirection) ApiGetTopicsRequest

func (ApiGetTopicsRequest) OrderKey 

func (r ApiGetTopicsRequest) OrderKey(orderKey TopicOrderKey) ApiGetTopicsRequest

func (ApiGetTopicsRequest) Page 

func (r ApiGetTopicsRequest) Page(page int32) ApiGetTopicsRequest

func (ApiGetTopicsRequest) Size 

func (r ApiGetTopicsRequest) Size(size int32) ApiGetTopicsRequest

type ApiProduceRecordRequest 

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

func (ApiProduceRecordRequest) Execute 

func (r ApiProduceRecordRequest) Execute() (Record, *_nethttp.Response, error)

func (ApiProduceRecordRequest) Record 

func (r ApiProduceRecordRequest) Record(record Record) ApiProduceRecordRequest

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 

func (r ApiResetConsumerGroupOffsetRequest) Execute() (ConsumerGroupResetOffsetResult, *_nethttp.Response, error)

type ApiUpdateTopicRequest 

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

func (ApiUpdateTopicRequest) Execute 

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

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 

func (v ConsumerGroupDescriptionOrderKey) IsValid() bool

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

func (ConsumerGroupDescriptionOrderKey) Ptr 

func (v ConsumerGroupDescriptionOrderKey) Ptr() *ConsumerGroupDescriptionOrderKey

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 

func (v ConsumerGroupOrderKey) Ptr() *ConsumerGroupOrderKey

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 

func (o *ConsumerGroupResetOffsetParameters) GetOffset() OffsetType

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 

func (o *ConsumerGroupResetOffsetParameters) GetTopics() []TopicsToResetOffset

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

func (*ConsumerGroupResetOffsetParameters) GetTopicsOk 

func (o *ConsumerGroupResetOffsetParameters) GetTopicsOk() (*[]TopicsToResetOffset, bool)

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 

func (o *ConsumerGroupResetOffsetParameters) GetValue() string

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 

func (o *ConsumerGroupResetOffsetParameters) HasTopics() bool

HasTopics returns a boolean if a field has been set.

func (*ConsumerGroupResetOffsetParameters) HasValue 

func (o *ConsumerGroupResetOffsetParameters) HasValue() bool

HasValue returns a boolean if a field has been set.

func (ConsumerGroupResetOffsetParameters) MarshalJSON 

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

func (*ConsumerGroupResetOffsetParameters) SetOffset 

func (o *ConsumerGroupResetOffsetParameters) SetOffset(v OffsetType)

SetOffset sets field value

func (*ConsumerGroupResetOffsetParameters) SetTopics 

func (o *ConsumerGroupResetOffsetParameters) SetTopics(v []TopicsToResetOffset)

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

func (*ConsumerGroupResetOffsetParameters) SetValue 

func (o *ConsumerGroupResetOffsetParameters) SetValue(v string)

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 

func (o *ConsumerGroupResetOffsetResult) GetItems() []ConsumerGroupResetOffsetResultItem

GetItems returns the Items field value

func (*ConsumerGroupResetOffsetResult) GetItemsOk 

func (o *ConsumerGroupResetOffsetResult) GetItemsOk() (*[]ConsumerGroupResetOffsetResultItem, bool)

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

func (*ConsumerGroupResetOffsetResult) GetKind 

func (o *ConsumerGroupResetOffsetResult) GetKind() string

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 

func (o *ConsumerGroupResetOffsetResult) GetPage() int32

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 

func (o *ConsumerGroupResetOffsetResult) GetSize() int32

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 

func (o *ConsumerGroupResetOffsetResult) SetItems(v []ConsumerGroupResetOffsetResultItem)

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 

func (o *ConsumerGroupResetOffsetResultAllOf) GetItems() []ConsumerGroupResetOffsetResultItem

GetItems returns the Items field value

func (*ConsumerGroupResetOffsetResultAllOf) GetItemsOk 

func (o *ConsumerGroupResetOffsetResultAllOf) GetItemsOk() (*[]ConsumerGroupResetOffsetResultItem, bool)

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 

func (o *ConsumerGroupResetOffsetResultAllOf) SetItems(v []ConsumerGroupResetOffsetResultItem)

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 

func (o *ConsumerGroupResetOffsetResultItem) GetOffset() int64

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 

func (o *ConsumerGroupResetOffsetResultItem) GetTopic() string

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 

func (o *ConsumerGroupResetOffsetResultItem) HasOffset() bool

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 

func (o *ConsumerGroupResetOffsetResultItem) HasTopic() bool

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 

func (o *ConsumerGroupResetOffsetResultItem) SetTopic(v string)

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 

func (v ConsumerGroupState) Ptr() *ConsumerGroupState

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 

func (a *ErrorsApiService) GetErrors(ctx _context.Context) ApiGetErrorsRequest

* 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 

func (a *ErrorsApiService) GetErrorsExecute(r ApiGetErrorsRequest) (ErrorList, *_nethttp.Response, error)

* 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 

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

* Execute executes the request * @return ConsumerGroup

func (*GroupsApiService) GetConsumerGroups 

func (a *GroupsApiService) GetConsumerGroups(ctx _context.Context) ApiGetConsumerGroupsRequest

* 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 

func (a *GroupsApiService) GetConsumerGroupsExecute(r ApiGetConsumerGroupsRequest) (ConsumerGroupList, *_nethttp.Response, error)

* 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 

func (a *GroupsApiService) ResetConsumerGroupOffsetExecute(r ApiResetConsumerGroupOffsetRequest) (ConsumerGroupResetOffsetResult, *_nethttp.Response, error)

* 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 (v NullableAclBindingAllOf) Get() *AclBindingAllOf

func (NullableAclBindingAllOf) IsSet 

func (v NullableAclBindingAllOf) IsSet() bool

func (NullableAclBindingAllOf) MarshalJSON 

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

func (*NullableAclBindingAllOf) Set 

func (v *NullableAclBindingAllOf) Set(val *AclBindingAllOf)

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 (v NullableAclBindingListPage) Get() *AclBindingListPage

func (NullableAclBindingListPage) IsSet 

func (v NullableAclBindingListPage) IsSet() bool

func (NullableAclBindingListPage) MarshalJSON 

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

func (*NullableAclBindingListPage) Set 

func (v *NullableAclBindingListPage) Set(val *AclBindingListPage)

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 NewNullableAclBindingListPageAllOf 

func NewNullableAclBindingListPageAllOf(val *AclBindingListPageAllOf) *NullableAclBindingListPageAllOf

func (NullableAclBindingListPageAllOf) Get 

func (v NullableAclBindingListPageAllOf) Get() *AclBindingListPageAllOf

func (NullableAclBindingListPageAllOf) IsSet 

func (v NullableAclBindingListPageAllOf) IsSet() bool

func (NullableAclBindingListPageAllOf) MarshalJSON 

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

func (*NullableAclBindingListPageAllOf) Set 

func (v *NullableAclBindingListPageAllOf) Set(val *AclBindingListPageAllOf)

func (*NullableAclBindingListPageAllOf) UnmarshalJSON 

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

func (*NullableAclBindingListPageAllOf) Unset 

func (v *NullableAclBindingListPageAllOf) Unset()

type NullableAclBindingOrderKey 

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

func NewNullableAclBindingOrderKey 

func NewNullableAclBindingOrderKey(val *AclBindingOrderKey) *NullableAclBindingOrderKey

func (NullableAclBindingOrderKey) Get 

func (v NullableAclBindingOrderKey) Get() *AclBindingOrderKey

func (NullableAclBindingOrderKey) IsSet 

func (v NullableAclBindingOrderKey) IsSet() bool

func (NullableAclBindingOrderKey) MarshalJSON 

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

func (*NullableAclBindingOrderKey) Set 

func (v *NullableAclBindingOrderKey) Set(val *AclBindingOrderKey)

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 (v NullableAclOperation) Get() *AclOperation

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 (v NullableAclOperationFilter) Get() *AclOperationFilter

func (NullableAclOperationFilter) IsSet 

func (v NullableAclOperationFilter) IsSet() bool

func (NullableAclOperationFilter) MarshalJSON 

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

func (*NullableAclOperationFilter) Set 

func (v *NullableAclOperationFilter) Set(val *AclOperationFilter)

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 (v NullableAclPatternType) Get() *AclPatternType

func (NullableAclPatternType) IsSet 

func (v NullableAclPatternType) IsSet() bool

func (NullableAclPatternType) MarshalJSON 

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

func (*NullableAclPatternType) Set 

func (v *NullableAclPatternType) Set(val *AclPatternType)

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 (v NullableAclPatternTypeFilter) Get() *AclPatternTypeFilter

func (NullableAclPatternTypeFilter) IsSet 

func (v NullableAclPatternTypeFilter) IsSet() bool

func (NullableAclPatternTypeFilter) MarshalJSON 

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

func (*NullableAclPatternTypeFilter) Set 

func (v *NullableAclPatternTypeFilter) Set(val *AclPatternTypeFilter)

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 (v NullableAclPermissionType) Get() *AclPermissionType

func (NullableAclPermissionType) IsSet 

func (v NullableAclPermissionType) IsSet() bool

func (NullableAclPermissionType) MarshalJSON 

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

func (*NullableAclPermissionType) Set 

func (v *NullableAclPermissionType) Set(val *AclPermissionType)

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 NewNullableAclPermissionTypeFilter 

func NewNullableAclPermissionTypeFilter(val *AclPermissionTypeFilter) *NullableAclPermissionTypeFilter

func (NullableAclPermissionTypeFilter) Get 

func (v NullableAclPermissionTypeFilter) Get() *AclPermissionTypeFilter

func (NullableAclPermissionTypeFilter) IsSet 

func (v NullableAclPermissionTypeFilter) IsSet() bool

func (NullableAclPermissionTypeFilter) MarshalJSON 

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

func (*NullableAclPermissionTypeFilter) Set 

func (v *NullableAclPermissionTypeFilter) Set(val *AclPermissionTypeFilter)

func (*NullableAclPermissionTypeFilter) UnmarshalJSON 

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

func (*NullableAclPermissionTypeFilter) Unset 

func (v *NullableAclPermissionTypeFilter) Unset()

type NullableAclResourceType 

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

func NewNullableAclResourceType 

func NewNullableAclResourceType(val *AclResourceType) *NullableAclResourceType

func (NullableAclResourceType) Get 

func (v NullableAclResourceType) Get() *AclResourceType

func (NullableAclResourceType) IsSet 

func (v NullableAclResourceType) IsSet() bool

func (NullableAclResourceType) MarshalJSON 

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

func (*NullableAclResourceType) Set 

func (v *NullableAclResourceType) Set(val *AclResourceType)

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 NewNullableAclResourceTypeFilter 

func NewNullableAclResourceTypeFilter(val *AclResourceTypeFilter) *NullableAclResourceTypeFilter

func (NullableAclResourceTypeFilter) Get 

func (v NullableAclResourceTypeFilter) Get() *AclResourceTypeFilter

func (NullableAclResourceTypeFilter) IsSet 

func (v NullableAclResourceTypeFilter) IsSet() bool

func (NullableAclResourceTypeFilter) MarshalJSON 

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

func (*NullableAclResourceTypeFilter) Set 

func (v *NullableAclResourceTypeFilter) Set(val *AclResourceTypeFilter)

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 (v NullableConfigEntry) Get() *ConfigEntry

func (NullableConfigEntry) IsSet 

func (v NullableConfigEntry) IsSet() bool

func (NullableConfigEntry) MarshalJSON 

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

func (*NullableConfigEntry) Set 

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

func (*NullableConfigEntry) UnmarshalJSON 

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

func (*NullableConfigEntry) Unset 

func (v *NullableConfigEntry) Unset()

type NullableConsumer 

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

func NewNullableConsumer 

func NewNullableConsumer(val *Consumer) *NullableConsumer

func (NullableConsumer) Get 

func (v NullableConsumer) Get() *Consumer

func (NullableConsumer) IsSet 

func (v NullableConsumer) IsSet() bool

func (NullableConsumer) MarshalJSON 

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

func (*NullableConsumer) Set 

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

func (*NullableConsumer) UnmarshalJSON 

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

func (*NullableConsumer) Unset 

func (v *NullableConsumer) Unset()

type NullableConsumerGroup 

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

func NewNullableConsumerGroup 

func NewNullableConsumerGroup(val *ConsumerGroup) *NullableConsumerGroup

func (NullableConsumerGroup) Get 

func (v NullableConsumerGroup) Get() *ConsumerGroup

func (NullableConsumerGroup) IsSet 

func (v NullableConsumerGroup) IsSet() bool

func (NullableConsumerGroup) MarshalJSON 

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

func (*NullableConsumerGroup) Set 

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

func (*NullableConsumerGroup) UnmarshalJSON 

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

func (*NullableConsumerGroup) Unset 

func (v *NullableConsumerGroup) Unset()

type NullableConsumerGroupAllOf 

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

func NewNullableConsumerGroupAllOf 

func NewNullableConsumerGroupAllOf(val *ConsumerGroupAllOf) *NullableConsumerGroupAllOf

func (NullableConsumerGroupAllOf) Get 

func (v NullableConsumerGroupAllOf) Get() *ConsumerGroupAllOf

func (NullableConsumerGroupAllOf) IsSet 

func (v NullableConsumerGroupAllOf) IsSet() bool

func (NullableConsumerGroupAllOf) MarshalJSON 

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

func (*NullableConsumerGroupAllOf) Set 

func (v *NullableConsumerGroupAllOf) Set(val *ConsumerGroupAllOf)

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 NewNullableConsumerGroupDescriptionOrderKey 

func NewNullableConsumerGroupDescriptionOrderKey(val *ConsumerGroupDescriptionOrderKey) *NullableConsumerGroupDescriptionOrderKey

func (NullableConsumerGroupDescriptionOrderKey) Get 

func (v NullableConsumerGroupDescriptionOrderKey) Get() *ConsumerGroupDescriptionOrderKey

func (NullableConsumerGroupDescriptionOrderKey) IsSet 

func (v NullableConsumerGroupDescriptionOrderKey) IsSet() bool

func (NullableConsumerGroupDescriptionOrderKey) MarshalJSON 

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

func (*NullableConsumerGroupDescriptionOrderKey) Set 

func (v *NullableConsumerGroupDescriptionOrderKey) Set(val *ConsumerGroupDescriptionOrderKey)

func (*NullableConsumerGroupDescriptionOrderKey) UnmarshalJSON 

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

func (*NullableConsumerGroupDescriptionOrderKey) Unset 

func (v *NullableConsumerGroupDescriptionOrderKey) Unset()

type NullableConsumerGroupList 

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

func NewNullableConsumerGroupList 

func NewNullableConsumerGroupList(val *ConsumerGroupList) *NullableConsumerGroupList

func (NullableConsumerGroupList) Get 

func (v NullableConsumerGroupList) Get() *ConsumerGroupList

func (NullableConsumerGroupList) IsSet 

func (v NullableConsumerGroupList) IsSet() bool

func (NullableConsumerGroupList) MarshalJSON 

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

func (*NullableConsumerGroupList) Set 

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

func (*NullableConsumerGroupList) UnmarshalJSON 

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

func (*NullableConsumerGroupList) Unset 

func (v *NullableConsumerGroupList) Unset()

type NullableConsumerGroupListAllOf 

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

func NewNullableConsumerGroupListAllOf 

func NewNullableConsumerGroupListAllOf(val *ConsumerGroupListAllOf) *NullableConsumerGroupListAllOf

func (NullableConsumerGroupListAllOf) Get 

func (v NullableConsumerGroupListAllOf) Get() *ConsumerGroupListAllOf

func (NullableConsumerGroupListAllOf) IsSet 

func (v NullableConsumerGroupListAllOf) IsSet() bool

func (NullableConsumerGroupListAllOf) MarshalJSON 

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

func (*NullableConsumerGroupListAllOf) Set 

func (v *NullableConsumerGroupListAllOf) Set(val *ConsumerGroupListAllOf)

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 (v NullableConsumerGroupMetrics) Get() *ConsumerGroupMetrics

func (NullableConsumerGroupMetrics) IsSet 

func (v NullableConsumerGroupMetrics) IsSet() bool

func (NullableConsumerGroupMetrics) MarshalJSON 

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

func (*NullableConsumerGroupMetrics) Set 

func (v *NullableConsumerGroupMetrics) Set(val *ConsumerGroupMetrics)

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 NewNullableConsumerGroupOrderKey 

func NewNullableConsumerGroupOrderKey(val *ConsumerGroupOrderKey) *NullableConsumerGroupOrderKey

func (NullableConsumerGroupOrderKey) Get 

func (v NullableConsumerGroupOrderKey) Get() *ConsumerGroupOrderKey

func (NullableConsumerGroupOrderKey) IsSet 

func (v NullableConsumerGroupOrderKey) IsSet() bool

func (NullableConsumerGroupOrderKey) MarshalJSON 

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

func (*NullableConsumerGroupOrderKey) Set 

func (v *NullableConsumerGroupOrderKey) Set(val *ConsumerGroupOrderKey)

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 NewNullableConsumerGroupResetOffsetParameters 

func NewNullableConsumerGroupResetOffsetParameters(val *ConsumerGroupResetOffsetParameters) *NullableConsumerGroupResetOffsetParameters

func (NullableConsumerGroupResetOffsetParameters) Get 

func (v NullableConsumerGroupResetOffsetParameters) Get() *ConsumerGroupResetOffsetParameters

func (NullableConsumerGroupResetOffsetParameters) IsSet 

func (v NullableConsumerGroupResetOffsetParameters) IsSet() bool

func (NullableConsumerGroupResetOffsetParameters) MarshalJSON 

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

func (*NullableConsumerGroupResetOffsetParameters) Set 

func (v *NullableConsumerGroupResetOffsetParameters) Set(val *ConsumerGroupResetOffsetParameters)

func (*NullableConsumerGroupResetOffsetParameters) UnmarshalJSON 

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

func (*NullableConsumerGroupResetOffsetParameters) Unset 

func (v *NullableConsumerGroupResetOffsetParameters) Unset()

type NullableConsumerGroupResetOffsetResult 

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

func NewNullableConsumerGroupResetOffsetResult 

func NewNullableConsumerGroupResetOffsetResult(val *ConsumerGroupResetOffsetResult) *NullableConsumerGroupResetOffsetResult

func (NullableConsumerGroupResetOffsetResult) Get 

func (v NullableConsumerGroupResetOffsetResult) Get() *ConsumerGroupResetOffsetResult

func (NullableConsumerGroupResetOffsetResult) IsSet 

func (v NullableConsumerGroupResetOffsetResult) IsSet() bool

func (NullableConsumerGroupResetOffsetResult) MarshalJSON 

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

func (*NullableConsumerGroupResetOffsetResult) Set 

func (v *NullableConsumerGroupResetOffsetResult) Set(val *ConsumerGroupResetOffsetResult)

func (*NullableConsumerGroupResetOffsetResult) UnmarshalJSON 

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

func (*NullableConsumerGroupResetOffsetResult) Unset 

func (v *NullableConsumerGroupResetOffsetResult) Unset()

type NullableConsumerGroupResetOffsetResultAllOf 

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

func NewNullableConsumerGroupResetOffsetResultAllOf 

func NewNullableConsumerGroupResetOffsetResultAllOf(val *ConsumerGroupResetOffsetResultAllOf) *NullableConsumerGroupResetOffsetResultAllOf

func (NullableConsumerGroupResetOffsetResultAllOf) Get 

func (v NullableConsumerGroupResetOffsetResultAllOf) Get() *ConsumerGroupResetOffsetResultAllOf

func (NullableConsumerGroupResetOffsetResultAllOf) IsSet 

func (v NullableConsumerGroupResetOffsetResultAllOf) IsSet() bool

func (NullableConsumerGroupResetOffsetResultAllOf) MarshalJSON 

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

func (*NullableConsumerGroupResetOffsetResultAllOf) Set 

func (v *NullableConsumerGroupResetOffsetResultAllOf) Set(val *ConsumerGroupResetOffsetResultAllOf)

func (*NullableConsumerGroupResetOffsetResultAllOf) UnmarshalJSON 

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

func (*NullableConsumerGroupResetOffsetResultAllOf) Unset 

func (v *NullableConsumerGroupResetOffsetResultAllOf) Unset()

type NullableConsumerGroupResetOffsetResultItem 

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

func NewNullableConsumerGroupResetOffsetResultItem 

func NewNullableConsumerGroupResetOffsetResultItem(val *ConsumerGroupResetOffsetResultItem) *NullableConsumerGroupResetOffsetResultItem

func (NullableConsumerGroupResetOffsetResultItem) Get 

func (v NullableConsumerGroupResetOffsetResultItem) Get() *ConsumerGroupResetOffsetResultItem

func (NullableConsumerGroupResetOffsetResultItem) IsSet 

func (v NullableConsumerGroupResetOffsetResultItem) IsSet() bool

func (NullableConsumerGroupResetOffsetResultItem) MarshalJSON 

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

func (*NullableConsumerGroupResetOffsetResultItem) Set 

func (v *NullableConsumerGroupResetOffsetResultItem) Set(val *ConsumerGroupResetOffsetResultItem)

func (*NullableConsumerGroupResetOffsetResultItem) UnmarshalJSON 

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

func (*NullableConsumerGroupResetOffsetResultItem) Unset 

func (v *NullableConsumerGroupResetOffsetResultItem) Unset()

type NullableConsumerGroupState 

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

func NewNullableConsumerGroupState 

func NewNullableConsumerGroupState(val *ConsumerGroupState) *NullableConsumerGroupState

func (NullableConsumerGroupState) Get 

func (v NullableConsumerGroupState) Get() *ConsumerGroupState

func (NullableConsumerGroupState) IsSet 

func (v NullableConsumerGroupState) IsSet() bool

func (NullableConsumerGroupState) MarshalJSON 

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

func (*NullableConsumerGroupState) Set 

func (v *NullableConsumerGroupState) Set(val *ConsumerGroupState)

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 (v NullableErrorListAllOf) Get() *ErrorListAllOf

func (NullableErrorListAllOf) IsSet 

func (v NullableErrorListAllOf) IsSet() bool

func (NullableErrorListAllOf) MarshalJSON 

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

func (*NullableErrorListAllOf) Set 

func (v *NullableErrorListAllOf) Set(val *ErrorListAllOf)

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 (v NullableListDeprecated) Get() *ListDeprecated

func (NullableListDeprecated) IsSet 

func (v NullableListDeprecated) IsSet() bool

func (NullableListDeprecated) MarshalJSON 

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

func (*NullableListDeprecated) Set 

func (v *NullableListDeprecated) Set(val *ListDeprecated)

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 (v NullableListDeprecatedAllOf) Get() *ListDeprecatedAllOf

func (NullableListDeprecatedAllOf) IsSet 

func (v NullableListDeprecatedAllOf) IsSet() bool

func (NullableListDeprecatedAllOf) MarshalJSON 

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

func (*NullableListDeprecatedAllOf) Set 

func (v *NullableListDeprecatedAllOf) Set(val *ListDeprecatedAllOf)

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 (v NullableNewTopicInput) Get() *NewTopicInput

func (NullableNewTopicInput) IsSet 

func (v NullableNewTopicInput) IsSet() bool

func (NullableNewTopicInput) MarshalJSON 

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

func (*NullableNewTopicInput) Set 

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

func (*NullableNewTopicInput) UnmarshalJSON 

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

func (*NullableNewTopicInput) Unset 

func (v *NullableNewTopicInput) Unset()

type 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 (v NullableObjectReference) Get() *ObjectReference

func (NullableObjectReference) IsSet 

func (v NullableObjectReference) IsSet() bool

func (NullableObjectReference) MarshalJSON 

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

func (*NullableObjectReference) Set 

func (v *NullableObjectReference) Set(val *ObjectReference)

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 (v NullableRecordAllOf) Get() *RecordAllOf

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 NewNullableRecordIncludedProperty 

func NewNullableRecordIncludedProperty(val *RecordIncludedProperty) *NullableRecordIncludedProperty

func (NullableRecordIncludedProperty) Get 

func (v NullableRecordIncludedProperty) Get() *RecordIncludedProperty

func (NullableRecordIncludedProperty) IsSet 

func (v NullableRecordIncludedProperty) IsSet() bool

func (NullableRecordIncludedProperty) MarshalJSON 

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

func (*NullableRecordIncludedProperty) Set 

func (v *NullableRecordIncludedProperty) Set(val *RecordIncludedProperty)

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 (v NullableRecordListAllOf) Get() *RecordListAllOf

func (NullableRecordListAllOf) IsSet 

func (v NullableRecordListAllOf) IsSet() bool

func (NullableRecordListAllOf) MarshalJSON 

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

func (*NullableRecordListAllOf) Set 

func (v *NullableRecordListAllOf) Set(val *RecordListAllOf)

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 (v NullableSortDirection) Get() *SortDirection

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 (v NullableTopicOrderKey) Get() *TopicOrderKey

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 (v NullableTopicSettings) Get() *TopicSettings

func (NullableTopicSettings) IsSet 

func (v NullableTopicSettings) IsSet() bool

func (NullableTopicSettings) MarshalJSON 

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

func (*NullableTopicSettings) Set 

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

func (*NullableTopicSettings) UnmarshalJSON 

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

func (*NullableTopicSettings) Unset 

func (v *NullableTopicSettings) Unset()

type NullableTopicsList 

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

func NewNullableTopicsList 

func NewNullableTopicsList(val *TopicsList) *NullableTopicsList

func (NullableTopicsList) Get 

func (v NullableTopicsList) Get() *TopicsList

func (NullableTopicsList) IsSet 

func (v NullableTopicsList) IsSet() bool

func (NullableTopicsList) MarshalJSON 

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

func (*NullableTopicsList) Set 

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

func (*NullableTopicsList) UnmarshalJSON 

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

func (*NullableTopicsList) Unset 

func (v *NullableTopicsList) Unset()

type NullableTopicsListAllOf 

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

func NewNullableTopicsListAllOf 

func NewNullableTopicsListAllOf(val *TopicsListAllOf) *NullableTopicsListAllOf

func (NullableTopicsListAllOf) Get 

func (v NullableTopicsListAllOf) Get() *TopicsListAllOf

func (NullableTopicsListAllOf) IsSet 

func (v NullableTopicsListAllOf) IsSet() bool

func (NullableTopicsListAllOf) MarshalJSON 

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

func (*NullableTopicsListAllOf) Set 

func (v *NullableTopicsListAllOf) Set(val *TopicsListAllOf)

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 (v NullableTopicsToResetOffset) Get() *TopicsToResetOffset

func (NullableTopicsToResetOffset) IsSet 

func (v NullableTopicsToResetOffset) IsSet() bool

func (NullableTopicsToResetOffset) MarshalJSON 

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

func (*NullableTopicsToResetOffset) Set 

func (v *NullableTopicsToResetOffset) Set(val *TopicsToResetOffset)

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 

func (v RecordIncludedProperty) Ptr() *RecordIncludedProperty

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 

func (a *RecordsApiService) ConsumeRecordsExecute(r ApiConsumeRecordsRequest) (RecordList, *_nethttp.Response, error)

* 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 

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

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

func (*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 

func (a *TopicsApiService) GetTopics(ctx _context.Context) ApiGetTopicsRequest

* 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 

func (a *TopicsApiService) GetTopicsExecute(r ApiGetTopicsRequest) (TopicsList, *_nethttp.Response, error)

* 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

View all Source files

Jump to

Keyboard shortcuts

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