api

package
v0.4.0 Latest Latest
Warning

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

Go to latest
Published: May 8, 2022 License: MIT Imports: 22 Imported by: 0

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 {
	DataplaneApi *DataplaneApiService

	ManagementApi *ManagementApiService
	// contains filtered or unexported fields
}

APIClient manages communication with the httpmq API vv0.4.0-rc.2 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

func (*APIClient) PrepareRequest

func (c *APIClient) PrepareRequest(
	ctx context.Context,
	path string, method string,
	postBody interface{},
	headerParams map[string]string,
	queryParams url.Values,
	formParams url.Values,
	formFiles []formFile) (localVarRequest *http.Request, err error)

PrepareRequest build the request

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 ApiV1AdminAliveGetRequest

type ApiV1AdminAliveGetRequest struct {
	ApiService *ManagementApiService
	// contains filtered or unexported fields
}

func (ApiV1AdminAliveGetRequest) Execute

type ApiV1AdminReadyGetRequest

type ApiV1AdminReadyGetRequest struct {
	ApiService *ManagementApiService
	// contains filtered or unexported fields
}

func (ApiV1AdminReadyGetRequest) Execute

type ApiV1AdminStreamGetRequest

type ApiV1AdminStreamGetRequest struct {
	ApiService *ManagementApiService
	// contains filtered or unexported fields
}

func (ApiV1AdminStreamGetRequest) Execute

func (ApiV1AdminStreamGetRequest) HttpmqRequestID

func (r ApiV1AdminStreamGetRequest) HttpmqRequestID(httpmqRequestID string) ApiV1AdminStreamGetRequest

User provided request ID to match against logs

type ApiV1AdminStreamPostRequest

type ApiV1AdminStreamPostRequest struct {
	ApiService *ManagementApiService
	// contains filtered or unexported fields
}

func (ApiV1AdminStreamPostRequest) Execute

func (ApiV1AdminStreamPostRequest) HttpmqRequestID

func (r ApiV1AdminStreamPostRequest) HttpmqRequestID(httpmqRequestID string) ApiV1AdminStreamPostRequest

User provided request ID to match against logs

func (ApiV1AdminStreamPostRequest) Setting

JetStream stream setting

type ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest

type ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest struct {
	ApiService *ManagementApiService
	// contains filtered or unexported fields
}

func (ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest) Execute

func (ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest) HttpmqRequestID

User provided request ID to match against logs

type ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest

type ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest struct {
	ApiService *ManagementApiService
	// contains filtered or unexported fields
}

func (ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest) Execute

func (ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest) HttpmqRequestID

User provided request ID to match against logs

type ApiV1AdminStreamStreamNameConsumerGetRequest

type ApiV1AdminStreamStreamNameConsumerGetRequest struct {
	ApiService *ManagementApiService
	// contains filtered or unexported fields
}

func (ApiV1AdminStreamStreamNameConsumerGetRequest) Execute

func (ApiV1AdminStreamStreamNameConsumerGetRequest) HttpmqRequestID

User provided request ID to match against logs

type ApiV1AdminStreamStreamNameConsumerPostRequest

type ApiV1AdminStreamStreamNameConsumerPostRequest struct {
	ApiService *ManagementApiService
	// contains filtered or unexported fields
}

func (ApiV1AdminStreamStreamNameConsumerPostRequest) ConsumerParam

Consumer parameters

func (ApiV1AdminStreamStreamNameConsumerPostRequest) Execute

func (ApiV1AdminStreamStreamNameConsumerPostRequest) HttpmqRequestID

User provided request ID to match against logs

type ApiV1AdminStreamStreamNameDeleteRequest

type ApiV1AdminStreamStreamNameDeleteRequest struct {
	ApiService *ManagementApiService
	// contains filtered or unexported fields
}

func (ApiV1AdminStreamStreamNameDeleteRequest) Execute

func (ApiV1AdminStreamStreamNameDeleteRequest) HttpmqRequestID

User provided request ID to match against logs

type ApiV1AdminStreamStreamNameGetRequest

type ApiV1AdminStreamStreamNameGetRequest struct {
	ApiService *ManagementApiService
	// contains filtered or unexported fields
}

func (ApiV1AdminStreamStreamNameGetRequest) Execute

func (ApiV1AdminStreamStreamNameGetRequest) HttpmqRequestID

User provided request ID to match against logs

type ApiV1AdminStreamStreamNameLimitPutRequest

type ApiV1AdminStreamStreamNameLimitPutRequest struct {
	ApiService *ManagementApiService
	// contains filtered or unexported fields
}

func (ApiV1AdminStreamStreamNameLimitPutRequest) Execute

func (ApiV1AdminStreamStreamNameLimitPutRequest) HttpmqRequestID

User provided request ID to match against logs

func (ApiV1AdminStreamStreamNameLimitPutRequest) Limits

New stream limits

type ApiV1AdminStreamStreamNameSubjectPutRequest

type ApiV1AdminStreamStreamNameSubjectPutRequest struct {
	ApiService *ManagementApiService
	// contains filtered or unexported fields
}

func (ApiV1AdminStreamStreamNameSubjectPutRequest) Execute

func (ApiV1AdminStreamStreamNameSubjectPutRequest) HttpmqRequestID

User provided request ID to match against logs

func (ApiV1AdminStreamStreamNameSubjectPutRequest) Subjects

List of new subjects

type ApiV1DataAliveGetRequest

type ApiV1DataAliveGetRequest struct {
	ApiService *DataplaneApiService
	// contains filtered or unexported fields
}

func (ApiV1DataAliveGetRequest) Execute

type ApiV1DataReadyGetRequest

type ApiV1DataReadyGetRequest struct {
	ApiService *DataplaneApiService
	// contains filtered or unexported fields
}

func (ApiV1DataReadyGetRequest) Execute

type ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest

type ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest struct {
	ApiService *DataplaneApiService
	// contains filtered or unexported fields
}

func (ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest) Execute

func (ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest) HttpmqRequestID

User provided request ID to match against logs

func (ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest) SequenceNum

Message message sequence numbers

type ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest

type ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest struct {
	ApiService *DataplaneApiService
	// contains filtered or unexported fields
}

func (ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) DeliveryGroup

Needed if consumer uses delivery groups

func (ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) Execute

func (ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) HttpmqRequestID

User provided request ID to match against logs

func (ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) MaxMsgInflight

Max number of inflight messages (DEFAULT: 1)

func (ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) SubjectName

JetStream subject to subscribe to

type ApiV1DataSubjectSubjectNamePostRequest

type ApiV1DataSubjectSubjectNamePostRequest struct {
	ApiService *DataplaneApiService
	// contains filtered or unexported fields
}

func (ApiV1DataSubjectSubjectNamePostRequest) Execute

func (ApiV1DataSubjectSubjectNamePostRequest) HttpmqRequestID

User provided request ID to match against logs

func (ApiV1DataSubjectSubjectNamePostRequest) Message

Message to publish in Base64 encoding

type ApisAPIRestReqStreamSubjects

type ApisAPIRestReqStreamSubjects struct {
	// Subjects the list of new subject this stream will listen to
	Subjects []string `json:"subjects"`
}

ApisAPIRestReqStreamSubjects struct for ApisAPIRestReqStreamSubjects

func NewApisAPIRestReqStreamSubjects

func NewApisAPIRestReqStreamSubjects(subjects []string) *ApisAPIRestReqStreamSubjects

NewApisAPIRestReqStreamSubjects instantiates a new ApisAPIRestReqStreamSubjects 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 NewApisAPIRestReqStreamSubjectsWithDefaults

func NewApisAPIRestReqStreamSubjectsWithDefaults() *ApisAPIRestReqStreamSubjects

NewApisAPIRestReqStreamSubjectsWithDefaults instantiates a new ApisAPIRestReqStreamSubjects 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 (*ApisAPIRestReqStreamSubjects) GetSubjects

func (o *ApisAPIRestReqStreamSubjects) GetSubjects() []string

GetSubjects returns the Subjects field value

func (*ApisAPIRestReqStreamSubjects) GetSubjectsOk

func (o *ApisAPIRestReqStreamSubjects) GetSubjectsOk() (*[]string, bool)

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

func (ApisAPIRestReqStreamSubjects) MarshalJSON

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

func (*ApisAPIRestReqStreamSubjects) SetSubjects

func (o *ApisAPIRestReqStreamSubjects) SetSubjects(v []string)

SetSubjects sets field value

type ApisAPIRestRespAllJetStreamConsumers

type ApisAPIRestRespAllJetStreamConsumers struct {
	// Consumers the set of consumer details mapped against consumer name
	Consumers *map[string]ApisAPIRestRespConsumerInfo `json:"consumers,omitempty"`
	Error     *GoutilsErrorDetail                     `json:"error,omitempty"`
	// RequestID gives the request ID to match against logs
	RequestId string `json:"request_id"`
	// Success indicates whether the request was successful
	Success bool `json:"success"`
}

ApisAPIRestRespAllJetStreamConsumers struct for ApisAPIRestRespAllJetStreamConsumers

func NewApisAPIRestRespAllJetStreamConsumers

func NewApisAPIRestRespAllJetStreamConsumers(requestId string, success bool) *ApisAPIRestRespAllJetStreamConsumers

NewApisAPIRestRespAllJetStreamConsumers instantiates a new ApisAPIRestRespAllJetStreamConsumers 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 NewApisAPIRestRespAllJetStreamConsumersWithDefaults

func NewApisAPIRestRespAllJetStreamConsumersWithDefaults() *ApisAPIRestRespAllJetStreamConsumers

NewApisAPIRestRespAllJetStreamConsumersWithDefaults instantiates a new ApisAPIRestRespAllJetStreamConsumers 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 (*ApisAPIRestRespAllJetStreamConsumers) GetConsumers

GetConsumers returns the Consumers field value if set, zero value otherwise.

func (*ApisAPIRestRespAllJetStreamConsumers) GetConsumersOk

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

func (*ApisAPIRestRespAllJetStreamConsumers) GetError

GetError returns the Error field value if set, zero value otherwise.

func (*ApisAPIRestRespAllJetStreamConsumers) GetErrorOk

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

func (*ApisAPIRestRespAllJetStreamConsumers) GetRequestId added in v0.3.0

func (o *ApisAPIRestRespAllJetStreamConsumers) GetRequestId() string

GetRequestId returns the RequestId field value

func (*ApisAPIRestRespAllJetStreamConsumers) GetRequestIdOk added in v0.3.0

func (o *ApisAPIRestRespAllJetStreamConsumers) GetRequestIdOk() (*string, bool)

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

func (*ApisAPIRestRespAllJetStreamConsumers) GetSuccess

GetSuccess returns the Success field value

func (*ApisAPIRestRespAllJetStreamConsumers) GetSuccessOk

func (o *ApisAPIRestRespAllJetStreamConsumers) GetSuccessOk() (*bool, bool)

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

func (*ApisAPIRestRespAllJetStreamConsumers) HasConsumers

func (o *ApisAPIRestRespAllJetStreamConsumers) HasConsumers() bool

HasConsumers returns a boolean if a field has been set.

func (*ApisAPIRestRespAllJetStreamConsumers) HasError

HasError returns a boolean if a field has been set.

func (ApisAPIRestRespAllJetStreamConsumers) MarshalJSON

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

func (*ApisAPIRestRespAllJetStreamConsumers) SetConsumers

SetConsumers gets a reference to the given map[string]ApisAPIRestRespConsumerInfo and assigns it to the Consumers field.

func (*ApisAPIRestRespAllJetStreamConsumers) SetError

SetError gets a reference to the given GoutilsErrorDetail and assigns it to the Error field.

func (*ApisAPIRestRespAllJetStreamConsumers) SetRequestId added in v0.3.0

func (o *ApisAPIRestRespAllJetStreamConsumers) SetRequestId(v string)

SetRequestId sets field value

func (*ApisAPIRestRespAllJetStreamConsumers) SetSuccess

func (o *ApisAPIRestRespAllJetStreamConsumers) SetSuccess(v bool)

SetSuccess sets field value

type ApisAPIRestRespAllJetStreams

type ApisAPIRestRespAllJetStreams struct {
	Error *GoutilsErrorDetail `json:"error,omitempty"`
	// RequestID gives the request ID to match against logs
	RequestId string `json:"request_id"`
	// Streams the set of stream details mapped against its names
	Streams *map[string]ApisAPIRestRespStreamInfo `json:"streams,omitempty"`
	// Success indicates whether the request was successful
	Success bool `json:"success"`
}

ApisAPIRestRespAllJetStreams struct for ApisAPIRestRespAllJetStreams

func NewApisAPIRestRespAllJetStreams

func NewApisAPIRestRespAllJetStreams(requestId string, success bool) *ApisAPIRestRespAllJetStreams

NewApisAPIRestRespAllJetStreams instantiates a new ApisAPIRestRespAllJetStreams 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 NewApisAPIRestRespAllJetStreamsWithDefaults

func NewApisAPIRestRespAllJetStreamsWithDefaults() *ApisAPIRestRespAllJetStreams

NewApisAPIRestRespAllJetStreamsWithDefaults instantiates a new ApisAPIRestRespAllJetStreams 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 (*ApisAPIRestRespAllJetStreams) GetError

GetError returns the Error field value if set, zero value otherwise.

func (*ApisAPIRestRespAllJetStreams) GetErrorOk

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

func (*ApisAPIRestRespAllJetStreams) GetRequestId added in v0.3.0

func (o *ApisAPIRestRespAllJetStreams) GetRequestId() string

GetRequestId returns the RequestId field value

func (*ApisAPIRestRespAllJetStreams) GetRequestIdOk added in v0.3.0

func (o *ApisAPIRestRespAllJetStreams) GetRequestIdOk() (*string, bool)

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

func (*ApisAPIRestRespAllJetStreams) GetStreams

GetStreams returns the Streams field value if set, zero value otherwise.

func (*ApisAPIRestRespAllJetStreams) GetStreamsOk

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

func (*ApisAPIRestRespAllJetStreams) GetSuccess

func (o *ApisAPIRestRespAllJetStreams) GetSuccess() bool

GetSuccess returns the Success field value

func (*ApisAPIRestRespAllJetStreams) GetSuccessOk

func (o *ApisAPIRestRespAllJetStreams) GetSuccessOk() (*bool, bool)

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

func (*ApisAPIRestRespAllJetStreams) HasError

func (o *ApisAPIRestRespAllJetStreams) HasError() bool

HasError returns a boolean if a field has been set.

func (*ApisAPIRestRespAllJetStreams) HasStreams

func (o *ApisAPIRestRespAllJetStreams) HasStreams() bool

HasStreams returns a boolean if a field has been set.

func (ApisAPIRestRespAllJetStreams) MarshalJSON

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

func (*ApisAPIRestRespAllJetStreams) SetError

SetError gets a reference to the given GoutilsErrorDetail and assigns it to the Error field.

func (*ApisAPIRestRespAllJetStreams) SetRequestId added in v0.3.0

func (o *ApisAPIRestRespAllJetStreams) SetRequestId(v string)

SetRequestId sets field value

func (*ApisAPIRestRespAllJetStreams) SetStreams

SetStreams gets a reference to the given map[string]ApisAPIRestRespStreamInfo and assigns it to the Streams field.

func (*ApisAPIRestRespAllJetStreams) SetSuccess

func (o *ApisAPIRestRespAllJetStreams) SetSuccess(v bool)

SetSuccess sets field value

type ApisAPIRestRespConsumerConfig

type ApisAPIRestRespConsumerConfig struct {
	// AckWait duration (ns) to wait for an ACK for the delivery of a message
	AckWait int64 `json:"ack_wait"`
	// DeliverGroup is the delivery group if this consumer uses delivery group  A consumer using delivery group allows multiple clients to subscribe under the same consumer and group name tuple. For subjects this consumer listens to, the messages will be shared amongst the connected clients.
	DeliverGroup *string `json:"deliver_group,omitempty"`
	// DeliverSubject subject this consumer is listening on
	DeliverSubject *string `json:"deliver_subject,omitempty"`
	// FilterSubject sets the consumer to filter for subjects matching this NATs subject string  See https://docs.nats.io/nats-concepts/subjects
	FilterSubject *string `json:"filter_subject,omitempty"`
	// MaxAckPending controls the max number of un-ACKed messages permitted in-flight
	MaxAckPending *int64 `json:"max_ack_pending,omitempty"`
	// MaxDeliver max number of times a message can be deliveried (including retry) to this consumer
	MaxDeliver *int64 `json:"max_deliver,omitempty"`
	// MaxWaiting NATS JetStream does not clearly document this
	MaxWaiting *int64 `json:"max_waiting,omitempty"`
	// Description an optional description of the consumer
	Notes *string `json:"notes,omitempty"`
}

ApisAPIRestRespConsumerConfig struct for ApisAPIRestRespConsumerConfig

func NewApisAPIRestRespConsumerConfig

func NewApisAPIRestRespConsumerConfig(ackWait int64) *ApisAPIRestRespConsumerConfig

NewApisAPIRestRespConsumerConfig instantiates a new ApisAPIRestRespConsumerConfig 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 NewApisAPIRestRespConsumerConfigWithDefaults

func NewApisAPIRestRespConsumerConfigWithDefaults() *ApisAPIRestRespConsumerConfig

NewApisAPIRestRespConsumerConfigWithDefaults instantiates a new ApisAPIRestRespConsumerConfig 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 (*ApisAPIRestRespConsumerConfig) GetAckWait

func (o *ApisAPIRestRespConsumerConfig) GetAckWait() int64

GetAckWait returns the AckWait field value

func (*ApisAPIRestRespConsumerConfig) GetAckWaitOk

func (o *ApisAPIRestRespConsumerConfig) GetAckWaitOk() (*int64, bool)

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

func (*ApisAPIRestRespConsumerConfig) GetDeliverGroup

func (o *ApisAPIRestRespConsumerConfig) GetDeliverGroup() string

GetDeliverGroup returns the DeliverGroup field value if set, zero value otherwise.

func (*ApisAPIRestRespConsumerConfig) GetDeliverGroupOk

func (o *ApisAPIRestRespConsumerConfig) GetDeliverGroupOk() (*string, bool)

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

func (*ApisAPIRestRespConsumerConfig) GetDeliverSubject

func (o *ApisAPIRestRespConsumerConfig) GetDeliverSubject() string

GetDeliverSubject returns the DeliverSubject field value if set, zero value otherwise.

func (*ApisAPIRestRespConsumerConfig) GetDeliverSubjectOk

func (o *ApisAPIRestRespConsumerConfig) GetDeliverSubjectOk() (*string, bool)

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

func (*ApisAPIRestRespConsumerConfig) GetFilterSubject

func (o *ApisAPIRestRespConsumerConfig) GetFilterSubject() string

GetFilterSubject returns the FilterSubject field value if set, zero value otherwise.

func (*ApisAPIRestRespConsumerConfig) GetFilterSubjectOk

func (o *ApisAPIRestRespConsumerConfig) GetFilterSubjectOk() (*string, bool)

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

func (*ApisAPIRestRespConsumerConfig) GetMaxAckPending

func (o *ApisAPIRestRespConsumerConfig) GetMaxAckPending() int64

GetMaxAckPending returns the MaxAckPending field value if set, zero value otherwise.

func (*ApisAPIRestRespConsumerConfig) GetMaxAckPendingOk

func (o *ApisAPIRestRespConsumerConfig) GetMaxAckPendingOk() (*int64, bool)

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

func (*ApisAPIRestRespConsumerConfig) GetMaxDeliver

func (o *ApisAPIRestRespConsumerConfig) GetMaxDeliver() int64

GetMaxDeliver returns the MaxDeliver field value if set, zero value otherwise.

func (*ApisAPIRestRespConsumerConfig) GetMaxDeliverOk

func (o *ApisAPIRestRespConsumerConfig) GetMaxDeliverOk() (*int64, bool)

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

func (*ApisAPIRestRespConsumerConfig) GetMaxWaiting

func (o *ApisAPIRestRespConsumerConfig) GetMaxWaiting() int64

GetMaxWaiting returns the MaxWaiting field value if set, zero value otherwise.

func (*ApisAPIRestRespConsumerConfig) GetMaxWaitingOk

func (o *ApisAPIRestRespConsumerConfig) GetMaxWaitingOk() (*int64, bool)

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

func (*ApisAPIRestRespConsumerConfig) GetNotes

func (o *ApisAPIRestRespConsumerConfig) GetNotes() string

GetNotes returns the Notes field value if set, zero value otherwise.

func (*ApisAPIRestRespConsumerConfig) GetNotesOk

func (o *ApisAPIRestRespConsumerConfig) GetNotesOk() (*string, bool)

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

func (*ApisAPIRestRespConsumerConfig) HasDeliverGroup

func (o *ApisAPIRestRespConsumerConfig) HasDeliverGroup() bool

HasDeliverGroup returns a boolean if a field has been set.

func (*ApisAPIRestRespConsumerConfig) HasDeliverSubject

func (o *ApisAPIRestRespConsumerConfig) HasDeliverSubject() bool

HasDeliverSubject returns a boolean if a field has been set.

func (*ApisAPIRestRespConsumerConfig) HasFilterSubject

func (o *ApisAPIRestRespConsumerConfig) HasFilterSubject() bool

HasFilterSubject returns a boolean if a field has been set.

func (*ApisAPIRestRespConsumerConfig) HasMaxAckPending

func (o *ApisAPIRestRespConsumerConfig) HasMaxAckPending() bool

HasMaxAckPending returns a boolean if a field has been set.

func (*ApisAPIRestRespConsumerConfig) HasMaxDeliver

func (o *ApisAPIRestRespConsumerConfig) HasMaxDeliver() bool

HasMaxDeliver returns a boolean if a field has been set.

func (*ApisAPIRestRespConsumerConfig) HasMaxWaiting

func (o *ApisAPIRestRespConsumerConfig) HasMaxWaiting() bool

HasMaxWaiting returns a boolean if a field has been set.

func (*ApisAPIRestRespConsumerConfig) HasNotes

func (o *ApisAPIRestRespConsumerConfig) HasNotes() bool

HasNotes returns a boolean if a field has been set.

func (ApisAPIRestRespConsumerConfig) MarshalJSON

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

func (*ApisAPIRestRespConsumerConfig) SetAckWait

func (o *ApisAPIRestRespConsumerConfig) SetAckWait(v int64)

SetAckWait sets field value

func (*ApisAPIRestRespConsumerConfig) SetDeliverGroup

func (o *ApisAPIRestRespConsumerConfig) SetDeliverGroup(v string)

SetDeliverGroup gets a reference to the given string and assigns it to the DeliverGroup field.

func (*ApisAPIRestRespConsumerConfig) SetDeliverSubject

func (o *ApisAPIRestRespConsumerConfig) SetDeliverSubject(v string)

SetDeliverSubject gets a reference to the given string and assigns it to the DeliverSubject field.

func (*ApisAPIRestRespConsumerConfig) SetFilterSubject

func (o *ApisAPIRestRespConsumerConfig) SetFilterSubject(v string)

SetFilterSubject gets a reference to the given string and assigns it to the FilterSubject field.

func (*ApisAPIRestRespConsumerConfig) SetMaxAckPending

func (o *ApisAPIRestRespConsumerConfig) SetMaxAckPending(v int64)

SetMaxAckPending gets a reference to the given int64 and assigns it to the MaxAckPending field.

func (*ApisAPIRestRespConsumerConfig) SetMaxDeliver

func (o *ApisAPIRestRespConsumerConfig) SetMaxDeliver(v int64)

SetMaxDeliver gets a reference to the given int64 and assigns it to the MaxDeliver field.

func (*ApisAPIRestRespConsumerConfig) SetMaxWaiting

func (o *ApisAPIRestRespConsumerConfig) SetMaxWaiting(v int64)

SetMaxWaiting gets a reference to the given int64 and assigns it to the MaxWaiting field.

func (*ApisAPIRestRespConsumerConfig) SetNotes

func (o *ApisAPIRestRespConsumerConfig) SetNotes(v string)

SetNotes gets a reference to the given string and assigns it to the Notes field.

type ApisAPIRestRespConsumerInfo

type ApisAPIRestRespConsumerInfo struct {
	AckFloor ApisAPIRestRespSequenceInfo   `json:"ack_floor"`
	Config   ApisAPIRestRespConsumerConfig `json:"config"`
	// Created is when this consumer was defined
	Created   string                      `json:"created"`
	Delivered ApisAPIRestRespSequenceInfo `json:"delivered"`
	// Name is the name of the consumer
	Name string `json:"name"`
	// NumAckPending is the number of ACK pending / messages in-flight
	NumAckPending int32 `json:"num_ack_pending"`
	// NumPending is the number of message to be delivered for this consumer
	NumPending int32 `json:"num_pending"`
	// NumRedelivered is the number of messages redelivered
	NumRedelivered int32 `json:"num_redelivered"`
	// NumWaiting NATS JetStream does not clearly document this
	NumWaiting int32 `json:"num_waiting"`
	// Stream is the name of the stream
	StreamName string `json:"stream_name"`
}

ApisAPIRestRespConsumerInfo struct for ApisAPIRestRespConsumerInfo

func NewApisAPIRestRespConsumerInfo

func NewApisAPIRestRespConsumerInfo(ackFloor ApisAPIRestRespSequenceInfo, config ApisAPIRestRespConsumerConfig, created string, delivered ApisAPIRestRespSequenceInfo, name string, numAckPending int32, numPending int32, numRedelivered int32, numWaiting int32, streamName string) *ApisAPIRestRespConsumerInfo

NewApisAPIRestRespConsumerInfo instantiates a new ApisAPIRestRespConsumerInfo 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 NewApisAPIRestRespConsumerInfoWithDefaults

func NewApisAPIRestRespConsumerInfoWithDefaults() *ApisAPIRestRespConsumerInfo

NewApisAPIRestRespConsumerInfoWithDefaults instantiates a new ApisAPIRestRespConsumerInfo 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 (*ApisAPIRestRespConsumerInfo) GetAckFloor

GetAckFloor returns the AckFloor field value

func (*ApisAPIRestRespConsumerInfo) GetAckFloorOk

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

func (*ApisAPIRestRespConsumerInfo) GetConfig

GetConfig returns the Config field value

func (*ApisAPIRestRespConsumerInfo) GetConfigOk

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

func (*ApisAPIRestRespConsumerInfo) GetCreated

func (o *ApisAPIRestRespConsumerInfo) GetCreated() string

GetCreated returns the Created field value

func (*ApisAPIRestRespConsumerInfo) GetCreatedOk

func (o *ApisAPIRestRespConsumerInfo) GetCreatedOk() (*string, bool)

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

func (*ApisAPIRestRespConsumerInfo) GetDelivered

GetDelivered returns the Delivered field value

func (*ApisAPIRestRespConsumerInfo) GetDeliveredOk

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

func (*ApisAPIRestRespConsumerInfo) GetName

func (o *ApisAPIRestRespConsumerInfo) GetName() string

GetName returns the Name field value

func (*ApisAPIRestRespConsumerInfo) GetNameOk

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

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

func (*ApisAPIRestRespConsumerInfo) GetNumAckPending

func (o *ApisAPIRestRespConsumerInfo) GetNumAckPending() int32

GetNumAckPending returns the NumAckPending field value

func (*ApisAPIRestRespConsumerInfo) GetNumAckPendingOk

func (o *ApisAPIRestRespConsumerInfo) GetNumAckPendingOk() (*int32, bool)

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

func (*ApisAPIRestRespConsumerInfo) GetNumPending

func (o *ApisAPIRestRespConsumerInfo) GetNumPending() int32

GetNumPending returns the NumPending field value

func (*ApisAPIRestRespConsumerInfo) GetNumPendingOk

func (o *ApisAPIRestRespConsumerInfo) GetNumPendingOk() (*int32, bool)

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

func (*ApisAPIRestRespConsumerInfo) GetNumRedelivered

func (o *ApisAPIRestRespConsumerInfo) GetNumRedelivered() int32

GetNumRedelivered returns the NumRedelivered field value

func (*ApisAPIRestRespConsumerInfo) GetNumRedeliveredOk

func (o *ApisAPIRestRespConsumerInfo) GetNumRedeliveredOk() (*int32, bool)

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

func (*ApisAPIRestRespConsumerInfo) GetNumWaiting

func (o *ApisAPIRestRespConsumerInfo) GetNumWaiting() int32

GetNumWaiting returns the NumWaiting field value

func (*ApisAPIRestRespConsumerInfo) GetNumWaitingOk

func (o *ApisAPIRestRespConsumerInfo) GetNumWaitingOk() (*int32, bool)

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

func (*ApisAPIRestRespConsumerInfo) GetStreamName

func (o *ApisAPIRestRespConsumerInfo) GetStreamName() string

GetStreamName returns the StreamName field value

func (*ApisAPIRestRespConsumerInfo) GetStreamNameOk

func (o *ApisAPIRestRespConsumerInfo) GetStreamNameOk() (*string, bool)

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

func (ApisAPIRestRespConsumerInfo) MarshalJSON

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

func (*ApisAPIRestRespConsumerInfo) SetAckFloor

SetAckFloor sets field value

func (*ApisAPIRestRespConsumerInfo) SetConfig

SetConfig sets field value

func (*ApisAPIRestRespConsumerInfo) SetCreated

func (o *ApisAPIRestRespConsumerInfo) SetCreated(v string)

SetCreated sets field value

func (*ApisAPIRestRespConsumerInfo) SetDelivered

SetDelivered sets field value

func (*ApisAPIRestRespConsumerInfo) SetName

func (o *ApisAPIRestRespConsumerInfo) SetName(v string)

SetName sets field value

func (*ApisAPIRestRespConsumerInfo) SetNumAckPending

func (o *ApisAPIRestRespConsumerInfo) SetNumAckPending(v int32)

SetNumAckPending sets field value

func (*ApisAPIRestRespConsumerInfo) SetNumPending

func (o *ApisAPIRestRespConsumerInfo) SetNumPending(v int32)

SetNumPending sets field value

func (*ApisAPIRestRespConsumerInfo) SetNumRedelivered

func (o *ApisAPIRestRespConsumerInfo) SetNumRedelivered(v int32)

SetNumRedelivered sets field value

func (*ApisAPIRestRespConsumerInfo) SetNumWaiting

func (o *ApisAPIRestRespConsumerInfo) SetNumWaiting(v int32)

SetNumWaiting sets field value

func (*ApisAPIRestRespConsumerInfo) SetStreamName

func (o *ApisAPIRestRespConsumerInfo) SetStreamName(v string)

SetStreamName sets field value

type ApisAPIRestRespDataMessage

type ApisAPIRestRespDataMessage struct {
	// Message is the message body
	B64Msg []byte `json:"b64_msg"`
	// Consumer is the name of the consumer
	Consumer string              `json:"consumer"`
	Error    *GoutilsErrorDetail `json:"error,omitempty"`
	// RequestID gives the request ID to match against logs
	RequestId string                   `json:"request_id"`
	Sequence  DataplaneMsgToDeliverSeq `json:"sequence"`
	// Stream is the name of the stream
	Stream string `json:"stream"`
	// Subject is the name of the subject / subject filter
	Subject string `json:"subject"`
	// Success indicates whether the request was successful
	Success bool `json:"success"`
}

ApisAPIRestRespDataMessage struct for ApisAPIRestRespDataMessage

func NewApisAPIRestRespDataMessage

func NewApisAPIRestRespDataMessage(b64Msg []byte, consumer string, requestId string, sequence DataplaneMsgToDeliverSeq, stream string, subject string, success bool) *ApisAPIRestRespDataMessage

NewApisAPIRestRespDataMessage instantiates a new ApisAPIRestRespDataMessage 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 NewApisAPIRestRespDataMessageWithDefaults

func NewApisAPIRestRespDataMessageWithDefaults() *ApisAPIRestRespDataMessage

NewApisAPIRestRespDataMessageWithDefaults instantiates a new ApisAPIRestRespDataMessage 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 (*ApisAPIRestRespDataMessage) GetB64Msg

func (o *ApisAPIRestRespDataMessage) GetB64Msg() []byte

GetB64Msg returns the B64Msg field value

func (*ApisAPIRestRespDataMessage) GetB64MsgOk

func (o *ApisAPIRestRespDataMessage) GetB64MsgOk() (*[]byte, bool)

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

func (*ApisAPIRestRespDataMessage) GetConsumer

func (o *ApisAPIRestRespDataMessage) GetConsumer() string

GetConsumer returns the Consumer field value

func (*ApisAPIRestRespDataMessage) GetConsumerOk

func (o *ApisAPIRestRespDataMessage) GetConsumerOk() (*string, bool)

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

func (*ApisAPIRestRespDataMessage) GetError

GetError returns the Error field value if set, zero value otherwise.

func (*ApisAPIRestRespDataMessage) GetErrorOk

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

func (*ApisAPIRestRespDataMessage) GetRequestId added in v0.3.0

func (o *ApisAPIRestRespDataMessage) GetRequestId() string

GetRequestId returns the RequestId field value

func (*ApisAPIRestRespDataMessage) GetRequestIdOk added in v0.3.0

func (o *ApisAPIRestRespDataMessage) GetRequestIdOk() (*string, bool)

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

func (*ApisAPIRestRespDataMessage) GetSequence

GetSequence returns the Sequence field value

func (*ApisAPIRestRespDataMessage) GetSequenceOk

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

func (*ApisAPIRestRespDataMessage) GetStream

func (o *ApisAPIRestRespDataMessage) GetStream() string

GetStream returns the Stream field value

func (*ApisAPIRestRespDataMessage) GetStreamOk

func (o *ApisAPIRestRespDataMessage) GetStreamOk() (*string, bool)

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

func (*ApisAPIRestRespDataMessage) GetSubject

func (o *ApisAPIRestRespDataMessage) GetSubject() string

GetSubject returns the Subject field value

func (*ApisAPIRestRespDataMessage) GetSubjectOk

func (o *ApisAPIRestRespDataMessage) GetSubjectOk() (*string, bool)

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

func (*ApisAPIRestRespDataMessage) GetSuccess

func (o *ApisAPIRestRespDataMessage) GetSuccess() bool

GetSuccess returns the Success field value

func (*ApisAPIRestRespDataMessage) GetSuccessOk

func (o *ApisAPIRestRespDataMessage) GetSuccessOk() (*bool, bool)

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

func (*ApisAPIRestRespDataMessage) HasError

func (o *ApisAPIRestRespDataMessage) HasError() bool

HasError returns a boolean if a field has been set.

func (ApisAPIRestRespDataMessage) MarshalJSON

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

func (*ApisAPIRestRespDataMessage) SetB64Msg

func (o *ApisAPIRestRespDataMessage) SetB64Msg(v []byte)

SetB64Msg sets field value

func (*ApisAPIRestRespDataMessage) SetConsumer

func (o *ApisAPIRestRespDataMessage) SetConsumer(v string)

SetConsumer sets field value

func (*ApisAPIRestRespDataMessage) SetError

SetError gets a reference to the given GoutilsErrorDetail and assigns it to the Error field.

func (*ApisAPIRestRespDataMessage) SetRequestId added in v0.3.0

func (o *ApisAPIRestRespDataMessage) SetRequestId(v string)

SetRequestId sets field value

func (*ApisAPIRestRespDataMessage) SetSequence

SetSequence sets field value

func (*ApisAPIRestRespDataMessage) SetStream

func (o *ApisAPIRestRespDataMessage) SetStream(v string)

SetStream sets field value

func (*ApisAPIRestRespDataMessage) SetSubject

func (o *ApisAPIRestRespDataMessage) SetSubject(v string)

SetSubject sets field value

func (*ApisAPIRestRespDataMessage) SetSuccess

func (o *ApisAPIRestRespDataMessage) SetSuccess(v bool)

SetSuccess sets field value

type ApisAPIRestRespOneJetStream

type ApisAPIRestRespOneJetStream struct {
	Error *GoutilsErrorDetail `json:"error,omitempty"`
	// RequestID gives the request ID to match against logs
	RequestId string                     `json:"request_id"`
	Stream    *ApisAPIRestRespStreamInfo `json:"stream,omitempty"`
	// Success indicates whether the request was successful
	Success bool `json:"success"`
}

ApisAPIRestRespOneJetStream struct for ApisAPIRestRespOneJetStream

func NewApisAPIRestRespOneJetStream

func NewApisAPIRestRespOneJetStream(requestId string, success bool) *ApisAPIRestRespOneJetStream

NewApisAPIRestRespOneJetStream instantiates a new ApisAPIRestRespOneJetStream 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 NewApisAPIRestRespOneJetStreamWithDefaults

func NewApisAPIRestRespOneJetStreamWithDefaults() *ApisAPIRestRespOneJetStream

NewApisAPIRestRespOneJetStreamWithDefaults instantiates a new ApisAPIRestRespOneJetStream 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 (*ApisAPIRestRespOneJetStream) GetError

GetError returns the Error field value if set, zero value otherwise.

func (*ApisAPIRestRespOneJetStream) GetErrorOk

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

func (*ApisAPIRestRespOneJetStream) GetRequestId added in v0.3.0

func (o *ApisAPIRestRespOneJetStream) GetRequestId() string

GetRequestId returns the RequestId field value

func (*ApisAPIRestRespOneJetStream) GetRequestIdOk added in v0.3.0

func (o *ApisAPIRestRespOneJetStream) GetRequestIdOk() (*string, bool)

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

func (*ApisAPIRestRespOneJetStream) GetStream

GetStream returns the Stream field value if set, zero value otherwise.

func (*ApisAPIRestRespOneJetStream) GetStreamOk

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

func (*ApisAPIRestRespOneJetStream) GetSuccess

func (o *ApisAPIRestRespOneJetStream) GetSuccess() bool

GetSuccess returns the Success field value

func (*ApisAPIRestRespOneJetStream) GetSuccessOk

func (o *ApisAPIRestRespOneJetStream) GetSuccessOk() (*bool, bool)

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

func (*ApisAPIRestRespOneJetStream) HasError

func (o *ApisAPIRestRespOneJetStream) HasError() bool

HasError returns a boolean if a field has been set.

func (*ApisAPIRestRespOneJetStream) HasStream

func (o *ApisAPIRestRespOneJetStream) HasStream() bool

HasStream returns a boolean if a field has been set.

func (ApisAPIRestRespOneJetStream) MarshalJSON

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

func (*ApisAPIRestRespOneJetStream) SetError

SetError gets a reference to the given GoutilsErrorDetail and assigns it to the Error field.

func (*ApisAPIRestRespOneJetStream) SetRequestId added in v0.3.0

func (o *ApisAPIRestRespOneJetStream) SetRequestId(v string)

SetRequestId sets field value

func (*ApisAPIRestRespOneJetStream) SetStream

SetStream gets a reference to the given ApisAPIRestRespStreamInfo and assigns it to the Stream field.

func (*ApisAPIRestRespOneJetStream) SetSuccess

func (o *ApisAPIRestRespOneJetStream) SetSuccess(v bool)

SetSuccess sets field value

type ApisAPIRestRespOneJetStreamConsumer

type ApisAPIRestRespOneJetStreamConsumer struct {
	Consumer *ApisAPIRestRespConsumerInfo `json:"consumer,omitempty"`
	Error    *GoutilsErrorDetail          `json:"error,omitempty"`
	// RequestID gives the request ID to match against logs
	RequestId string `json:"request_id"`
	// Success indicates whether the request was successful
	Success bool `json:"success"`
}

ApisAPIRestRespOneJetStreamConsumer struct for ApisAPIRestRespOneJetStreamConsumer

func NewApisAPIRestRespOneJetStreamConsumer

func NewApisAPIRestRespOneJetStreamConsumer(requestId string, success bool) *ApisAPIRestRespOneJetStreamConsumer

NewApisAPIRestRespOneJetStreamConsumer instantiates a new ApisAPIRestRespOneJetStreamConsumer 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 NewApisAPIRestRespOneJetStreamConsumerWithDefaults

func NewApisAPIRestRespOneJetStreamConsumerWithDefaults() *ApisAPIRestRespOneJetStreamConsumer

NewApisAPIRestRespOneJetStreamConsumerWithDefaults instantiates a new ApisAPIRestRespOneJetStreamConsumer 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 (*ApisAPIRestRespOneJetStreamConsumer) GetConsumer

GetConsumer returns the Consumer field value if set, zero value otherwise.

func (*ApisAPIRestRespOneJetStreamConsumer) GetConsumerOk

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

func (*ApisAPIRestRespOneJetStreamConsumer) GetError

GetError returns the Error field value if set, zero value otherwise.

func (*ApisAPIRestRespOneJetStreamConsumer) GetErrorOk

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

func (*ApisAPIRestRespOneJetStreamConsumer) GetRequestId added in v0.3.0

func (o *ApisAPIRestRespOneJetStreamConsumer) GetRequestId() string

GetRequestId returns the RequestId field value

func (*ApisAPIRestRespOneJetStreamConsumer) GetRequestIdOk added in v0.3.0

func (o *ApisAPIRestRespOneJetStreamConsumer) GetRequestIdOk() (*string, bool)

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

func (*ApisAPIRestRespOneJetStreamConsumer) GetSuccess

func (o *ApisAPIRestRespOneJetStreamConsumer) GetSuccess() bool

GetSuccess returns the Success field value

func (*ApisAPIRestRespOneJetStreamConsumer) GetSuccessOk

func (o *ApisAPIRestRespOneJetStreamConsumer) GetSuccessOk() (*bool, bool)

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

func (*ApisAPIRestRespOneJetStreamConsumer) HasConsumer

func (o *ApisAPIRestRespOneJetStreamConsumer) HasConsumer() bool

HasConsumer returns a boolean if a field has been set.

func (*ApisAPIRestRespOneJetStreamConsumer) HasError

HasError returns a boolean if a field has been set.

func (ApisAPIRestRespOneJetStreamConsumer) MarshalJSON

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

func (*ApisAPIRestRespOneJetStreamConsumer) SetConsumer

SetConsumer gets a reference to the given ApisAPIRestRespConsumerInfo and assigns it to the Consumer field.

func (*ApisAPIRestRespOneJetStreamConsumer) SetError

SetError gets a reference to the given GoutilsErrorDetail and assigns it to the Error field.

func (*ApisAPIRestRespOneJetStreamConsumer) SetRequestId added in v0.3.0

func (o *ApisAPIRestRespOneJetStreamConsumer) SetRequestId(v string)

SetRequestId sets field value

func (*ApisAPIRestRespOneJetStreamConsumer) SetSuccess

func (o *ApisAPIRestRespOneJetStreamConsumer) SetSuccess(v bool)

SetSuccess sets field value

type ApisAPIRestRespSequenceInfo

type ApisAPIRestRespSequenceInfo struct {
	// Consumer is consumer level sequence number
	ConsumerSeq int32 `json:"consumer_seq"`
	// Last timestamp when these values updated
	LastActive *string `json:"last_active,omitempty"`
	// Stream is stream level sequence number
	StreamSeq int32 `json:"stream_seq"`
}

ApisAPIRestRespSequenceInfo struct for ApisAPIRestRespSequenceInfo

func NewApisAPIRestRespSequenceInfo

func NewApisAPIRestRespSequenceInfo(consumerSeq int32, streamSeq int32) *ApisAPIRestRespSequenceInfo

NewApisAPIRestRespSequenceInfo instantiates a new ApisAPIRestRespSequenceInfo 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 NewApisAPIRestRespSequenceInfoWithDefaults

func NewApisAPIRestRespSequenceInfoWithDefaults() *ApisAPIRestRespSequenceInfo

NewApisAPIRestRespSequenceInfoWithDefaults instantiates a new ApisAPIRestRespSequenceInfo 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 (*ApisAPIRestRespSequenceInfo) GetConsumerSeq

func (o *ApisAPIRestRespSequenceInfo) GetConsumerSeq() int32

GetConsumerSeq returns the ConsumerSeq field value

func (*ApisAPIRestRespSequenceInfo) GetConsumerSeqOk

func (o *ApisAPIRestRespSequenceInfo) GetConsumerSeqOk() (*int32, bool)

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

func (*ApisAPIRestRespSequenceInfo) GetLastActive

func (o *ApisAPIRestRespSequenceInfo) GetLastActive() string

GetLastActive returns the LastActive field value if set, zero value otherwise.

func (*ApisAPIRestRespSequenceInfo) GetLastActiveOk

func (o *ApisAPIRestRespSequenceInfo) GetLastActiveOk() (*string, bool)

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

func (*ApisAPIRestRespSequenceInfo) GetStreamSeq

func (o *ApisAPIRestRespSequenceInfo) GetStreamSeq() int32

GetStreamSeq returns the StreamSeq field value

func (*ApisAPIRestRespSequenceInfo) GetStreamSeqOk

func (o *ApisAPIRestRespSequenceInfo) GetStreamSeqOk() (*int32, bool)

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

func (*ApisAPIRestRespSequenceInfo) HasLastActive

func (o *ApisAPIRestRespSequenceInfo) HasLastActive() bool

HasLastActive returns a boolean if a field has been set.

func (ApisAPIRestRespSequenceInfo) MarshalJSON

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

func (*ApisAPIRestRespSequenceInfo) SetConsumerSeq

func (o *ApisAPIRestRespSequenceInfo) SetConsumerSeq(v int32)

SetConsumerSeq sets field value

func (*ApisAPIRestRespSequenceInfo) SetLastActive

func (o *ApisAPIRestRespSequenceInfo) SetLastActive(v string)

SetLastActive gets a reference to the given string and assigns it to the LastActive field.

func (*ApisAPIRestRespSequenceInfo) SetStreamSeq

func (o *ApisAPIRestRespSequenceInfo) SetStreamSeq(v int32)

SetStreamSeq sets field value

type ApisAPIRestRespStreamConfig

type ApisAPIRestRespStreamConfig struct {
	// Description is an optional description of the stream
	Description *string `json:"description,omitempty"`
	// MaxBytes is the max duration (ns) the stream will store a message  Messages breaching the limit will be removed.
	MaxAge int64 `json:"max_age"`
	// MaxBytes is the max number of message bytes the stream will store.  Oldest messages are removed once limit breached.
	MaxBytes int64 `json:"max_bytes"`
	// MaxConsumers is the max number of consumers allowed on the stream
	MaxConsumers int64 `json:"max_consumers"`
	// MaxMsgSize is the max size of a message allowed in this stream
	MaxMsgSize *int64 `json:"max_msg_size,omitempty"`
	// MaxMsgs is the max number of messages the stream will store.  Oldest messages are removed once limit breached.
	MaxMsgs int64 `json:"max_msgs"`
	// MaxMsgsPerSubject is the maximum number of subjects allowed on this stream
	MaxMsgsPerSubject int64 `json:"max_msgs_per_subject"`
	// Name is the stream name
	Name string `json:"name"`
	// Subjects is the list subjects this stream is listening on
	Subjects *[]string `json:"subjects,omitempty"`
}

ApisAPIRestRespStreamConfig struct for ApisAPIRestRespStreamConfig

func NewApisAPIRestRespStreamConfig

func NewApisAPIRestRespStreamConfig(maxAge int64, maxBytes int64, maxConsumers int64, maxMsgs int64, maxMsgsPerSubject int64, name string) *ApisAPIRestRespStreamConfig

NewApisAPIRestRespStreamConfig instantiates a new ApisAPIRestRespStreamConfig 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 NewApisAPIRestRespStreamConfigWithDefaults

func NewApisAPIRestRespStreamConfigWithDefaults() *ApisAPIRestRespStreamConfig

NewApisAPIRestRespStreamConfigWithDefaults instantiates a new ApisAPIRestRespStreamConfig 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 (*ApisAPIRestRespStreamConfig) GetDescription

func (o *ApisAPIRestRespStreamConfig) GetDescription() string

GetDescription returns the Description field value if set, zero value otherwise.

func (*ApisAPIRestRespStreamConfig) GetDescriptionOk

func (o *ApisAPIRestRespStreamConfig) GetDescriptionOk() (*string, bool)

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

func (*ApisAPIRestRespStreamConfig) GetMaxAge

func (o *ApisAPIRestRespStreamConfig) GetMaxAge() int64

GetMaxAge returns the MaxAge field value

func (*ApisAPIRestRespStreamConfig) GetMaxAgeOk

func (o *ApisAPIRestRespStreamConfig) GetMaxAgeOk() (*int64, bool)

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

func (*ApisAPIRestRespStreamConfig) GetMaxBytes

func (o *ApisAPIRestRespStreamConfig) GetMaxBytes() int64

GetMaxBytes returns the MaxBytes field value

func (*ApisAPIRestRespStreamConfig) GetMaxBytesOk

func (o *ApisAPIRestRespStreamConfig) GetMaxBytesOk() (*int64, bool)

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

func (*ApisAPIRestRespStreamConfig) GetMaxConsumers

func (o *ApisAPIRestRespStreamConfig) GetMaxConsumers() int64

GetMaxConsumers returns the MaxConsumers field value

func (*ApisAPIRestRespStreamConfig) GetMaxConsumersOk

func (o *ApisAPIRestRespStreamConfig) GetMaxConsumersOk() (*int64, bool)

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

func (*ApisAPIRestRespStreamConfig) GetMaxMsgSize

func (o *ApisAPIRestRespStreamConfig) GetMaxMsgSize() int64

GetMaxMsgSize returns the MaxMsgSize field value if set, zero value otherwise.

func (*ApisAPIRestRespStreamConfig) GetMaxMsgSizeOk

func (o *ApisAPIRestRespStreamConfig) GetMaxMsgSizeOk() (*int64, bool)

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

func (*ApisAPIRestRespStreamConfig) GetMaxMsgs

func (o *ApisAPIRestRespStreamConfig) GetMaxMsgs() int64

GetMaxMsgs returns the MaxMsgs field value

func (*ApisAPIRestRespStreamConfig) GetMaxMsgsOk

func (o *ApisAPIRestRespStreamConfig) GetMaxMsgsOk() (*int64, bool)

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

func (*ApisAPIRestRespStreamConfig) GetMaxMsgsPerSubject

func (o *ApisAPIRestRespStreamConfig) GetMaxMsgsPerSubject() int64

GetMaxMsgsPerSubject returns the MaxMsgsPerSubject field value

func (*ApisAPIRestRespStreamConfig) GetMaxMsgsPerSubjectOk

func (o *ApisAPIRestRespStreamConfig) GetMaxMsgsPerSubjectOk() (*int64, bool)

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

func (*ApisAPIRestRespStreamConfig) GetName

func (o *ApisAPIRestRespStreamConfig) GetName() string

GetName returns the Name field value

func (*ApisAPIRestRespStreamConfig) GetNameOk

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

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

func (*ApisAPIRestRespStreamConfig) GetSubjects

func (o *ApisAPIRestRespStreamConfig) GetSubjects() []string

GetSubjects returns the Subjects field value if set, zero value otherwise.

func (*ApisAPIRestRespStreamConfig) GetSubjectsOk

func (o *ApisAPIRestRespStreamConfig) GetSubjectsOk() (*[]string, bool)

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

func (*ApisAPIRestRespStreamConfig) HasDescription

func (o *ApisAPIRestRespStreamConfig) HasDescription() bool

HasDescription returns a boolean if a field has been set.

func (*ApisAPIRestRespStreamConfig) HasMaxMsgSize

func (o *ApisAPIRestRespStreamConfig) HasMaxMsgSize() bool

HasMaxMsgSize returns a boolean if a field has been set.

func (*ApisAPIRestRespStreamConfig) HasSubjects

func (o *ApisAPIRestRespStreamConfig) HasSubjects() bool

HasSubjects returns a boolean if a field has been set.

func (ApisAPIRestRespStreamConfig) MarshalJSON

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

func (*ApisAPIRestRespStreamConfig) SetDescription

func (o *ApisAPIRestRespStreamConfig) SetDescription(v string)

SetDescription gets a reference to the given string and assigns it to the Description field.

func (*ApisAPIRestRespStreamConfig) SetMaxAge

func (o *ApisAPIRestRespStreamConfig) SetMaxAge(v int64)

SetMaxAge sets field value

func (*ApisAPIRestRespStreamConfig) SetMaxBytes

func (o *ApisAPIRestRespStreamConfig) SetMaxBytes(v int64)

SetMaxBytes sets field value

func (*ApisAPIRestRespStreamConfig) SetMaxConsumers

func (o *ApisAPIRestRespStreamConfig) SetMaxConsumers(v int64)

SetMaxConsumers sets field value

func (*ApisAPIRestRespStreamConfig) SetMaxMsgSize

func (o *ApisAPIRestRespStreamConfig) SetMaxMsgSize(v int64)

SetMaxMsgSize gets a reference to the given int64 and assigns it to the MaxMsgSize field.

func (*ApisAPIRestRespStreamConfig) SetMaxMsgs

func (o *ApisAPIRestRespStreamConfig) SetMaxMsgs(v int64)

SetMaxMsgs sets field value

func (*ApisAPIRestRespStreamConfig) SetMaxMsgsPerSubject

func (o *ApisAPIRestRespStreamConfig) SetMaxMsgsPerSubject(v int64)

SetMaxMsgsPerSubject sets field value

func (*ApisAPIRestRespStreamConfig) SetName

func (o *ApisAPIRestRespStreamConfig) SetName(v string)

SetName sets field value

func (*ApisAPIRestRespStreamConfig) SetSubjects

func (o *ApisAPIRestRespStreamConfig) SetSubjects(v []string)

SetSubjects gets a reference to the given []string and assigns it to the Subjects field.

type ApisAPIRestRespStreamInfo

type ApisAPIRestRespStreamInfo struct {
	Config ApisAPIRestRespStreamConfig `json:"config"`
	// Created is the stream creation timestamp
	Created string                     `json:"created"`
	State   ApisAPIRestRespStreamState `json:"state"`
}

ApisAPIRestRespStreamInfo struct for ApisAPIRestRespStreamInfo

func NewApisAPIRestRespStreamInfo

func NewApisAPIRestRespStreamInfo(config ApisAPIRestRespStreamConfig, created string, state ApisAPIRestRespStreamState) *ApisAPIRestRespStreamInfo

NewApisAPIRestRespStreamInfo instantiates a new ApisAPIRestRespStreamInfo 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 NewApisAPIRestRespStreamInfoWithDefaults

func NewApisAPIRestRespStreamInfoWithDefaults() *ApisAPIRestRespStreamInfo

NewApisAPIRestRespStreamInfoWithDefaults instantiates a new ApisAPIRestRespStreamInfo 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 (*ApisAPIRestRespStreamInfo) GetConfig

GetConfig returns the Config field value

func (*ApisAPIRestRespStreamInfo) GetConfigOk

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

func (*ApisAPIRestRespStreamInfo) GetCreated

func (o *ApisAPIRestRespStreamInfo) GetCreated() string

GetCreated returns the Created field value

func (*ApisAPIRestRespStreamInfo) GetCreatedOk

func (o *ApisAPIRestRespStreamInfo) GetCreatedOk() (*string, bool)

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

func (*ApisAPIRestRespStreamInfo) GetState

GetState returns the State field value

func (*ApisAPIRestRespStreamInfo) GetStateOk

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

func (ApisAPIRestRespStreamInfo) MarshalJSON

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

func (*ApisAPIRestRespStreamInfo) SetConfig

SetConfig sets field value

func (*ApisAPIRestRespStreamInfo) SetCreated

func (o *ApisAPIRestRespStreamInfo) SetCreated(v string)

SetCreated sets field value

func (*ApisAPIRestRespStreamInfo) SetState

SetState sets field value

type ApisAPIRestRespStreamState

type ApisAPIRestRespStreamState struct {
	// Bytes is the number of message bytes in the stream
	Bytes int32 `json:"bytes"`
	// Consumers number of consumers on the stream
	ConsumerCount int32 `json:"consumer_count"`
	// FirstSeq is the oldest message sequence number on the stream
	FirstSeq int32 `json:"first_seq"`
	// FirstTime is the oldest message timestamp on the stream
	FirstTs string `json:"first_ts"`
	// LastSeq is the newest message sequence number on the stream
	LastSeq int32 `json:"last_seq"`
	// LastTime is the newest message timestamp on the stream
	LastTs string `json:"last_ts"`
	// Msgs is the number of messages in the stream
	Messages int32 `json:"messages"`
}

ApisAPIRestRespStreamState struct for ApisAPIRestRespStreamState

func NewApisAPIRestRespStreamState

func NewApisAPIRestRespStreamState(bytes int32, consumerCount int32, firstSeq int32, firstTs string, lastSeq int32, lastTs string, messages int32) *ApisAPIRestRespStreamState

NewApisAPIRestRespStreamState instantiates a new ApisAPIRestRespStreamState 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 NewApisAPIRestRespStreamStateWithDefaults

func NewApisAPIRestRespStreamStateWithDefaults() *ApisAPIRestRespStreamState

NewApisAPIRestRespStreamStateWithDefaults instantiates a new ApisAPIRestRespStreamState 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 (*ApisAPIRestRespStreamState) GetBytes

func (o *ApisAPIRestRespStreamState) GetBytes() int32

GetBytes returns the Bytes field value

func (*ApisAPIRestRespStreamState) GetBytesOk

func (o *ApisAPIRestRespStreamState) GetBytesOk() (*int32, bool)

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

func (*ApisAPIRestRespStreamState) GetConsumerCount

func (o *ApisAPIRestRespStreamState) GetConsumerCount() int32

GetConsumerCount returns the ConsumerCount field value

func (*ApisAPIRestRespStreamState) GetConsumerCountOk

func (o *ApisAPIRestRespStreamState) GetConsumerCountOk() (*int32, bool)

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

func (*ApisAPIRestRespStreamState) GetFirstSeq

func (o *ApisAPIRestRespStreamState) GetFirstSeq() int32

GetFirstSeq returns the FirstSeq field value

func (*ApisAPIRestRespStreamState) GetFirstSeqOk

func (o *ApisAPIRestRespStreamState) GetFirstSeqOk() (*int32, bool)

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

func (*ApisAPIRestRespStreamState) GetFirstTs

func (o *ApisAPIRestRespStreamState) GetFirstTs() string

GetFirstTs returns the FirstTs field value

func (*ApisAPIRestRespStreamState) GetFirstTsOk

func (o *ApisAPIRestRespStreamState) GetFirstTsOk() (*string, bool)

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

func (*ApisAPIRestRespStreamState) GetLastSeq

func (o *ApisAPIRestRespStreamState) GetLastSeq() int32

GetLastSeq returns the LastSeq field value

func (*ApisAPIRestRespStreamState) GetLastSeqOk

func (o *ApisAPIRestRespStreamState) GetLastSeqOk() (*int32, bool)

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

func (*ApisAPIRestRespStreamState) GetLastTs

func (o *ApisAPIRestRespStreamState) GetLastTs() string

GetLastTs returns the LastTs field value

func (*ApisAPIRestRespStreamState) GetLastTsOk

func (o *ApisAPIRestRespStreamState) GetLastTsOk() (*string, bool)

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

func (*ApisAPIRestRespStreamState) GetMessages

func (o *ApisAPIRestRespStreamState) GetMessages() int32

GetMessages returns the Messages field value

func (*ApisAPIRestRespStreamState) GetMessagesOk

func (o *ApisAPIRestRespStreamState) GetMessagesOk() (*int32, bool)

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

func (ApisAPIRestRespStreamState) MarshalJSON

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

func (*ApisAPIRestRespStreamState) SetBytes

func (o *ApisAPIRestRespStreamState) SetBytes(v int32)

SetBytes sets field value

func (*ApisAPIRestRespStreamState) SetConsumerCount

func (o *ApisAPIRestRespStreamState) SetConsumerCount(v int32)

SetConsumerCount sets field value

func (*ApisAPIRestRespStreamState) SetFirstSeq

func (o *ApisAPIRestRespStreamState) SetFirstSeq(v int32)

SetFirstSeq sets field value

func (*ApisAPIRestRespStreamState) SetFirstTs

func (o *ApisAPIRestRespStreamState) SetFirstTs(v string)

SetFirstTs sets field value

func (*ApisAPIRestRespStreamState) SetLastSeq

func (o *ApisAPIRestRespStreamState) SetLastSeq(v int32)

SetLastSeq sets field value

func (*ApisAPIRestRespStreamState) SetLastTs

func (o *ApisAPIRestRespStreamState) SetLastTs(v string)

SetLastTs sets field value

func (*ApisAPIRestRespStreamState) SetMessages

func (o *ApisAPIRestRespStreamState) SetMessages(v int32)

SetMessages sets field value

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 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 DataplaneAckSeqNum

type DataplaneAckSeqNum struct {
	// Consumer is the JetStream message sequence number for this consumer
	Consumer int64 `json:"consumer"`
	// Stream is the JetStream message sequence number for this stream
	Stream int64 `json:"stream"`
}

DataplaneAckSeqNum struct for DataplaneAckSeqNum

func NewDataplaneAckSeqNum

func NewDataplaneAckSeqNum(consumer int64, stream int64) *DataplaneAckSeqNum

NewDataplaneAckSeqNum instantiates a new DataplaneAckSeqNum 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 NewDataplaneAckSeqNumWithDefaults

func NewDataplaneAckSeqNumWithDefaults() *DataplaneAckSeqNum

NewDataplaneAckSeqNumWithDefaults instantiates a new DataplaneAckSeqNum 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 (*DataplaneAckSeqNum) GetConsumer

func (o *DataplaneAckSeqNum) GetConsumer() int64

GetConsumer returns the Consumer field value

func (*DataplaneAckSeqNum) GetConsumerOk

func (o *DataplaneAckSeqNum) GetConsumerOk() (*int64, bool)

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

func (*DataplaneAckSeqNum) GetStream

func (o *DataplaneAckSeqNum) GetStream() int64

GetStream returns the Stream field value

func (*DataplaneAckSeqNum) GetStreamOk

func (o *DataplaneAckSeqNum) GetStreamOk() (*int64, bool)

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

func (DataplaneAckSeqNum) MarshalJSON

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

func (*DataplaneAckSeqNum) SetConsumer

func (o *DataplaneAckSeqNum) SetConsumer(v int64)

SetConsumer sets field value

func (*DataplaneAckSeqNum) SetStream

func (o *DataplaneAckSeqNum) SetStream(v int64)

SetStream sets field value

type DataplaneApiService

type DataplaneApiService service

DataplaneApiService DataplaneApi service

func (*DataplaneApiService) V1DataAliveGet

V1DataAliveGet For dataplane REST API liveness check

Will return success to indicate dataplane REST API module is live

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

func (*DataplaneApiService) V1DataAliveGetExecute

Execute executes the request

@return GoutilsRestAPIBaseResponse

func (*DataplaneApiService) V1DataReadyGet

V1DataReadyGet For dataplane REST API readiness check

Will return success if dataplane REST API module is ready for use

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

func (*DataplaneApiService) V1DataReadyGetExecute

Execute executes the request

@return GoutilsRestAPIBaseResponse

func (*DataplaneApiService) V1DataStreamStreamNameConsumerConsumerNameAckPost

func (a *DataplaneApiService) V1DataStreamStreamNameConsumerConsumerNameAckPost(ctx _context.Context, streamName string, consumerName string) ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest

V1DataStreamStreamNameConsumerConsumerNameAckPost Handle ACK for message

Process JetStream message ACK for a stream / consumer

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param streamName JetStream stream name
@param consumerName JetStream consumer name
@return ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest

func (*DataplaneApiService) V1DataStreamStreamNameConsumerConsumerNameAckPostExecute

Execute executes the request

@return GoutilsRestAPIBaseResponse

func (*DataplaneApiService) V1DataStreamStreamNameConsumerConsumerNameGet

func (a *DataplaneApiService) V1DataStreamStreamNameConsumerConsumerNameGet(ctx _context.Context, streamName string, consumerName string) ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest

V1DataStreamStreamNameConsumerConsumerNameGet Establish a pull subscribe session

Establish a JetStream pull subscribe session for a client. This is a long lived

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param streamName JetStream stream name
@param consumerName JetStream consumer name
@return ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest

func (*DataplaneApiService) V1DataStreamStreamNameConsumerConsumerNameGetExecute

Execute executes the request

@return ApisAPIRestRespDataMessage

func (*DataplaneApiService) V1DataSubjectSubjectNamePost

func (a *DataplaneApiService) V1DataSubjectSubjectNamePost(ctx _context.Context, subjectName string) ApiV1DataSubjectSubjectNamePostRequest

V1DataSubjectSubjectNamePost Publish a message

Publish a Base64 encoded message to a JetStream subject

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param subjectName JetStream subject to publish under
@return ApiV1DataSubjectSubjectNamePostRequest

func (*DataplaneApiService) V1DataSubjectSubjectNamePostExecute

Execute executes the request

@return GoutilsRestAPIBaseResponse

type DataplaneMsgToDeliverSeq

type DataplaneMsgToDeliverSeq struct {
	// Consumer is the message sequence number for this consumer
	Consumer int64 `json:"consumer"`
	// Stream is the message sequence number within the stream
	Stream int64 `json:"stream"`
}

DataplaneMsgToDeliverSeq struct for DataplaneMsgToDeliverSeq

func NewDataplaneMsgToDeliverSeq

func NewDataplaneMsgToDeliverSeq(consumer int64, stream int64) *DataplaneMsgToDeliverSeq

NewDataplaneMsgToDeliverSeq instantiates a new DataplaneMsgToDeliverSeq 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 NewDataplaneMsgToDeliverSeqWithDefaults

func NewDataplaneMsgToDeliverSeqWithDefaults() *DataplaneMsgToDeliverSeq

NewDataplaneMsgToDeliverSeqWithDefaults instantiates a new DataplaneMsgToDeliverSeq 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 (*DataplaneMsgToDeliverSeq) GetConsumer

func (o *DataplaneMsgToDeliverSeq) GetConsumer() int64

GetConsumer returns the Consumer field value

func (*DataplaneMsgToDeliverSeq) GetConsumerOk

func (o *DataplaneMsgToDeliverSeq) GetConsumerOk() (*int64, bool)

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

func (*DataplaneMsgToDeliverSeq) GetStream

func (o *DataplaneMsgToDeliverSeq) GetStream() int64

GetStream returns the Stream field value

func (*DataplaneMsgToDeliverSeq) GetStreamOk

func (o *DataplaneMsgToDeliverSeq) GetStreamOk() (*int64, bool)

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

func (DataplaneMsgToDeliverSeq) MarshalJSON

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

func (*DataplaneMsgToDeliverSeq) SetConsumer

func (o *DataplaneMsgToDeliverSeq) SetConsumer(v int64)

SetConsumer sets field value

func (*DataplaneMsgToDeliverSeq) SetStream

func (o *DataplaneMsgToDeliverSeq) SetStream(v int64)

SetStream sets field value

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 GoutilsErrorDetail added in v0.4.0

type GoutilsErrorDetail struct {
	// Code is the response code
	Code int32 `json:"code"`
	// Detail is an optional descriptive message providing additional details on the error
	Detail *string `json:"detail,omitempty"`
	// Msg is an optional descriptive message
	Message *string `json:"message,omitempty"`
}

GoutilsErrorDetail struct for GoutilsErrorDetail

func NewGoutilsErrorDetail added in v0.4.0

func NewGoutilsErrorDetail(code int32) *GoutilsErrorDetail

NewGoutilsErrorDetail instantiates a new GoutilsErrorDetail 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 NewGoutilsErrorDetailWithDefaults added in v0.4.0

func NewGoutilsErrorDetailWithDefaults() *GoutilsErrorDetail

NewGoutilsErrorDetailWithDefaults instantiates a new GoutilsErrorDetail 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 (*GoutilsErrorDetail) GetCode added in v0.4.0

func (o *GoutilsErrorDetail) GetCode() int32

GetCode returns the Code field value

func (*GoutilsErrorDetail) GetCodeOk added in v0.4.0

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

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

func (*GoutilsErrorDetail) GetDetail added in v0.4.0

func (o *GoutilsErrorDetail) GetDetail() string

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

func (*GoutilsErrorDetail) GetDetailOk added in v0.4.0

func (o *GoutilsErrorDetail) 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 (*GoutilsErrorDetail) GetMessage added in v0.4.0

func (o *GoutilsErrorDetail) GetMessage() string

GetMessage returns the Message field value if set, zero value otherwise.

func (*GoutilsErrorDetail) GetMessageOk added in v0.4.0

func (o *GoutilsErrorDetail) GetMessageOk() (*string, bool)

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

func (*GoutilsErrorDetail) HasDetail added in v0.4.0

func (o *GoutilsErrorDetail) HasDetail() bool

HasDetail returns a boolean if a field has been set.

func (*GoutilsErrorDetail) HasMessage added in v0.4.0

func (o *GoutilsErrorDetail) HasMessage() bool

HasMessage returns a boolean if a field has been set.

func (GoutilsErrorDetail) MarshalJSON added in v0.4.0

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

func (*GoutilsErrorDetail) SetCode added in v0.4.0

func (o *GoutilsErrorDetail) SetCode(v int32)

SetCode sets field value

func (*GoutilsErrorDetail) SetDetail added in v0.4.0

func (o *GoutilsErrorDetail) SetDetail(v string)

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

func (*GoutilsErrorDetail) SetMessage added in v0.4.0

func (o *GoutilsErrorDetail) SetMessage(v string)

SetMessage gets a reference to the given string and assigns it to the Message field.

type GoutilsRestAPIBaseResponse added in v0.4.0

type GoutilsRestAPIBaseResponse struct {
	Error *GoutilsErrorDetail `json:"error,omitempty"`
	// RequestID gives the request ID to match against logs
	RequestId string `json:"request_id"`
	// Success indicates whether the request was successful
	Success bool `json:"success"`
}

GoutilsRestAPIBaseResponse struct for GoutilsRestAPIBaseResponse

func NewGoutilsRestAPIBaseResponse added in v0.4.0

func NewGoutilsRestAPIBaseResponse(requestId string, success bool) *GoutilsRestAPIBaseResponse

NewGoutilsRestAPIBaseResponse instantiates a new GoutilsRestAPIBaseResponse 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 NewGoutilsRestAPIBaseResponseWithDefaults added in v0.4.0

func NewGoutilsRestAPIBaseResponseWithDefaults() *GoutilsRestAPIBaseResponse

NewGoutilsRestAPIBaseResponseWithDefaults instantiates a new GoutilsRestAPIBaseResponse 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 (*GoutilsRestAPIBaseResponse) GetError added in v0.4.0

GetError returns the Error field value if set, zero value otherwise.

func (*GoutilsRestAPIBaseResponse) GetErrorOk added in v0.4.0

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

func (*GoutilsRestAPIBaseResponse) GetRequestId added in v0.4.0

func (o *GoutilsRestAPIBaseResponse) GetRequestId() string

GetRequestId returns the RequestId field value

func (*GoutilsRestAPIBaseResponse) GetRequestIdOk added in v0.4.0

func (o *GoutilsRestAPIBaseResponse) GetRequestIdOk() (*string, bool)

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

func (*GoutilsRestAPIBaseResponse) GetSuccess added in v0.4.0

func (o *GoutilsRestAPIBaseResponse) GetSuccess() bool

GetSuccess returns the Success field value

func (*GoutilsRestAPIBaseResponse) GetSuccessOk added in v0.4.0

func (o *GoutilsRestAPIBaseResponse) GetSuccessOk() (*bool, bool)

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

func (*GoutilsRestAPIBaseResponse) HasError added in v0.4.0

func (o *GoutilsRestAPIBaseResponse) HasError() bool

HasError returns a boolean if a field has been set.

func (GoutilsRestAPIBaseResponse) MarshalJSON added in v0.4.0

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

func (*GoutilsRestAPIBaseResponse) SetError added in v0.4.0

SetError gets a reference to the given GoutilsErrorDetail and assigns it to the Error field.

func (*GoutilsRestAPIBaseResponse) SetRequestId added in v0.4.0

func (o *GoutilsRestAPIBaseResponse) SetRequestId(v string)

SetRequestId sets field value

func (*GoutilsRestAPIBaseResponse) SetSuccess added in v0.4.0

func (o *GoutilsRestAPIBaseResponse) SetSuccess(v bool)

SetSuccess sets field value

type ManagementApiService

type ManagementApiService service

ManagementApiService ManagementApi service

func (*ManagementApiService) V1AdminAliveGet

V1AdminAliveGet For management REST API liveness check

Will return success to indicate management REST API module is live

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

func (*ManagementApiService) V1AdminAliveGetExecute

Execute executes the request

@return GoutilsRestAPIBaseResponse

func (*ManagementApiService) V1AdminReadyGet

V1AdminReadyGet For management REST API readiness check

Will return success if management REST API module is ready for use

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

func (*ManagementApiService) V1AdminReadyGetExecute

Execute executes the request

@return GoutilsRestAPIBaseResponse

func (*ManagementApiService) V1AdminStreamGet

V1AdminStreamGet Query for info on all streams

Query for the details of all streams

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

func (*ManagementApiService) V1AdminStreamGetExecute

Execute executes the request

@return ApisAPIRestRespAllJetStreams

func (*ManagementApiService) V1AdminStreamPost

V1AdminStreamPost Define new stream

Define new JetStream stream

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

func (*ManagementApiService) V1AdminStreamPostExecute

Execute executes the request

@return GoutilsRestAPIBaseResponse

func (*ManagementApiService) V1AdminStreamStreamNameConsumerConsumerNameDelete

func (a *ManagementApiService) V1AdminStreamStreamNameConsumerConsumerNameDelete(ctx _context.Context, streamName string, consumerName string) ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest

V1AdminStreamStreamNameConsumerConsumerNameDelete Delete one consumer of a stream

Delete one consumer of a stream

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param streamName JetStream stream name
@param consumerName JetStream consumer name
@return ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest

func (*ManagementApiService) V1AdminStreamStreamNameConsumerConsumerNameDeleteExecute

Execute executes the request

@return GoutilsRestAPIBaseResponse

func (*ManagementApiService) V1AdminStreamStreamNameConsumerConsumerNameGet

func (a *ManagementApiService) V1AdminStreamStreamNameConsumerConsumerNameGet(ctx _context.Context, streamName string, consumerName string) ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest

V1AdminStreamStreamNameConsumerConsumerNameGet Get one consumer of a stream

Query for the details of a consumer on a stream

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param streamName JetStream stream name
@param consumerName JetStream consumer name
@return ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest

func (*ManagementApiService) V1AdminStreamStreamNameConsumerConsumerNameGetExecute

Execute executes the request

@return ApisAPIRestRespOneJetStreamConsumer

func (*ManagementApiService) V1AdminStreamStreamNameConsumerGet

func (a *ManagementApiService) V1AdminStreamStreamNameConsumerGet(ctx _context.Context, streamName string) ApiV1AdminStreamStreamNameConsumerGetRequest

V1AdminStreamStreamNameConsumerGet Get all consumers of a stream

Query for the details of all consumers of a stream

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param streamName JetStream stream name
@return ApiV1AdminStreamStreamNameConsumerGetRequest

func (*ManagementApiService) V1AdminStreamStreamNameConsumerGetExecute

Execute executes the request

@return ApisAPIRestRespAllJetStreamConsumers

func (*ManagementApiService) V1AdminStreamStreamNameConsumerPost

func (a *ManagementApiService) V1AdminStreamStreamNameConsumerPost(ctx _context.Context, streamName string) ApiV1AdminStreamStreamNameConsumerPostRequest

V1AdminStreamStreamNameConsumerPost Create a consumer on a stream

Create a new consumer on a stream. The stream must already be defined.

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param streamName JetStream stream name
@return ApiV1AdminStreamStreamNameConsumerPostRequest

func (*ManagementApiService) V1AdminStreamStreamNameConsumerPostExecute

Execute executes the request

@return GoutilsRestAPIBaseResponse

func (*ManagementApiService) V1AdminStreamStreamNameDelete

func (a *ManagementApiService) V1AdminStreamStreamNameDelete(ctx _context.Context, streamName string) ApiV1AdminStreamStreamNameDeleteRequest

V1AdminStreamStreamNameDelete Delete a stream

Delete a stream

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param streamName JetStream stream name
@return ApiV1AdminStreamStreamNameDeleteRequest

func (*ManagementApiService) V1AdminStreamStreamNameDeleteExecute

Execute executes the request

@return GoutilsRestAPIBaseResponse

func (*ManagementApiService) V1AdminStreamStreamNameGet

func (a *ManagementApiService) V1AdminStreamStreamNameGet(ctx _context.Context, streamName string) ApiV1AdminStreamStreamNameGetRequest

V1AdminStreamStreamNameGet Query for info on one stream

Query for the details of one stream

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param streamName JetStream stream name
@return ApiV1AdminStreamStreamNameGetRequest

func (*ManagementApiService) V1AdminStreamStreamNameGetExecute

Execute executes the request

@return ApisAPIRestRespOneJetStream

func (*ManagementApiService) V1AdminStreamStreamNameLimitPut

func (a *ManagementApiService) V1AdminStreamStreamNameLimitPut(ctx _context.Context, streamName string) ApiV1AdminStreamStreamNameLimitPutRequest

V1AdminStreamStreamNameLimitPut Change limits a stream

Change the data retention limits of a stream

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param streamName JetStream stream name
@return ApiV1AdminStreamStreamNameLimitPutRequest

func (*ManagementApiService) V1AdminStreamStreamNameLimitPutExecute

Execute executes the request

@return GoutilsRestAPIBaseResponse

func (*ManagementApiService) V1AdminStreamStreamNameSubjectPut

func (a *ManagementApiService) V1AdminStreamStreamNameSubjectPut(ctx _context.Context, streamName string) ApiV1AdminStreamStreamNameSubjectPutRequest

V1AdminStreamStreamNameSubjectPut Change subjects of a stream

Change the list of subjects of interest for a stream

@param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background().
@param streamName JetStream stream name
@return ApiV1AdminStreamStreamNameSubjectPutRequest

func (*ManagementApiService) V1AdminStreamStreamNameSubjectPutExecute

Execute executes the request

@return GoutilsRestAPIBaseResponse

type ManagementJSStreamLimits

type ManagementJSStreamLimits struct {
	// MaxAge is the max duration (ns) the stream will store a message  Messages breaching the limit will be removed.
	MaxAge *int64 `json:"max_age,omitempty"`
	// MaxBytes is the max number of message bytes the stream will store.  Oldest messages are removed once limit breached.
	MaxBytes *int64 `json:"max_bytes,omitempty"`
	// MaxConsumers is the max number of consumers allowed on the stream
	MaxConsumers *int64 `json:"max_consumers,omitempty"`
	// MaxMsgSize is the max size of a message allowed in this stream
	MaxMsgSize *int64 `json:"max_msg_size,omitempty"`
	// MaxMsgs is the max number of messages the stream will store.  Oldest messages are removed once limit breached.
	MaxMsgs *int64 `json:"max_msgs,omitempty"`
	// MaxMsgsPerSubject is the maximum number of subjects allowed on this stream
	MaxMsgsPerSubject *int64 `json:"max_msgs_per_subject,omitempty"`
}

ManagementJSStreamLimits struct for ManagementJSStreamLimits

func NewManagementJSStreamLimits

func NewManagementJSStreamLimits() *ManagementJSStreamLimits

NewManagementJSStreamLimits instantiates a new ManagementJSStreamLimits 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 NewManagementJSStreamLimitsWithDefaults

func NewManagementJSStreamLimitsWithDefaults() *ManagementJSStreamLimits

NewManagementJSStreamLimitsWithDefaults instantiates a new ManagementJSStreamLimits 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 (*ManagementJSStreamLimits) GetMaxAge

func (o *ManagementJSStreamLimits) GetMaxAge() int64

GetMaxAge returns the MaxAge field value if set, zero value otherwise.

func (*ManagementJSStreamLimits) GetMaxAgeOk

func (o *ManagementJSStreamLimits) GetMaxAgeOk() (*int64, bool)

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

func (*ManagementJSStreamLimits) GetMaxBytes

func (o *ManagementJSStreamLimits) GetMaxBytes() int64

GetMaxBytes returns the MaxBytes field value if set, zero value otherwise.

func (*ManagementJSStreamLimits) GetMaxBytesOk

func (o *ManagementJSStreamLimits) GetMaxBytesOk() (*int64, bool)

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

func (*ManagementJSStreamLimits) GetMaxConsumers

func (o *ManagementJSStreamLimits) GetMaxConsumers() int64

GetMaxConsumers returns the MaxConsumers field value if set, zero value otherwise.

func (*ManagementJSStreamLimits) GetMaxConsumersOk

func (o *ManagementJSStreamLimits) GetMaxConsumersOk() (*int64, bool)

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

func (*ManagementJSStreamLimits) GetMaxMsgSize

func (o *ManagementJSStreamLimits) GetMaxMsgSize() int64

GetMaxMsgSize returns the MaxMsgSize field value if set, zero value otherwise.

func (*ManagementJSStreamLimits) GetMaxMsgSizeOk

func (o *ManagementJSStreamLimits) GetMaxMsgSizeOk() (*int64, bool)

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

func (*ManagementJSStreamLimits) GetMaxMsgs

func (o *ManagementJSStreamLimits) GetMaxMsgs() int64

GetMaxMsgs returns the MaxMsgs field value if set, zero value otherwise.

func (*ManagementJSStreamLimits) GetMaxMsgsOk

func (o *ManagementJSStreamLimits) GetMaxMsgsOk() (*int64, bool)

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

func (*ManagementJSStreamLimits) GetMaxMsgsPerSubject

func (o *ManagementJSStreamLimits) GetMaxMsgsPerSubject() int64

GetMaxMsgsPerSubject returns the MaxMsgsPerSubject field value if set, zero value otherwise.

func (*ManagementJSStreamLimits) GetMaxMsgsPerSubjectOk

func (o *ManagementJSStreamLimits) GetMaxMsgsPerSubjectOk() (*int64, bool)

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

func (*ManagementJSStreamLimits) HasMaxAge

func (o *ManagementJSStreamLimits) HasMaxAge() bool

HasMaxAge returns a boolean if a field has been set.

func (*ManagementJSStreamLimits) HasMaxBytes

func (o *ManagementJSStreamLimits) HasMaxBytes() bool

HasMaxBytes returns a boolean if a field has been set.

func (*ManagementJSStreamLimits) HasMaxConsumers

func (o *ManagementJSStreamLimits) HasMaxConsumers() bool

HasMaxConsumers returns a boolean if a field has been set.

func (*ManagementJSStreamLimits) HasMaxMsgSize

func (o *ManagementJSStreamLimits) HasMaxMsgSize() bool

HasMaxMsgSize returns a boolean if a field has been set.

func (*ManagementJSStreamLimits) HasMaxMsgs

func (o *ManagementJSStreamLimits) HasMaxMsgs() bool

HasMaxMsgs returns a boolean if a field has been set.

func (*ManagementJSStreamLimits) HasMaxMsgsPerSubject

func (o *ManagementJSStreamLimits) HasMaxMsgsPerSubject() bool

HasMaxMsgsPerSubject returns a boolean if a field has been set.

func (ManagementJSStreamLimits) MarshalJSON

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

func (*ManagementJSStreamLimits) SetMaxAge

func (o *ManagementJSStreamLimits) SetMaxAge(v int64)

SetMaxAge gets a reference to the given int64 and assigns it to the MaxAge field.

func (*ManagementJSStreamLimits) SetMaxBytes

func (o *ManagementJSStreamLimits) SetMaxBytes(v int64)

SetMaxBytes gets a reference to the given int64 and assigns it to the MaxBytes field.

func (*ManagementJSStreamLimits) SetMaxConsumers

func (o *ManagementJSStreamLimits) SetMaxConsumers(v int64)

SetMaxConsumers gets a reference to the given int64 and assigns it to the MaxConsumers field.

func (*ManagementJSStreamLimits) SetMaxMsgSize

func (o *ManagementJSStreamLimits) SetMaxMsgSize(v int64)

SetMaxMsgSize gets a reference to the given int64 and assigns it to the MaxMsgSize field.

func (*ManagementJSStreamLimits) SetMaxMsgs

func (o *ManagementJSStreamLimits) SetMaxMsgs(v int64)

SetMaxMsgs gets a reference to the given int64 and assigns it to the MaxMsgs field.

func (*ManagementJSStreamLimits) SetMaxMsgsPerSubject

func (o *ManagementJSStreamLimits) SetMaxMsgsPerSubject(v int64)

SetMaxMsgsPerSubject gets a reference to the given int64 and assigns it to the MaxMsgsPerSubject field.

type ManagementJSStreamParam

type ManagementJSStreamParam struct {
	// MaxAge is the max duration (ns) the stream will store a message  Messages breaching the limit will be removed.
	MaxAge *int64 `json:"max_age,omitempty"`
	// MaxBytes is the max number of message bytes the stream will store.  Oldest messages are removed once limit breached.
	MaxBytes *int64 `json:"max_bytes,omitempty"`
	// MaxConsumers is the max number of consumers allowed on the stream
	MaxConsumers *int64 `json:"max_consumers,omitempty"`
	// MaxMsgSize is the max size of a message allowed in this stream
	MaxMsgSize *int64 `json:"max_msg_size,omitempty"`
	// MaxMsgs is the max number of messages the stream will store.  Oldest messages are removed once limit breached.
	MaxMsgs *int64 `json:"max_msgs,omitempty"`
	// MaxMsgsPerSubject is the maximum number of subjects allowed on this stream
	MaxMsgsPerSubject *int64 `json:"max_msgs_per_subject,omitempty"`
	// Name is the stream name
	Name string `json:"name"`
	// Subjects is the list of subjects of interest for this stream
	Subjects *[]string `json:"subjects,omitempty"`
}

ManagementJSStreamParam struct for ManagementJSStreamParam

func NewManagementJSStreamParam

func NewManagementJSStreamParam(name string) *ManagementJSStreamParam

NewManagementJSStreamParam instantiates a new ManagementJSStreamParam 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 NewManagementJSStreamParamWithDefaults

func NewManagementJSStreamParamWithDefaults() *ManagementJSStreamParam

NewManagementJSStreamParamWithDefaults instantiates a new ManagementJSStreamParam 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 (*ManagementJSStreamParam) GetMaxAge

func (o *ManagementJSStreamParam) GetMaxAge() int64

GetMaxAge returns the MaxAge field value if set, zero value otherwise.

func (*ManagementJSStreamParam) GetMaxAgeOk

func (o *ManagementJSStreamParam) GetMaxAgeOk() (*int64, bool)

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

func (*ManagementJSStreamParam) GetMaxBytes

func (o *ManagementJSStreamParam) GetMaxBytes() int64

GetMaxBytes returns the MaxBytes field value if set, zero value otherwise.

func (*ManagementJSStreamParam) GetMaxBytesOk

func (o *ManagementJSStreamParam) GetMaxBytesOk() (*int64, bool)

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

func (*ManagementJSStreamParam) GetMaxConsumers

func (o *ManagementJSStreamParam) GetMaxConsumers() int64

GetMaxConsumers returns the MaxConsumers field value if set, zero value otherwise.

func (*ManagementJSStreamParam) GetMaxConsumersOk

func (o *ManagementJSStreamParam) GetMaxConsumersOk() (*int64, bool)

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

func (*ManagementJSStreamParam) GetMaxMsgSize

func (o *ManagementJSStreamParam) GetMaxMsgSize() int64

GetMaxMsgSize returns the MaxMsgSize field value if set, zero value otherwise.

func (*ManagementJSStreamParam) GetMaxMsgSizeOk

func (o *ManagementJSStreamParam) GetMaxMsgSizeOk() (*int64, bool)

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

func (*ManagementJSStreamParam) GetMaxMsgs

func (o *ManagementJSStreamParam) GetMaxMsgs() int64

GetMaxMsgs returns the MaxMsgs field value if set, zero value otherwise.

func (*ManagementJSStreamParam) GetMaxMsgsOk

func (o *ManagementJSStreamParam) GetMaxMsgsOk() (*int64, bool)

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

func (*ManagementJSStreamParam) GetMaxMsgsPerSubject

func (o *ManagementJSStreamParam) GetMaxMsgsPerSubject() int64

GetMaxMsgsPerSubject returns the MaxMsgsPerSubject field value if set, zero value otherwise.

func (*ManagementJSStreamParam) GetMaxMsgsPerSubjectOk

func (o *ManagementJSStreamParam) GetMaxMsgsPerSubjectOk() (*int64, bool)

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

func (*ManagementJSStreamParam) GetName

func (o *ManagementJSStreamParam) GetName() string

GetName returns the Name field value

func (*ManagementJSStreamParam) GetNameOk

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

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

func (*ManagementJSStreamParam) GetSubjects

func (o *ManagementJSStreamParam) GetSubjects() []string

GetSubjects returns the Subjects field value if set, zero value otherwise.

func (*ManagementJSStreamParam) GetSubjectsOk

func (o *ManagementJSStreamParam) GetSubjectsOk() (*[]string, bool)

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

func (*ManagementJSStreamParam) HasMaxAge

func (o *ManagementJSStreamParam) HasMaxAge() bool

HasMaxAge returns a boolean if a field has been set.

func (*ManagementJSStreamParam) HasMaxBytes

func (o *ManagementJSStreamParam) HasMaxBytes() bool

HasMaxBytes returns a boolean if a field has been set.

func (*ManagementJSStreamParam) HasMaxConsumers

func (o *ManagementJSStreamParam) HasMaxConsumers() bool

HasMaxConsumers returns a boolean if a field has been set.

func (*ManagementJSStreamParam) HasMaxMsgSize

func (o *ManagementJSStreamParam) HasMaxMsgSize() bool

HasMaxMsgSize returns a boolean if a field has been set.

func (*ManagementJSStreamParam) HasMaxMsgs

func (o *ManagementJSStreamParam) HasMaxMsgs() bool

HasMaxMsgs returns a boolean if a field has been set.

func (*ManagementJSStreamParam) HasMaxMsgsPerSubject

func (o *ManagementJSStreamParam) HasMaxMsgsPerSubject() bool

HasMaxMsgsPerSubject returns a boolean if a field has been set.

func (*ManagementJSStreamParam) HasSubjects

func (o *ManagementJSStreamParam) HasSubjects() bool

HasSubjects returns a boolean if a field has been set.

func (ManagementJSStreamParam) MarshalJSON

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

func (*ManagementJSStreamParam) SetMaxAge

func (o *ManagementJSStreamParam) SetMaxAge(v int64)

SetMaxAge gets a reference to the given int64 and assigns it to the MaxAge field.

func (*ManagementJSStreamParam) SetMaxBytes

func (o *ManagementJSStreamParam) SetMaxBytes(v int64)

SetMaxBytes gets a reference to the given int64 and assigns it to the MaxBytes field.

func (*ManagementJSStreamParam) SetMaxConsumers

func (o *ManagementJSStreamParam) SetMaxConsumers(v int64)

SetMaxConsumers gets a reference to the given int64 and assigns it to the MaxConsumers field.

func (*ManagementJSStreamParam) SetMaxMsgSize

func (o *ManagementJSStreamParam) SetMaxMsgSize(v int64)

SetMaxMsgSize gets a reference to the given int64 and assigns it to the MaxMsgSize field.

func (*ManagementJSStreamParam) SetMaxMsgs

func (o *ManagementJSStreamParam) SetMaxMsgs(v int64)

SetMaxMsgs gets a reference to the given int64 and assigns it to the MaxMsgs field.

func (*ManagementJSStreamParam) SetMaxMsgsPerSubject

func (o *ManagementJSStreamParam) SetMaxMsgsPerSubject(v int64)

SetMaxMsgsPerSubject gets a reference to the given int64 and assigns it to the MaxMsgsPerSubject field.

func (*ManagementJSStreamParam) SetName

func (o *ManagementJSStreamParam) SetName(v string)

SetName sets field value

func (*ManagementJSStreamParam) SetSubjects

func (o *ManagementJSStreamParam) SetSubjects(v []string)

SetSubjects gets a reference to the given []string and assigns it to the Subjects field.

type ManagementJetStreamConsumerParam

type ManagementJetStreamConsumerParam struct {
	// AckWait when specified, the number of ns to wait for ACK before retry
	AckWait *int64 `json:"ack_wait,omitempty"`
	// DeliveryGroup creates a consumer using a delivery group name.  A consumer using delivery group allows multiple clients to subscribe under the same consumer and group name tuple. For subjects this consumer listens to, the messages will be shared amongst the connected clients.
	DeliveryGroup *string `json:"delivery_group,omitempty"`
	// FilterSubject sets the consumer to filter for subjects matching this NATs subject string  See https://docs.nats.io/nats-concepts/subjects
	FilterSubject *string `json:"filter_subject,omitempty"`
	// MaxInflight is max number of un-ACKed message permitted in-flight (must be >= 1)
	MaxInflight int64 `json:"max_inflight"`
	// MaxRetry max number of times an un-ACKed message is resent (-1: infinite)
	MaxRetry *int64 `json:"max_retry,omitempty"`
	// Mode whether the consumer is push or pull consumer
	Mode string `json:"mode"`
	// Name is the consumer name
	Name string `json:"name"`
	// Notes are descriptions regarding this consumer
	Notes *string `json:"notes,omitempty"`
}

ManagementJetStreamConsumerParam struct for ManagementJetStreamConsumerParam

func NewManagementJetStreamConsumerParam

func NewManagementJetStreamConsumerParam(maxInflight int64, mode string, name string) *ManagementJetStreamConsumerParam

NewManagementJetStreamConsumerParam instantiates a new ManagementJetStreamConsumerParam 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 NewManagementJetStreamConsumerParamWithDefaults

func NewManagementJetStreamConsumerParamWithDefaults() *ManagementJetStreamConsumerParam

NewManagementJetStreamConsumerParamWithDefaults instantiates a new ManagementJetStreamConsumerParam 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 (*ManagementJetStreamConsumerParam) GetAckWait

func (o *ManagementJetStreamConsumerParam) GetAckWait() int64

GetAckWait returns the AckWait field value if set, zero value otherwise.

func (*ManagementJetStreamConsumerParam) GetAckWaitOk

func (o *ManagementJetStreamConsumerParam) GetAckWaitOk() (*int64, bool)

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

func (*ManagementJetStreamConsumerParam) GetDeliveryGroup

func (o *ManagementJetStreamConsumerParam) GetDeliveryGroup() string

GetDeliveryGroup returns the DeliveryGroup field value if set, zero value otherwise.

func (*ManagementJetStreamConsumerParam) GetDeliveryGroupOk

func (o *ManagementJetStreamConsumerParam) GetDeliveryGroupOk() (*string, bool)

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

func (*ManagementJetStreamConsumerParam) GetFilterSubject

func (o *ManagementJetStreamConsumerParam) GetFilterSubject() string

GetFilterSubject returns the FilterSubject field value if set, zero value otherwise.

func (*ManagementJetStreamConsumerParam) GetFilterSubjectOk

func (o *ManagementJetStreamConsumerParam) GetFilterSubjectOk() (*string, bool)

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

func (*ManagementJetStreamConsumerParam) GetMaxInflight

func (o *ManagementJetStreamConsumerParam) GetMaxInflight() int64

GetMaxInflight returns the MaxInflight field value

func (*ManagementJetStreamConsumerParam) GetMaxInflightOk

func (o *ManagementJetStreamConsumerParam) GetMaxInflightOk() (*int64, bool)

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

func (*ManagementJetStreamConsumerParam) GetMaxRetry

func (o *ManagementJetStreamConsumerParam) GetMaxRetry() int64

GetMaxRetry returns the MaxRetry field value if set, zero value otherwise.

func (*ManagementJetStreamConsumerParam) GetMaxRetryOk

func (o *ManagementJetStreamConsumerParam) GetMaxRetryOk() (*int64, bool)

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

func (*ManagementJetStreamConsumerParam) GetMode

GetMode returns the Mode field value

func (*ManagementJetStreamConsumerParam) GetModeOk

func (o *ManagementJetStreamConsumerParam) GetModeOk() (*string, bool)

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

func (*ManagementJetStreamConsumerParam) GetName

GetName returns the Name field value

func (*ManagementJetStreamConsumerParam) GetNameOk

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

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

func (*ManagementJetStreamConsumerParam) GetNotes

GetNotes returns the Notes field value if set, zero value otherwise.

func (*ManagementJetStreamConsumerParam) GetNotesOk

func (o *ManagementJetStreamConsumerParam) GetNotesOk() (*string, bool)

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

func (*ManagementJetStreamConsumerParam) HasAckWait

func (o *ManagementJetStreamConsumerParam) HasAckWait() bool

HasAckWait returns a boolean if a field has been set.

func (*ManagementJetStreamConsumerParam) HasDeliveryGroup

func (o *ManagementJetStreamConsumerParam) HasDeliveryGroup() bool

HasDeliveryGroup returns a boolean if a field has been set.

func (*ManagementJetStreamConsumerParam) HasFilterSubject

func (o *ManagementJetStreamConsumerParam) HasFilterSubject() bool

HasFilterSubject returns a boolean if a field has been set.

func (*ManagementJetStreamConsumerParam) HasMaxRetry

func (o *ManagementJetStreamConsumerParam) HasMaxRetry() bool

HasMaxRetry returns a boolean if a field has been set.

func (*ManagementJetStreamConsumerParam) HasNotes

func (o *ManagementJetStreamConsumerParam) HasNotes() bool

HasNotes returns a boolean if a field has been set.

func (ManagementJetStreamConsumerParam) MarshalJSON

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

func (*ManagementJetStreamConsumerParam) SetAckWait

func (o *ManagementJetStreamConsumerParam) SetAckWait(v int64)

SetAckWait gets a reference to the given int64 and assigns it to the AckWait field.

func (*ManagementJetStreamConsumerParam) SetDeliveryGroup

func (o *ManagementJetStreamConsumerParam) SetDeliveryGroup(v string)

SetDeliveryGroup gets a reference to the given string and assigns it to the DeliveryGroup field.

func (*ManagementJetStreamConsumerParam) SetFilterSubject

func (o *ManagementJetStreamConsumerParam) SetFilterSubject(v string)

SetFilterSubject gets a reference to the given string and assigns it to the FilterSubject field.

func (*ManagementJetStreamConsumerParam) SetMaxInflight

func (o *ManagementJetStreamConsumerParam) SetMaxInflight(v int64)

SetMaxInflight sets field value

func (*ManagementJetStreamConsumerParam) SetMaxRetry

func (o *ManagementJetStreamConsumerParam) SetMaxRetry(v int64)

SetMaxRetry gets a reference to the given int64 and assigns it to the MaxRetry field.

func (*ManagementJetStreamConsumerParam) SetMode

SetMode sets field value

func (*ManagementJetStreamConsumerParam) SetName

SetName sets field value

func (*ManagementJetStreamConsumerParam) SetNotes

SetNotes gets a reference to the given string and assigns it to the Notes field.

type NullableApisAPIRestReqStreamSubjects

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

func (NullableApisAPIRestReqStreamSubjects) Get

func (NullableApisAPIRestReqStreamSubjects) IsSet

func (NullableApisAPIRestReqStreamSubjects) MarshalJSON

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

func (*NullableApisAPIRestReqStreamSubjects) Set

func (*NullableApisAPIRestReqStreamSubjects) UnmarshalJSON

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

func (*NullableApisAPIRestReqStreamSubjects) Unset

type NullableApisAPIRestRespAllJetStreamConsumers

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

func (NullableApisAPIRestRespAllJetStreamConsumers) Get

func (NullableApisAPIRestRespAllJetStreamConsumers) IsSet

func (NullableApisAPIRestRespAllJetStreamConsumers) MarshalJSON

func (*NullableApisAPIRestRespAllJetStreamConsumers) Set

func (*NullableApisAPIRestRespAllJetStreamConsumers) UnmarshalJSON

func (*NullableApisAPIRestRespAllJetStreamConsumers) Unset

type NullableApisAPIRestRespAllJetStreams

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

func (NullableApisAPIRestRespAllJetStreams) Get

func (NullableApisAPIRestRespAllJetStreams) IsSet

func (NullableApisAPIRestRespAllJetStreams) MarshalJSON

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

func (*NullableApisAPIRestRespAllJetStreams) Set

func (*NullableApisAPIRestRespAllJetStreams) UnmarshalJSON

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

func (*NullableApisAPIRestRespAllJetStreams) Unset

type NullableApisAPIRestRespConsumerConfig

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

func (NullableApisAPIRestRespConsumerConfig) Get

func (NullableApisAPIRestRespConsumerConfig) IsSet

func (NullableApisAPIRestRespConsumerConfig) MarshalJSON

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

func (*NullableApisAPIRestRespConsumerConfig) Set

func (*NullableApisAPIRestRespConsumerConfig) UnmarshalJSON

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

func (*NullableApisAPIRestRespConsumerConfig) Unset

type NullableApisAPIRestRespConsumerInfo

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

func (NullableApisAPIRestRespConsumerInfo) Get

func (NullableApisAPIRestRespConsumerInfo) IsSet

func (NullableApisAPIRestRespConsumerInfo) MarshalJSON

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

func (*NullableApisAPIRestRespConsumerInfo) Set

func (*NullableApisAPIRestRespConsumerInfo) UnmarshalJSON

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

func (*NullableApisAPIRestRespConsumerInfo) Unset

type NullableApisAPIRestRespDataMessage

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

func (NullableApisAPIRestRespDataMessage) Get

func (NullableApisAPIRestRespDataMessage) IsSet

func (NullableApisAPIRestRespDataMessage) MarshalJSON

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

func (*NullableApisAPIRestRespDataMessage) Set

func (*NullableApisAPIRestRespDataMessage) UnmarshalJSON

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

func (*NullableApisAPIRestRespDataMessage) Unset

type NullableApisAPIRestRespOneJetStream

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

func (NullableApisAPIRestRespOneJetStream) Get

func (NullableApisAPIRestRespOneJetStream) IsSet

func (NullableApisAPIRestRespOneJetStream) MarshalJSON

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

func (*NullableApisAPIRestRespOneJetStream) Set

func (*NullableApisAPIRestRespOneJetStream) UnmarshalJSON

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

func (*NullableApisAPIRestRespOneJetStream) Unset

type NullableApisAPIRestRespOneJetStreamConsumer

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

func (NullableApisAPIRestRespOneJetStreamConsumer) Get

func (NullableApisAPIRestRespOneJetStreamConsumer) IsSet

func (NullableApisAPIRestRespOneJetStreamConsumer) MarshalJSON

func (*NullableApisAPIRestRespOneJetStreamConsumer) Set

func (*NullableApisAPIRestRespOneJetStreamConsumer) UnmarshalJSON

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

func (*NullableApisAPIRestRespOneJetStreamConsumer) Unset

type NullableApisAPIRestRespSequenceInfo

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

func (NullableApisAPIRestRespSequenceInfo) Get

func (NullableApisAPIRestRespSequenceInfo) IsSet

func (NullableApisAPIRestRespSequenceInfo) MarshalJSON

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

func (*NullableApisAPIRestRespSequenceInfo) Set

func (*NullableApisAPIRestRespSequenceInfo) UnmarshalJSON

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

func (*NullableApisAPIRestRespSequenceInfo) Unset

type NullableApisAPIRestRespStreamConfig

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

func (NullableApisAPIRestRespStreamConfig) Get

func (NullableApisAPIRestRespStreamConfig) IsSet

func (NullableApisAPIRestRespStreamConfig) MarshalJSON

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

func (*NullableApisAPIRestRespStreamConfig) Set

func (*NullableApisAPIRestRespStreamConfig) UnmarshalJSON

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

func (*NullableApisAPIRestRespStreamConfig) Unset

type NullableApisAPIRestRespStreamInfo

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

func (NullableApisAPIRestRespStreamInfo) Get

func (NullableApisAPIRestRespStreamInfo) IsSet

func (NullableApisAPIRestRespStreamInfo) MarshalJSON

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

func (*NullableApisAPIRestRespStreamInfo) Set

func (*NullableApisAPIRestRespStreamInfo) UnmarshalJSON

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

func (*NullableApisAPIRestRespStreamInfo) Unset

type NullableApisAPIRestRespStreamState

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

func (NullableApisAPIRestRespStreamState) Get

func (NullableApisAPIRestRespStreamState) IsSet

func (NullableApisAPIRestRespStreamState) MarshalJSON

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

func (*NullableApisAPIRestRespStreamState) Set

func (*NullableApisAPIRestRespStreamState) UnmarshalJSON

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

func (*NullableApisAPIRestRespStreamState) 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 NullableDataplaneAckSeqNum

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

func NewNullableDataplaneAckSeqNum

func NewNullableDataplaneAckSeqNum(val *DataplaneAckSeqNum) *NullableDataplaneAckSeqNum

func (NullableDataplaneAckSeqNum) Get

func (NullableDataplaneAckSeqNum) IsSet

func (v NullableDataplaneAckSeqNum) IsSet() bool

func (NullableDataplaneAckSeqNum) MarshalJSON

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

func (*NullableDataplaneAckSeqNum) Set

func (*NullableDataplaneAckSeqNum) UnmarshalJSON

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

func (*NullableDataplaneAckSeqNum) Unset

func (v *NullableDataplaneAckSeqNum) Unset()

type NullableDataplaneMsgToDeliverSeq

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

func (NullableDataplaneMsgToDeliverSeq) Get

func (NullableDataplaneMsgToDeliverSeq) IsSet

func (NullableDataplaneMsgToDeliverSeq) MarshalJSON

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

func (*NullableDataplaneMsgToDeliverSeq) Set

func (*NullableDataplaneMsgToDeliverSeq) UnmarshalJSON

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

func (*NullableDataplaneMsgToDeliverSeq) 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 NullableGoutilsErrorDetail added in v0.4.0

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

func NewNullableGoutilsErrorDetail added in v0.4.0

func NewNullableGoutilsErrorDetail(val *GoutilsErrorDetail) *NullableGoutilsErrorDetail

func (NullableGoutilsErrorDetail) Get added in v0.4.0

func (NullableGoutilsErrorDetail) IsSet added in v0.4.0

func (v NullableGoutilsErrorDetail) IsSet() bool

func (NullableGoutilsErrorDetail) MarshalJSON added in v0.4.0

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

func (*NullableGoutilsErrorDetail) Set added in v0.4.0

func (*NullableGoutilsErrorDetail) UnmarshalJSON added in v0.4.0

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

func (*NullableGoutilsErrorDetail) Unset added in v0.4.0

func (v *NullableGoutilsErrorDetail) Unset()

type NullableGoutilsRestAPIBaseResponse added in v0.4.0

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

func NewNullableGoutilsRestAPIBaseResponse added in v0.4.0

func NewNullableGoutilsRestAPIBaseResponse(val *GoutilsRestAPIBaseResponse) *NullableGoutilsRestAPIBaseResponse

func (NullableGoutilsRestAPIBaseResponse) Get added in v0.4.0

func (NullableGoutilsRestAPIBaseResponse) IsSet added in v0.4.0

func (NullableGoutilsRestAPIBaseResponse) MarshalJSON added in v0.4.0

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

func (*NullableGoutilsRestAPIBaseResponse) Set added in v0.4.0

func (*NullableGoutilsRestAPIBaseResponse) UnmarshalJSON added in v0.4.0

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

func (*NullableGoutilsRestAPIBaseResponse) Unset added in v0.4.0

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 NullableManagementJSStreamLimits

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

func (NullableManagementJSStreamLimits) Get

func (NullableManagementJSStreamLimits) IsSet

func (NullableManagementJSStreamLimits) MarshalJSON

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

func (*NullableManagementJSStreamLimits) Set

func (*NullableManagementJSStreamLimits) UnmarshalJSON

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

func (*NullableManagementJSStreamLimits) Unset

type NullableManagementJSStreamParam

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

func (NullableManagementJSStreamParam) Get

func (NullableManagementJSStreamParam) IsSet

func (NullableManagementJSStreamParam) MarshalJSON

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

func (*NullableManagementJSStreamParam) Set

func (*NullableManagementJSStreamParam) UnmarshalJSON

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

func (*NullableManagementJSStreamParam) Unset

type NullableManagementJetStreamConsumerParam

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

func (NullableManagementJetStreamConsumerParam) Get

func (NullableManagementJetStreamConsumerParam) IsSet

func (NullableManagementJetStreamConsumerParam) MarshalJSON

func (*NullableManagementJetStreamConsumerParam) Set

func (*NullableManagementJetStreamConsumerParam) UnmarshalJSON

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL