Documentation ¶
Index ¶
- Variables
- func CacheExpires(r *http.Response) time.Time
- func PtrBool(v bool) *bool
- func PtrFloat32(v float32) *float32
- func PtrFloat64(v float64) *float64
- func PtrInt(v int) *int
- func PtrInt32(v int32) *int32
- func PtrInt64(v int64) *int64
- func PtrString(v string) *string
- func PtrTime(v time.Time) *time.Time
- type APIClient
- type APIKey
- type APIResponse
- type ApiV1AdminAliveGetRequest
- type ApiV1AdminReadyGetRequest
- type ApiV1AdminStreamGetRequest
- type ApiV1AdminStreamPostRequest
- func (r ApiV1AdminStreamPostRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- func (r ApiV1AdminStreamPostRequest) HttpmqRequestID(httpmqRequestID string) ApiV1AdminStreamPostRequest
- func (r ApiV1AdminStreamPostRequest) Setting(setting ManagementJSStreamParam) ApiV1AdminStreamPostRequest
- type ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest
- func (r ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- func (r ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest) HttpmqRequestID(httpmqRequestID string) ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest
- type ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest
- func (r ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest) Execute() (ApisAPIRestRespOneJetStreamConsumer, *_nethttp.Response, error)
- func (r ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest) HttpmqRequestID(httpmqRequestID string) ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest
- type ApiV1AdminStreamStreamNameConsumerGetRequest
- type ApiV1AdminStreamStreamNameConsumerPostRequest
- func (r ApiV1AdminStreamStreamNameConsumerPostRequest) ConsumerParam(consumerParam ManagementJetStreamConsumerParam) ApiV1AdminStreamStreamNameConsumerPostRequest
- func (r ApiV1AdminStreamStreamNameConsumerPostRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- func (r ApiV1AdminStreamStreamNameConsumerPostRequest) HttpmqRequestID(httpmqRequestID string) ApiV1AdminStreamStreamNameConsumerPostRequest
- type ApiV1AdminStreamStreamNameDeleteRequest
- type ApiV1AdminStreamStreamNameGetRequest
- type ApiV1AdminStreamStreamNameLimitPutRequest
- func (r ApiV1AdminStreamStreamNameLimitPutRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- func (r ApiV1AdminStreamStreamNameLimitPutRequest) HttpmqRequestID(httpmqRequestID string) ApiV1AdminStreamStreamNameLimitPutRequest
- func (r ApiV1AdminStreamStreamNameLimitPutRequest) Limits(limits ManagementJSStreamLimits) ApiV1AdminStreamStreamNameLimitPutRequest
- type ApiV1AdminStreamStreamNameSubjectPutRequest
- func (r ApiV1AdminStreamStreamNameSubjectPutRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- func (r ApiV1AdminStreamStreamNameSubjectPutRequest) HttpmqRequestID(httpmqRequestID string) ApiV1AdminStreamStreamNameSubjectPutRequest
- func (r ApiV1AdminStreamStreamNameSubjectPutRequest) Subjects(subjects ApisAPIRestReqStreamSubjects) ApiV1AdminStreamStreamNameSubjectPutRequest
- type ApiV1DataAliveGetRequest
- type ApiV1DataReadyGetRequest
- type ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest
- func (r ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- func (r ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest) HttpmqRequestID(httpmqRequestID string) ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest
- func (r ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest) SequenceNum(sequenceNum DataplaneAckSeqNum) ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest
- type ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest
- func (r ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) DeliveryGroup(deliveryGroup string) ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest
- func (r ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) Execute() (ApisAPIRestRespDataMessage, *_nethttp.Response, error)
- func (r ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) HttpmqRequestID(httpmqRequestID string) ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest
- func (r ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) MaxMsgInflight(maxMsgInflight int32) ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest
- func (r ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) SubjectName(subjectName string) ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest
- type ApiV1DataSubjectSubjectNamePostRequest
- func (r ApiV1DataSubjectSubjectNamePostRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- func (r ApiV1DataSubjectSubjectNamePostRequest) HttpmqRequestID(httpmqRequestID string) ApiV1DataSubjectSubjectNamePostRequest
- func (r ApiV1DataSubjectSubjectNamePostRequest) Message(message string) ApiV1DataSubjectSubjectNamePostRequest
- type ApisAPIRestReqStreamSubjects
- type ApisAPIRestRespAllJetStreamConsumers
- func (o *ApisAPIRestRespAllJetStreamConsumers) GetConsumers() map[string]ApisAPIRestRespConsumerInfo
- func (o *ApisAPIRestRespAllJetStreamConsumers) GetConsumersOk() (*map[string]ApisAPIRestRespConsumerInfo, bool)
- func (o *ApisAPIRestRespAllJetStreamConsumers) GetError() GoutilsErrorDetail
- func (o *ApisAPIRestRespAllJetStreamConsumers) GetErrorOk() (*GoutilsErrorDetail, bool)
- func (o *ApisAPIRestRespAllJetStreamConsumers) GetRequestId() string
- func (o *ApisAPIRestRespAllJetStreamConsumers) GetRequestIdOk() (*string, bool)
- func (o *ApisAPIRestRespAllJetStreamConsumers) GetSuccess() bool
- func (o *ApisAPIRestRespAllJetStreamConsumers) GetSuccessOk() (*bool, bool)
- func (o *ApisAPIRestRespAllJetStreamConsumers) HasConsumers() bool
- func (o *ApisAPIRestRespAllJetStreamConsumers) HasError() bool
- func (o ApisAPIRestRespAllJetStreamConsumers) MarshalJSON() ([]byte, error)
- func (o *ApisAPIRestRespAllJetStreamConsumers) SetConsumers(v map[string]ApisAPIRestRespConsumerInfo)
- func (o *ApisAPIRestRespAllJetStreamConsumers) SetError(v GoutilsErrorDetail)
- func (o *ApisAPIRestRespAllJetStreamConsumers) SetRequestId(v string)
- func (o *ApisAPIRestRespAllJetStreamConsumers) SetSuccess(v bool)
- type ApisAPIRestRespAllJetStreams
- func (o *ApisAPIRestRespAllJetStreams) GetError() GoutilsErrorDetail
- func (o *ApisAPIRestRespAllJetStreams) GetErrorOk() (*GoutilsErrorDetail, bool)
- func (o *ApisAPIRestRespAllJetStreams) GetRequestId() string
- func (o *ApisAPIRestRespAllJetStreams) GetRequestIdOk() (*string, bool)
- func (o *ApisAPIRestRespAllJetStreams) GetStreams() map[string]ApisAPIRestRespStreamInfo
- func (o *ApisAPIRestRespAllJetStreams) GetStreamsOk() (*map[string]ApisAPIRestRespStreamInfo, bool)
- func (o *ApisAPIRestRespAllJetStreams) GetSuccess() bool
- func (o *ApisAPIRestRespAllJetStreams) GetSuccessOk() (*bool, bool)
- func (o *ApisAPIRestRespAllJetStreams) HasError() bool
- func (o *ApisAPIRestRespAllJetStreams) HasStreams() bool
- func (o ApisAPIRestRespAllJetStreams) MarshalJSON() ([]byte, error)
- func (o *ApisAPIRestRespAllJetStreams) SetError(v GoutilsErrorDetail)
- func (o *ApisAPIRestRespAllJetStreams) SetRequestId(v string)
- func (o *ApisAPIRestRespAllJetStreams) SetStreams(v map[string]ApisAPIRestRespStreamInfo)
- func (o *ApisAPIRestRespAllJetStreams) SetSuccess(v bool)
- type ApisAPIRestRespConsumerConfig
- func (o *ApisAPIRestRespConsumerConfig) GetAckWait() int64
- func (o *ApisAPIRestRespConsumerConfig) GetAckWaitOk() (*int64, bool)
- func (o *ApisAPIRestRespConsumerConfig) GetDeliverGroup() string
- func (o *ApisAPIRestRespConsumerConfig) GetDeliverGroupOk() (*string, bool)
- func (o *ApisAPIRestRespConsumerConfig) GetDeliverSubject() string
- func (o *ApisAPIRestRespConsumerConfig) GetDeliverSubjectOk() (*string, bool)
- func (o *ApisAPIRestRespConsumerConfig) GetFilterSubject() string
- func (o *ApisAPIRestRespConsumerConfig) GetFilterSubjectOk() (*string, bool)
- func (o *ApisAPIRestRespConsumerConfig) GetMaxAckPending() int64
- func (o *ApisAPIRestRespConsumerConfig) GetMaxAckPendingOk() (*int64, bool)
- func (o *ApisAPIRestRespConsumerConfig) GetMaxDeliver() int64
- func (o *ApisAPIRestRespConsumerConfig) GetMaxDeliverOk() (*int64, bool)
- func (o *ApisAPIRestRespConsumerConfig) GetMaxWaiting() int64
- func (o *ApisAPIRestRespConsumerConfig) GetMaxWaitingOk() (*int64, bool)
- func (o *ApisAPIRestRespConsumerConfig) GetNotes() string
- func (o *ApisAPIRestRespConsumerConfig) GetNotesOk() (*string, bool)
- func (o *ApisAPIRestRespConsumerConfig) HasDeliverGroup() bool
- func (o *ApisAPIRestRespConsumerConfig) HasDeliverSubject() bool
- func (o *ApisAPIRestRespConsumerConfig) HasFilterSubject() bool
- func (o *ApisAPIRestRespConsumerConfig) HasMaxAckPending() bool
- func (o *ApisAPIRestRespConsumerConfig) HasMaxDeliver() bool
- func (o *ApisAPIRestRespConsumerConfig) HasMaxWaiting() bool
- func (o *ApisAPIRestRespConsumerConfig) HasNotes() bool
- func (o ApisAPIRestRespConsumerConfig) MarshalJSON() ([]byte, error)
- func (o *ApisAPIRestRespConsumerConfig) SetAckWait(v int64)
- func (o *ApisAPIRestRespConsumerConfig) SetDeliverGroup(v string)
- func (o *ApisAPIRestRespConsumerConfig) SetDeliverSubject(v string)
- func (o *ApisAPIRestRespConsumerConfig) SetFilterSubject(v string)
- func (o *ApisAPIRestRespConsumerConfig) SetMaxAckPending(v int64)
- func (o *ApisAPIRestRespConsumerConfig) SetMaxDeliver(v int64)
- func (o *ApisAPIRestRespConsumerConfig) SetMaxWaiting(v int64)
- func (o *ApisAPIRestRespConsumerConfig) SetNotes(v string)
- type ApisAPIRestRespConsumerInfo
- func (o *ApisAPIRestRespConsumerInfo) GetAckFloor() ApisAPIRestRespSequenceInfo
- func (o *ApisAPIRestRespConsumerInfo) GetAckFloorOk() (*ApisAPIRestRespSequenceInfo, bool)
- func (o *ApisAPIRestRespConsumerInfo) GetConfig() ApisAPIRestRespConsumerConfig
- func (o *ApisAPIRestRespConsumerInfo) GetConfigOk() (*ApisAPIRestRespConsumerConfig, bool)
- func (o *ApisAPIRestRespConsumerInfo) GetCreated() string
- func (o *ApisAPIRestRespConsumerInfo) GetCreatedOk() (*string, bool)
- func (o *ApisAPIRestRespConsumerInfo) GetDelivered() ApisAPIRestRespSequenceInfo
- func (o *ApisAPIRestRespConsumerInfo) GetDeliveredOk() (*ApisAPIRestRespSequenceInfo, bool)
- func (o *ApisAPIRestRespConsumerInfo) GetName() string
- func (o *ApisAPIRestRespConsumerInfo) GetNameOk() (*string, bool)
- func (o *ApisAPIRestRespConsumerInfo) GetNumAckPending() int32
- func (o *ApisAPIRestRespConsumerInfo) GetNumAckPendingOk() (*int32, bool)
- func (o *ApisAPIRestRespConsumerInfo) GetNumPending() int32
- func (o *ApisAPIRestRespConsumerInfo) GetNumPendingOk() (*int32, bool)
- func (o *ApisAPIRestRespConsumerInfo) GetNumRedelivered() int32
- func (o *ApisAPIRestRespConsumerInfo) GetNumRedeliveredOk() (*int32, bool)
- func (o *ApisAPIRestRespConsumerInfo) GetNumWaiting() int32
- func (o *ApisAPIRestRespConsumerInfo) GetNumWaitingOk() (*int32, bool)
- func (o *ApisAPIRestRespConsumerInfo) GetStreamName() string
- func (o *ApisAPIRestRespConsumerInfo) GetStreamNameOk() (*string, bool)
- func (o ApisAPIRestRespConsumerInfo) MarshalJSON() ([]byte, error)
- func (o *ApisAPIRestRespConsumerInfo) SetAckFloor(v ApisAPIRestRespSequenceInfo)
- func (o *ApisAPIRestRespConsumerInfo) SetConfig(v ApisAPIRestRespConsumerConfig)
- func (o *ApisAPIRestRespConsumerInfo) SetCreated(v string)
- func (o *ApisAPIRestRespConsumerInfo) SetDelivered(v ApisAPIRestRespSequenceInfo)
- func (o *ApisAPIRestRespConsumerInfo) SetName(v string)
- func (o *ApisAPIRestRespConsumerInfo) SetNumAckPending(v int32)
- func (o *ApisAPIRestRespConsumerInfo) SetNumPending(v int32)
- func (o *ApisAPIRestRespConsumerInfo) SetNumRedelivered(v int32)
- func (o *ApisAPIRestRespConsumerInfo) SetNumWaiting(v int32)
- func (o *ApisAPIRestRespConsumerInfo) SetStreamName(v string)
- type ApisAPIRestRespDataMessage
- func (o *ApisAPIRestRespDataMessage) GetB64Msg() []byte
- func (o *ApisAPIRestRespDataMessage) GetB64MsgOk() (*[]byte, bool)
- func (o *ApisAPIRestRespDataMessage) GetConsumer() string
- func (o *ApisAPIRestRespDataMessage) GetConsumerOk() (*string, bool)
- func (o *ApisAPIRestRespDataMessage) GetError() GoutilsErrorDetail
- func (o *ApisAPIRestRespDataMessage) GetErrorOk() (*GoutilsErrorDetail, bool)
- func (o *ApisAPIRestRespDataMessage) GetRequestId() string
- func (o *ApisAPIRestRespDataMessage) GetRequestIdOk() (*string, bool)
- func (o *ApisAPIRestRespDataMessage) GetSequence() DataplaneMsgToDeliverSeq
- func (o *ApisAPIRestRespDataMessage) GetSequenceOk() (*DataplaneMsgToDeliverSeq, bool)
- func (o *ApisAPIRestRespDataMessage) GetStream() string
- func (o *ApisAPIRestRespDataMessage) GetStreamOk() (*string, bool)
- func (o *ApisAPIRestRespDataMessage) GetSubject() string
- func (o *ApisAPIRestRespDataMessage) GetSubjectOk() (*string, bool)
- func (o *ApisAPIRestRespDataMessage) GetSuccess() bool
- func (o *ApisAPIRestRespDataMessage) GetSuccessOk() (*bool, bool)
- func (o *ApisAPIRestRespDataMessage) HasError() bool
- func (o ApisAPIRestRespDataMessage) MarshalJSON() ([]byte, error)
- func (o *ApisAPIRestRespDataMessage) SetB64Msg(v []byte)
- func (o *ApisAPIRestRespDataMessage) SetConsumer(v string)
- func (o *ApisAPIRestRespDataMessage) SetError(v GoutilsErrorDetail)
- func (o *ApisAPIRestRespDataMessage) SetRequestId(v string)
- func (o *ApisAPIRestRespDataMessage) SetSequence(v DataplaneMsgToDeliverSeq)
- func (o *ApisAPIRestRespDataMessage) SetStream(v string)
- func (o *ApisAPIRestRespDataMessage) SetSubject(v string)
- func (o *ApisAPIRestRespDataMessage) SetSuccess(v bool)
- type ApisAPIRestRespOneJetStream
- func (o *ApisAPIRestRespOneJetStream) GetError() GoutilsErrorDetail
- func (o *ApisAPIRestRespOneJetStream) GetErrorOk() (*GoutilsErrorDetail, bool)
- func (o *ApisAPIRestRespOneJetStream) GetRequestId() string
- func (o *ApisAPIRestRespOneJetStream) GetRequestIdOk() (*string, bool)
- func (o *ApisAPIRestRespOneJetStream) GetStream() ApisAPIRestRespStreamInfo
- func (o *ApisAPIRestRespOneJetStream) GetStreamOk() (*ApisAPIRestRespStreamInfo, bool)
- func (o *ApisAPIRestRespOneJetStream) GetSuccess() bool
- func (o *ApisAPIRestRespOneJetStream) GetSuccessOk() (*bool, bool)
- func (o *ApisAPIRestRespOneJetStream) HasError() bool
- func (o *ApisAPIRestRespOneJetStream) HasStream() bool
- func (o ApisAPIRestRespOneJetStream) MarshalJSON() ([]byte, error)
- func (o *ApisAPIRestRespOneJetStream) SetError(v GoutilsErrorDetail)
- func (o *ApisAPIRestRespOneJetStream) SetRequestId(v string)
- func (o *ApisAPIRestRespOneJetStream) SetStream(v ApisAPIRestRespStreamInfo)
- func (o *ApisAPIRestRespOneJetStream) SetSuccess(v bool)
- type ApisAPIRestRespOneJetStreamConsumer
- func (o *ApisAPIRestRespOneJetStreamConsumer) GetConsumer() ApisAPIRestRespConsumerInfo
- func (o *ApisAPIRestRespOneJetStreamConsumer) GetConsumerOk() (*ApisAPIRestRespConsumerInfo, bool)
- func (o *ApisAPIRestRespOneJetStreamConsumer) GetError() GoutilsErrorDetail
- func (o *ApisAPIRestRespOneJetStreamConsumer) GetErrorOk() (*GoutilsErrorDetail, bool)
- func (o *ApisAPIRestRespOneJetStreamConsumer) GetRequestId() string
- func (o *ApisAPIRestRespOneJetStreamConsumer) GetRequestIdOk() (*string, bool)
- func (o *ApisAPIRestRespOneJetStreamConsumer) GetSuccess() bool
- func (o *ApisAPIRestRespOneJetStreamConsumer) GetSuccessOk() (*bool, bool)
- func (o *ApisAPIRestRespOneJetStreamConsumer) HasConsumer() bool
- func (o *ApisAPIRestRespOneJetStreamConsumer) HasError() bool
- func (o ApisAPIRestRespOneJetStreamConsumer) MarshalJSON() ([]byte, error)
- func (o *ApisAPIRestRespOneJetStreamConsumer) SetConsumer(v ApisAPIRestRespConsumerInfo)
- func (o *ApisAPIRestRespOneJetStreamConsumer) SetError(v GoutilsErrorDetail)
- func (o *ApisAPIRestRespOneJetStreamConsumer) SetRequestId(v string)
- func (o *ApisAPIRestRespOneJetStreamConsumer) SetSuccess(v bool)
- type ApisAPIRestRespSequenceInfo
- func (o *ApisAPIRestRespSequenceInfo) GetConsumerSeq() int32
- func (o *ApisAPIRestRespSequenceInfo) GetConsumerSeqOk() (*int32, bool)
- func (o *ApisAPIRestRespSequenceInfo) GetLastActive() string
- func (o *ApisAPIRestRespSequenceInfo) GetLastActiveOk() (*string, bool)
- func (o *ApisAPIRestRespSequenceInfo) GetStreamSeq() int32
- func (o *ApisAPIRestRespSequenceInfo) GetStreamSeqOk() (*int32, bool)
- func (o *ApisAPIRestRespSequenceInfo) HasLastActive() bool
- func (o ApisAPIRestRespSequenceInfo) MarshalJSON() ([]byte, error)
- func (o *ApisAPIRestRespSequenceInfo) SetConsumerSeq(v int32)
- func (o *ApisAPIRestRespSequenceInfo) SetLastActive(v string)
- func (o *ApisAPIRestRespSequenceInfo) SetStreamSeq(v int32)
- type ApisAPIRestRespStreamConfig
- func (o *ApisAPIRestRespStreamConfig) GetDescription() string
- func (o *ApisAPIRestRespStreamConfig) GetDescriptionOk() (*string, bool)
- func (o *ApisAPIRestRespStreamConfig) GetMaxAge() int64
- func (o *ApisAPIRestRespStreamConfig) GetMaxAgeOk() (*int64, bool)
- func (o *ApisAPIRestRespStreamConfig) GetMaxBytes() int64
- func (o *ApisAPIRestRespStreamConfig) GetMaxBytesOk() (*int64, bool)
- func (o *ApisAPIRestRespStreamConfig) GetMaxConsumers() int64
- func (o *ApisAPIRestRespStreamConfig) GetMaxConsumersOk() (*int64, bool)
- func (o *ApisAPIRestRespStreamConfig) GetMaxMsgSize() int64
- func (o *ApisAPIRestRespStreamConfig) GetMaxMsgSizeOk() (*int64, bool)
- func (o *ApisAPIRestRespStreamConfig) GetMaxMsgs() int64
- func (o *ApisAPIRestRespStreamConfig) GetMaxMsgsOk() (*int64, bool)
- func (o *ApisAPIRestRespStreamConfig) GetMaxMsgsPerSubject() int64
- func (o *ApisAPIRestRespStreamConfig) GetMaxMsgsPerSubjectOk() (*int64, bool)
- func (o *ApisAPIRestRespStreamConfig) GetName() string
- func (o *ApisAPIRestRespStreamConfig) GetNameOk() (*string, bool)
- func (o *ApisAPIRestRespStreamConfig) GetSubjects() []string
- func (o *ApisAPIRestRespStreamConfig) GetSubjectsOk() (*[]string, bool)
- func (o *ApisAPIRestRespStreamConfig) HasDescription() bool
- func (o *ApisAPIRestRespStreamConfig) HasMaxMsgSize() bool
- func (o *ApisAPIRestRespStreamConfig) HasSubjects() bool
- func (o ApisAPIRestRespStreamConfig) MarshalJSON() ([]byte, error)
- func (o *ApisAPIRestRespStreamConfig) SetDescription(v string)
- func (o *ApisAPIRestRespStreamConfig) SetMaxAge(v int64)
- func (o *ApisAPIRestRespStreamConfig) SetMaxBytes(v int64)
- func (o *ApisAPIRestRespStreamConfig) SetMaxConsumers(v int64)
- func (o *ApisAPIRestRespStreamConfig) SetMaxMsgSize(v int64)
- func (o *ApisAPIRestRespStreamConfig) SetMaxMsgs(v int64)
- func (o *ApisAPIRestRespStreamConfig) SetMaxMsgsPerSubject(v int64)
- func (o *ApisAPIRestRespStreamConfig) SetName(v string)
- func (o *ApisAPIRestRespStreamConfig) SetSubjects(v []string)
- type ApisAPIRestRespStreamInfo
- func (o *ApisAPIRestRespStreamInfo) GetConfig() ApisAPIRestRespStreamConfig
- func (o *ApisAPIRestRespStreamInfo) GetConfigOk() (*ApisAPIRestRespStreamConfig, bool)
- func (o *ApisAPIRestRespStreamInfo) GetCreated() string
- func (o *ApisAPIRestRespStreamInfo) GetCreatedOk() (*string, bool)
- func (o *ApisAPIRestRespStreamInfo) GetState() ApisAPIRestRespStreamState
- func (o *ApisAPIRestRespStreamInfo) GetStateOk() (*ApisAPIRestRespStreamState, bool)
- func (o ApisAPIRestRespStreamInfo) MarshalJSON() ([]byte, error)
- func (o *ApisAPIRestRespStreamInfo) SetConfig(v ApisAPIRestRespStreamConfig)
- func (o *ApisAPIRestRespStreamInfo) SetCreated(v string)
- func (o *ApisAPIRestRespStreamInfo) SetState(v ApisAPIRestRespStreamState)
- type ApisAPIRestRespStreamState
- func (o *ApisAPIRestRespStreamState) GetBytes() int32
- func (o *ApisAPIRestRespStreamState) GetBytesOk() (*int32, bool)
- func (o *ApisAPIRestRespStreamState) GetConsumerCount() int32
- func (o *ApisAPIRestRespStreamState) GetConsumerCountOk() (*int32, bool)
- func (o *ApisAPIRestRespStreamState) GetFirstSeq() int32
- func (o *ApisAPIRestRespStreamState) GetFirstSeqOk() (*int32, bool)
- func (o *ApisAPIRestRespStreamState) GetFirstTs() string
- func (o *ApisAPIRestRespStreamState) GetFirstTsOk() (*string, bool)
- func (o *ApisAPIRestRespStreamState) GetLastSeq() int32
- func (o *ApisAPIRestRespStreamState) GetLastSeqOk() (*int32, bool)
- func (o *ApisAPIRestRespStreamState) GetLastTs() string
- func (o *ApisAPIRestRespStreamState) GetLastTsOk() (*string, bool)
- func (o *ApisAPIRestRespStreamState) GetMessages() int32
- func (o *ApisAPIRestRespStreamState) GetMessagesOk() (*int32, bool)
- func (o ApisAPIRestRespStreamState) MarshalJSON() ([]byte, error)
- func (o *ApisAPIRestRespStreamState) SetBytes(v int32)
- func (o *ApisAPIRestRespStreamState) SetConsumerCount(v int32)
- func (o *ApisAPIRestRespStreamState) SetFirstSeq(v int32)
- func (o *ApisAPIRestRespStreamState) SetFirstTs(v string)
- func (o *ApisAPIRestRespStreamState) SetLastSeq(v int32)
- func (o *ApisAPIRestRespStreamState) SetLastTs(v string)
- func (o *ApisAPIRestRespStreamState) SetMessages(v int32)
- type BasicAuth
- type Configuration
- type DataplaneAckSeqNum
- func (o *DataplaneAckSeqNum) GetConsumer() int64
- func (o *DataplaneAckSeqNum) GetConsumerOk() (*int64, bool)
- func (o *DataplaneAckSeqNum) GetStream() int64
- func (o *DataplaneAckSeqNum) GetStreamOk() (*int64, bool)
- func (o DataplaneAckSeqNum) MarshalJSON() ([]byte, error)
- func (o *DataplaneAckSeqNum) SetConsumer(v int64)
- func (o *DataplaneAckSeqNum) SetStream(v int64)
- type DataplaneApiService
- func (a *DataplaneApiService) V1DataAliveGet(ctx _context.Context) ApiV1DataAliveGetRequest
- func (a *DataplaneApiService) V1DataAliveGetExecute(r ApiV1DataAliveGetRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- func (a *DataplaneApiService) V1DataReadyGet(ctx _context.Context) ApiV1DataReadyGetRequest
- func (a *DataplaneApiService) V1DataReadyGetExecute(r ApiV1DataReadyGetRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- func (a *DataplaneApiService) V1DataStreamStreamNameConsumerConsumerNameAckPost(ctx _context.Context, streamName string, consumerName string) ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest
- func (a *DataplaneApiService) V1DataStreamStreamNameConsumerConsumerNameAckPostExecute(r ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- func (a *DataplaneApiService) V1DataStreamStreamNameConsumerConsumerNameGet(ctx _context.Context, streamName string, consumerName string) ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest
- func (a *DataplaneApiService) V1DataStreamStreamNameConsumerConsumerNameGetExecute(r ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) (ApisAPIRestRespDataMessage, *_nethttp.Response, error)
- func (a *DataplaneApiService) V1DataSubjectSubjectNamePost(ctx _context.Context, subjectName string) ApiV1DataSubjectSubjectNamePostRequest
- func (a *DataplaneApiService) V1DataSubjectSubjectNamePostExecute(r ApiV1DataSubjectSubjectNamePostRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- type DataplaneMsgToDeliverSeq
- func (o *DataplaneMsgToDeliverSeq) GetConsumer() int64
- func (o *DataplaneMsgToDeliverSeq) GetConsumerOk() (*int64, bool)
- func (o *DataplaneMsgToDeliverSeq) GetStream() int64
- func (o *DataplaneMsgToDeliverSeq) GetStreamOk() (*int64, bool)
- func (o DataplaneMsgToDeliverSeq) MarshalJSON() ([]byte, error)
- func (o *DataplaneMsgToDeliverSeq) SetConsumer(v int64)
- func (o *DataplaneMsgToDeliverSeq) SetStream(v int64)
- type GenericOpenAPIError
- type GoutilsErrorDetail
- func (o *GoutilsErrorDetail) GetCode() int32
- func (o *GoutilsErrorDetail) GetCodeOk() (*int32, bool)
- func (o *GoutilsErrorDetail) GetDetail() string
- func (o *GoutilsErrorDetail) GetDetailOk() (*string, bool)
- func (o *GoutilsErrorDetail) GetMessage() string
- func (o *GoutilsErrorDetail) GetMessageOk() (*string, bool)
- func (o *GoutilsErrorDetail) HasDetail() bool
- func (o *GoutilsErrorDetail) HasMessage() bool
- func (o GoutilsErrorDetail) MarshalJSON() ([]byte, error)
- func (o *GoutilsErrorDetail) SetCode(v int32)
- func (o *GoutilsErrorDetail) SetDetail(v string)
- func (o *GoutilsErrorDetail) SetMessage(v string)
- type GoutilsRestAPIBaseResponse
- func (o *GoutilsRestAPIBaseResponse) GetError() GoutilsErrorDetail
- func (o *GoutilsRestAPIBaseResponse) GetErrorOk() (*GoutilsErrorDetail, bool)
- func (o *GoutilsRestAPIBaseResponse) GetRequestId() string
- func (o *GoutilsRestAPIBaseResponse) GetRequestIdOk() (*string, bool)
- func (o *GoutilsRestAPIBaseResponse) GetSuccess() bool
- func (o *GoutilsRestAPIBaseResponse) GetSuccessOk() (*bool, bool)
- func (o *GoutilsRestAPIBaseResponse) HasError() bool
- func (o GoutilsRestAPIBaseResponse) MarshalJSON() ([]byte, error)
- func (o *GoutilsRestAPIBaseResponse) SetError(v GoutilsErrorDetail)
- func (o *GoutilsRestAPIBaseResponse) SetRequestId(v string)
- func (o *GoutilsRestAPIBaseResponse) SetSuccess(v bool)
- type ManagementApiService
- func (a *ManagementApiService) V1AdminAliveGet(ctx _context.Context) ApiV1AdminAliveGetRequest
- func (a *ManagementApiService) V1AdminAliveGetExecute(r ApiV1AdminAliveGetRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- func (a *ManagementApiService) V1AdminReadyGet(ctx _context.Context) ApiV1AdminReadyGetRequest
- func (a *ManagementApiService) V1AdminReadyGetExecute(r ApiV1AdminReadyGetRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- func (a *ManagementApiService) V1AdminStreamGet(ctx _context.Context) ApiV1AdminStreamGetRequest
- func (a *ManagementApiService) V1AdminStreamGetExecute(r ApiV1AdminStreamGetRequest) (ApisAPIRestRespAllJetStreams, *_nethttp.Response, error)
- func (a *ManagementApiService) V1AdminStreamPost(ctx _context.Context) ApiV1AdminStreamPostRequest
- func (a *ManagementApiService) V1AdminStreamPostExecute(r ApiV1AdminStreamPostRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- func (a *ManagementApiService) V1AdminStreamStreamNameConsumerConsumerNameDelete(ctx _context.Context, streamName string, consumerName string) ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest
- func (a *ManagementApiService) V1AdminStreamStreamNameConsumerConsumerNameDeleteExecute(r ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- func (a *ManagementApiService) V1AdminStreamStreamNameConsumerConsumerNameGet(ctx _context.Context, streamName string, consumerName string) ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest
- func (a *ManagementApiService) V1AdminStreamStreamNameConsumerConsumerNameGetExecute(r ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest) (ApisAPIRestRespOneJetStreamConsumer, *_nethttp.Response, error)
- func (a *ManagementApiService) V1AdminStreamStreamNameConsumerGet(ctx _context.Context, streamName string) ApiV1AdminStreamStreamNameConsumerGetRequest
- func (a *ManagementApiService) V1AdminStreamStreamNameConsumerGetExecute(r ApiV1AdminStreamStreamNameConsumerGetRequest) (ApisAPIRestRespAllJetStreamConsumers, *_nethttp.Response, error)
- func (a *ManagementApiService) V1AdminStreamStreamNameConsumerPost(ctx _context.Context, streamName string) ApiV1AdminStreamStreamNameConsumerPostRequest
- func (a *ManagementApiService) V1AdminStreamStreamNameConsumerPostExecute(r ApiV1AdminStreamStreamNameConsumerPostRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- func (a *ManagementApiService) V1AdminStreamStreamNameDelete(ctx _context.Context, streamName string) ApiV1AdminStreamStreamNameDeleteRequest
- func (a *ManagementApiService) V1AdminStreamStreamNameDeleteExecute(r ApiV1AdminStreamStreamNameDeleteRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- func (a *ManagementApiService) V1AdminStreamStreamNameGet(ctx _context.Context, streamName string) ApiV1AdminStreamStreamNameGetRequest
- func (a *ManagementApiService) V1AdminStreamStreamNameGetExecute(r ApiV1AdminStreamStreamNameGetRequest) (ApisAPIRestRespOneJetStream, *_nethttp.Response, error)
- func (a *ManagementApiService) V1AdminStreamStreamNameLimitPut(ctx _context.Context, streamName string) ApiV1AdminStreamStreamNameLimitPutRequest
- func (a *ManagementApiService) V1AdminStreamStreamNameLimitPutExecute(r ApiV1AdminStreamStreamNameLimitPutRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- func (a *ManagementApiService) V1AdminStreamStreamNameSubjectPut(ctx _context.Context, streamName string) ApiV1AdminStreamStreamNameSubjectPutRequest
- func (a *ManagementApiService) V1AdminStreamStreamNameSubjectPutExecute(r ApiV1AdminStreamStreamNameSubjectPutRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
- type ManagementJSStreamLimits
- func (o *ManagementJSStreamLimits) GetMaxAge() int64
- func (o *ManagementJSStreamLimits) GetMaxAgeOk() (*int64, bool)
- func (o *ManagementJSStreamLimits) GetMaxBytes() int64
- func (o *ManagementJSStreamLimits) GetMaxBytesOk() (*int64, bool)
- func (o *ManagementJSStreamLimits) GetMaxConsumers() int64
- func (o *ManagementJSStreamLimits) GetMaxConsumersOk() (*int64, bool)
- func (o *ManagementJSStreamLimits) GetMaxMsgSize() int64
- func (o *ManagementJSStreamLimits) GetMaxMsgSizeOk() (*int64, bool)
- func (o *ManagementJSStreamLimits) GetMaxMsgs() int64
- func (o *ManagementJSStreamLimits) GetMaxMsgsOk() (*int64, bool)
- func (o *ManagementJSStreamLimits) GetMaxMsgsPerSubject() int64
- func (o *ManagementJSStreamLimits) GetMaxMsgsPerSubjectOk() (*int64, bool)
- func (o *ManagementJSStreamLimits) HasMaxAge() bool
- func (o *ManagementJSStreamLimits) HasMaxBytes() bool
- func (o *ManagementJSStreamLimits) HasMaxConsumers() bool
- func (o *ManagementJSStreamLimits) HasMaxMsgSize() bool
- func (o *ManagementJSStreamLimits) HasMaxMsgs() bool
- func (o *ManagementJSStreamLimits) HasMaxMsgsPerSubject() bool
- func (o ManagementJSStreamLimits) MarshalJSON() ([]byte, error)
- func (o *ManagementJSStreamLimits) SetMaxAge(v int64)
- func (o *ManagementJSStreamLimits) SetMaxBytes(v int64)
- func (o *ManagementJSStreamLimits) SetMaxConsumers(v int64)
- func (o *ManagementJSStreamLimits) SetMaxMsgSize(v int64)
- func (o *ManagementJSStreamLimits) SetMaxMsgs(v int64)
- func (o *ManagementJSStreamLimits) SetMaxMsgsPerSubject(v int64)
- type ManagementJSStreamParam
- func (o *ManagementJSStreamParam) GetMaxAge() int64
- func (o *ManagementJSStreamParam) GetMaxAgeOk() (*int64, bool)
- func (o *ManagementJSStreamParam) GetMaxBytes() int64
- func (o *ManagementJSStreamParam) GetMaxBytesOk() (*int64, bool)
- func (o *ManagementJSStreamParam) GetMaxConsumers() int64
- func (o *ManagementJSStreamParam) GetMaxConsumersOk() (*int64, bool)
- func (o *ManagementJSStreamParam) GetMaxMsgSize() int64
- func (o *ManagementJSStreamParam) GetMaxMsgSizeOk() (*int64, bool)
- func (o *ManagementJSStreamParam) GetMaxMsgs() int64
- func (o *ManagementJSStreamParam) GetMaxMsgsOk() (*int64, bool)
- func (o *ManagementJSStreamParam) GetMaxMsgsPerSubject() int64
- func (o *ManagementJSStreamParam) GetMaxMsgsPerSubjectOk() (*int64, bool)
- func (o *ManagementJSStreamParam) GetName() string
- func (o *ManagementJSStreamParam) GetNameOk() (*string, bool)
- func (o *ManagementJSStreamParam) GetSubjects() []string
- func (o *ManagementJSStreamParam) GetSubjectsOk() (*[]string, bool)
- func (o *ManagementJSStreamParam) HasMaxAge() bool
- func (o *ManagementJSStreamParam) HasMaxBytes() bool
- func (o *ManagementJSStreamParam) HasMaxConsumers() bool
- func (o *ManagementJSStreamParam) HasMaxMsgSize() bool
- func (o *ManagementJSStreamParam) HasMaxMsgs() bool
- func (o *ManagementJSStreamParam) HasMaxMsgsPerSubject() bool
- func (o *ManagementJSStreamParam) HasSubjects() bool
- func (o ManagementJSStreamParam) MarshalJSON() ([]byte, error)
- func (o *ManagementJSStreamParam) SetMaxAge(v int64)
- func (o *ManagementJSStreamParam) SetMaxBytes(v int64)
- func (o *ManagementJSStreamParam) SetMaxConsumers(v int64)
- func (o *ManagementJSStreamParam) SetMaxMsgSize(v int64)
- func (o *ManagementJSStreamParam) SetMaxMsgs(v int64)
- func (o *ManagementJSStreamParam) SetMaxMsgsPerSubject(v int64)
- func (o *ManagementJSStreamParam) SetName(v string)
- func (o *ManagementJSStreamParam) SetSubjects(v []string)
- type ManagementJetStreamConsumerParam
- func (o *ManagementJetStreamConsumerParam) GetAckWait() int64
- func (o *ManagementJetStreamConsumerParam) GetAckWaitOk() (*int64, bool)
- func (o *ManagementJetStreamConsumerParam) GetDeliveryGroup() string
- func (o *ManagementJetStreamConsumerParam) GetDeliveryGroupOk() (*string, bool)
- func (o *ManagementJetStreamConsumerParam) GetFilterSubject() string
- func (o *ManagementJetStreamConsumerParam) GetFilterSubjectOk() (*string, bool)
- func (o *ManagementJetStreamConsumerParam) GetMaxInflight() int64
- func (o *ManagementJetStreamConsumerParam) GetMaxInflightOk() (*int64, bool)
- func (o *ManagementJetStreamConsumerParam) GetMaxRetry() int64
- func (o *ManagementJetStreamConsumerParam) GetMaxRetryOk() (*int64, bool)
- func (o *ManagementJetStreamConsumerParam) GetMode() string
- func (o *ManagementJetStreamConsumerParam) GetModeOk() (*string, bool)
- func (o *ManagementJetStreamConsumerParam) GetName() string
- func (o *ManagementJetStreamConsumerParam) GetNameOk() (*string, bool)
- func (o *ManagementJetStreamConsumerParam) GetNotes() string
- func (o *ManagementJetStreamConsumerParam) GetNotesOk() (*string, bool)
- func (o *ManagementJetStreamConsumerParam) HasAckWait() bool
- func (o *ManagementJetStreamConsumerParam) HasDeliveryGroup() bool
- func (o *ManagementJetStreamConsumerParam) HasFilterSubject() bool
- func (o *ManagementJetStreamConsumerParam) HasMaxRetry() bool
- func (o *ManagementJetStreamConsumerParam) HasNotes() bool
- func (o ManagementJetStreamConsumerParam) MarshalJSON() ([]byte, error)
- func (o *ManagementJetStreamConsumerParam) SetAckWait(v int64)
- func (o *ManagementJetStreamConsumerParam) SetDeliveryGroup(v string)
- func (o *ManagementJetStreamConsumerParam) SetFilterSubject(v string)
- func (o *ManagementJetStreamConsumerParam) SetMaxInflight(v int64)
- func (o *ManagementJetStreamConsumerParam) SetMaxRetry(v int64)
- func (o *ManagementJetStreamConsumerParam) SetMode(v string)
- func (o *ManagementJetStreamConsumerParam) SetName(v string)
- func (o *ManagementJetStreamConsumerParam) SetNotes(v string)
- type NullableApisAPIRestReqStreamSubjects
- func (v NullableApisAPIRestReqStreamSubjects) Get() *ApisAPIRestReqStreamSubjects
- func (v NullableApisAPIRestReqStreamSubjects) IsSet() bool
- func (v NullableApisAPIRestReqStreamSubjects) MarshalJSON() ([]byte, error)
- func (v *NullableApisAPIRestReqStreamSubjects) Set(val *ApisAPIRestReqStreamSubjects)
- func (v *NullableApisAPIRestReqStreamSubjects) UnmarshalJSON(src []byte) error
- func (v *NullableApisAPIRestReqStreamSubjects) Unset()
- type NullableApisAPIRestRespAllJetStreamConsumers
- func (v NullableApisAPIRestRespAllJetStreamConsumers) Get() *ApisAPIRestRespAllJetStreamConsumers
- func (v NullableApisAPIRestRespAllJetStreamConsumers) IsSet() bool
- func (v NullableApisAPIRestRespAllJetStreamConsumers) MarshalJSON() ([]byte, error)
- func (v *NullableApisAPIRestRespAllJetStreamConsumers) Set(val *ApisAPIRestRespAllJetStreamConsumers)
- func (v *NullableApisAPIRestRespAllJetStreamConsumers) UnmarshalJSON(src []byte) error
- func (v *NullableApisAPIRestRespAllJetStreamConsumers) Unset()
- type NullableApisAPIRestRespAllJetStreams
- func (v NullableApisAPIRestRespAllJetStreams) Get() *ApisAPIRestRespAllJetStreams
- func (v NullableApisAPIRestRespAllJetStreams) IsSet() bool
- func (v NullableApisAPIRestRespAllJetStreams) MarshalJSON() ([]byte, error)
- func (v *NullableApisAPIRestRespAllJetStreams) Set(val *ApisAPIRestRespAllJetStreams)
- func (v *NullableApisAPIRestRespAllJetStreams) UnmarshalJSON(src []byte) error
- func (v *NullableApisAPIRestRespAllJetStreams) Unset()
- type NullableApisAPIRestRespConsumerConfig
- func (v NullableApisAPIRestRespConsumerConfig) Get() *ApisAPIRestRespConsumerConfig
- func (v NullableApisAPIRestRespConsumerConfig) IsSet() bool
- func (v NullableApisAPIRestRespConsumerConfig) MarshalJSON() ([]byte, error)
- func (v *NullableApisAPIRestRespConsumerConfig) Set(val *ApisAPIRestRespConsumerConfig)
- func (v *NullableApisAPIRestRespConsumerConfig) UnmarshalJSON(src []byte) error
- func (v *NullableApisAPIRestRespConsumerConfig) Unset()
- type NullableApisAPIRestRespConsumerInfo
- func (v NullableApisAPIRestRespConsumerInfo) Get() *ApisAPIRestRespConsumerInfo
- func (v NullableApisAPIRestRespConsumerInfo) IsSet() bool
- func (v NullableApisAPIRestRespConsumerInfo) MarshalJSON() ([]byte, error)
- func (v *NullableApisAPIRestRespConsumerInfo) Set(val *ApisAPIRestRespConsumerInfo)
- func (v *NullableApisAPIRestRespConsumerInfo) UnmarshalJSON(src []byte) error
- func (v *NullableApisAPIRestRespConsumerInfo) Unset()
- type NullableApisAPIRestRespDataMessage
- func (v NullableApisAPIRestRespDataMessage) Get() *ApisAPIRestRespDataMessage
- func (v NullableApisAPIRestRespDataMessage) IsSet() bool
- func (v NullableApisAPIRestRespDataMessage) MarshalJSON() ([]byte, error)
- func (v *NullableApisAPIRestRespDataMessage) Set(val *ApisAPIRestRespDataMessage)
- func (v *NullableApisAPIRestRespDataMessage) UnmarshalJSON(src []byte) error
- func (v *NullableApisAPIRestRespDataMessage) Unset()
- type NullableApisAPIRestRespOneJetStream
- func (v NullableApisAPIRestRespOneJetStream) Get() *ApisAPIRestRespOneJetStream
- func (v NullableApisAPIRestRespOneJetStream) IsSet() bool
- func (v NullableApisAPIRestRespOneJetStream) MarshalJSON() ([]byte, error)
- func (v *NullableApisAPIRestRespOneJetStream) Set(val *ApisAPIRestRespOneJetStream)
- func (v *NullableApisAPIRestRespOneJetStream) UnmarshalJSON(src []byte) error
- func (v *NullableApisAPIRestRespOneJetStream) Unset()
- type NullableApisAPIRestRespOneJetStreamConsumer
- func (v NullableApisAPIRestRespOneJetStreamConsumer) Get() *ApisAPIRestRespOneJetStreamConsumer
- func (v NullableApisAPIRestRespOneJetStreamConsumer) IsSet() bool
- func (v NullableApisAPIRestRespOneJetStreamConsumer) MarshalJSON() ([]byte, error)
- func (v *NullableApisAPIRestRespOneJetStreamConsumer) Set(val *ApisAPIRestRespOneJetStreamConsumer)
- func (v *NullableApisAPIRestRespOneJetStreamConsumer) UnmarshalJSON(src []byte) error
- func (v *NullableApisAPIRestRespOneJetStreamConsumer) Unset()
- type NullableApisAPIRestRespSequenceInfo
- func (v NullableApisAPIRestRespSequenceInfo) Get() *ApisAPIRestRespSequenceInfo
- func (v NullableApisAPIRestRespSequenceInfo) IsSet() bool
- func (v NullableApisAPIRestRespSequenceInfo) MarshalJSON() ([]byte, error)
- func (v *NullableApisAPIRestRespSequenceInfo) Set(val *ApisAPIRestRespSequenceInfo)
- func (v *NullableApisAPIRestRespSequenceInfo) UnmarshalJSON(src []byte) error
- func (v *NullableApisAPIRestRespSequenceInfo) Unset()
- type NullableApisAPIRestRespStreamConfig
- func (v NullableApisAPIRestRespStreamConfig) Get() *ApisAPIRestRespStreamConfig
- func (v NullableApisAPIRestRespStreamConfig) IsSet() bool
- func (v NullableApisAPIRestRespStreamConfig) MarshalJSON() ([]byte, error)
- func (v *NullableApisAPIRestRespStreamConfig) Set(val *ApisAPIRestRespStreamConfig)
- func (v *NullableApisAPIRestRespStreamConfig) UnmarshalJSON(src []byte) error
- func (v *NullableApisAPIRestRespStreamConfig) Unset()
- type NullableApisAPIRestRespStreamInfo
- func (v NullableApisAPIRestRespStreamInfo) Get() *ApisAPIRestRespStreamInfo
- func (v NullableApisAPIRestRespStreamInfo) IsSet() bool
- func (v NullableApisAPIRestRespStreamInfo) MarshalJSON() ([]byte, error)
- func (v *NullableApisAPIRestRespStreamInfo) Set(val *ApisAPIRestRespStreamInfo)
- func (v *NullableApisAPIRestRespStreamInfo) UnmarshalJSON(src []byte) error
- func (v *NullableApisAPIRestRespStreamInfo) Unset()
- type NullableApisAPIRestRespStreamState
- func (v NullableApisAPIRestRespStreamState) Get() *ApisAPIRestRespStreamState
- func (v NullableApisAPIRestRespStreamState) IsSet() bool
- func (v NullableApisAPIRestRespStreamState) MarshalJSON() ([]byte, error)
- func (v *NullableApisAPIRestRespStreamState) Set(val *ApisAPIRestRespStreamState)
- func (v *NullableApisAPIRestRespStreamState) UnmarshalJSON(src []byte) error
- func (v *NullableApisAPIRestRespStreamState) Unset()
- type NullableBool
- type NullableDataplaneAckSeqNum
- func (v NullableDataplaneAckSeqNum) Get() *DataplaneAckSeqNum
- func (v NullableDataplaneAckSeqNum) IsSet() bool
- func (v NullableDataplaneAckSeqNum) MarshalJSON() ([]byte, error)
- func (v *NullableDataplaneAckSeqNum) Set(val *DataplaneAckSeqNum)
- func (v *NullableDataplaneAckSeqNum) UnmarshalJSON(src []byte) error
- func (v *NullableDataplaneAckSeqNum) Unset()
- type NullableDataplaneMsgToDeliverSeq
- func (v NullableDataplaneMsgToDeliverSeq) Get() *DataplaneMsgToDeliverSeq
- func (v NullableDataplaneMsgToDeliverSeq) IsSet() bool
- func (v NullableDataplaneMsgToDeliverSeq) MarshalJSON() ([]byte, error)
- func (v *NullableDataplaneMsgToDeliverSeq) Set(val *DataplaneMsgToDeliverSeq)
- func (v *NullableDataplaneMsgToDeliverSeq) UnmarshalJSON(src []byte) error
- func (v *NullableDataplaneMsgToDeliverSeq) Unset()
- type NullableFloat32
- type NullableFloat64
- type NullableGoutilsErrorDetail
- func (v NullableGoutilsErrorDetail) Get() *GoutilsErrorDetail
- func (v NullableGoutilsErrorDetail) IsSet() bool
- func (v NullableGoutilsErrorDetail) MarshalJSON() ([]byte, error)
- func (v *NullableGoutilsErrorDetail) Set(val *GoutilsErrorDetail)
- func (v *NullableGoutilsErrorDetail) UnmarshalJSON(src []byte) error
- func (v *NullableGoutilsErrorDetail) Unset()
- type NullableGoutilsRestAPIBaseResponse
- func (v NullableGoutilsRestAPIBaseResponse) Get() *GoutilsRestAPIBaseResponse
- func (v NullableGoutilsRestAPIBaseResponse) IsSet() bool
- func (v NullableGoutilsRestAPIBaseResponse) MarshalJSON() ([]byte, error)
- func (v *NullableGoutilsRestAPIBaseResponse) Set(val *GoutilsRestAPIBaseResponse)
- func (v *NullableGoutilsRestAPIBaseResponse) UnmarshalJSON(src []byte) error
- func (v *NullableGoutilsRestAPIBaseResponse) Unset()
- type NullableInt
- type NullableInt32
- type NullableInt64
- type NullableManagementJSStreamLimits
- func (v NullableManagementJSStreamLimits) Get() *ManagementJSStreamLimits
- func (v NullableManagementJSStreamLimits) IsSet() bool
- func (v NullableManagementJSStreamLimits) MarshalJSON() ([]byte, error)
- func (v *NullableManagementJSStreamLimits) Set(val *ManagementJSStreamLimits)
- func (v *NullableManagementJSStreamLimits) UnmarshalJSON(src []byte) error
- func (v *NullableManagementJSStreamLimits) Unset()
- type NullableManagementJSStreamParam
- func (v NullableManagementJSStreamParam) Get() *ManagementJSStreamParam
- func (v NullableManagementJSStreamParam) IsSet() bool
- func (v NullableManagementJSStreamParam) MarshalJSON() ([]byte, error)
- func (v *NullableManagementJSStreamParam) Set(val *ManagementJSStreamParam)
- func (v *NullableManagementJSStreamParam) UnmarshalJSON(src []byte) error
- func (v *NullableManagementJSStreamParam) Unset()
- type NullableManagementJetStreamConsumerParam
- func (v NullableManagementJetStreamConsumerParam) Get() *ManagementJetStreamConsumerParam
- func (v NullableManagementJetStreamConsumerParam) IsSet() bool
- func (v NullableManagementJetStreamConsumerParam) MarshalJSON() ([]byte, error)
- func (v *NullableManagementJetStreamConsumerParam) Set(val *ManagementJetStreamConsumerParam)
- func (v *NullableManagementJetStreamConsumerParam) UnmarshalJSON(src []byte) error
- func (v *NullableManagementJetStreamConsumerParam) Unset()
- type NullableString
- type NullableTime
- type ServerConfiguration
- type ServerConfigurations
- type ServerVariable
Constants ¶
This section is empty.
Variables ¶
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 ¶
CacheExpires helper function to determine remaining time before repeating a request.
func PtrFloat32 ¶
PtrFloat32 is a helper routine that returns a pointer to given float value.
func PtrFloat64 ¶
PtrFloat64 is a helper routine that returns a pointer to given float 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 ¶
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 ¶
func (r ApiV1AdminAliveGetRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
type ApiV1AdminReadyGetRequest ¶
type ApiV1AdminReadyGetRequest struct { ApiService *ManagementApiService // contains filtered or unexported fields }
func (ApiV1AdminReadyGetRequest) Execute ¶
func (r ApiV1AdminReadyGetRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
type ApiV1AdminStreamGetRequest ¶
type ApiV1AdminStreamGetRequest struct { ApiService *ManagementApiService // contains filtered or unexported fields }
func (ApiV1AdminStreamGetRequest) Execute ¶
func (r ApiV1AdminStreamGetRequest) Execute() (ApisAPIRestRespAllJetStreams, *_nethttp.Response, error)
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 (r ApiV1AdminStreamPostRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
func (ApiV1AdminStreamPostRequest) HttpmqRequestID ¶
func (r ApiV1AdminStreamPostRequest) HttpmqRequestID(httpmqRequestID string) ApiV1AdminStreamPostRequest
User provided request ID to match against logs
func (ApiV1AdminStreamPostRequest) Setting ¶
func (r ApiV1AdminStreamPostRequest) Setting(setting ManagementJSStreamParam) ApiV1AdminStreamPostRequest
JetStream stream setting
type ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest ¶
type ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest struct { ApiService *ManagementApiService // contains filtered or unexported fields }
func (ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest) Execute ¶
func (r ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
func (ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest) HttpmqRequestID ¶
func (r ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest) HttpmqRequestID(httpmqRequestID string) ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest
User provided request ID to match against logs
type ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest ¶
type ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest struct { ApiService *ManagementApiService // contains filtered or unexported fields }
func (ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest) Execute ¶
func (r ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest) Execute() (ApisAPIRestRespOneJetStreamConsumer, *_nethttp.Response, error)
func (ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest) HttpmqRequestID ¶
func (r ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest) HttpmqRequestID(httpmqRequestID string) ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest
User provided request ID to match against logs
type ApiV1AdminStreamStreamNameConsumerGetRequest ¶
type ApiV1AdminStreamStreamNameConsumerGetRequest struct { ApiService *ManagementApiService // contains filtered or unexported fields }
func (ApiV1AdminStreamStreamNameConsumerGetRequest) Execute ¶
func (r ApiV1AdminStreamStreamNameConsumerGetRequest) Execute() (ApisAPIRestRespAllJetStreamConsumers, *_nethttp.Response, error)
func (ApiV1AdminStreamStreamNameConsumerGetRequest) HttpmqRequestID ¶
func (r ApiV1AdminStreamStreamNameConsumerGetRequest) HttpmqRequestID(httpmqRequestID string) ApiV1AdminStreamStreamNameConsumerGetRequest
User provided request ID to match against logs
type ApiV1AdminStreamStreamNameConsumerPostRequest ¶
type ApiV1AdminStreamStreamNameConsumerPostRequest struct { ApiService *ManagementApiService // contains filtered or unexported fields }
func (ApiV1AdminStreamStreamNameConsumerPostRequest) ConsumerParam ¶
func (r ApiV1AdminStreamStreamNameConsumerPostRequest) ConsumerParam(consumerParam ManagementJetStreamConsumerParam) ApiV1AdminStreamStreamNameConsumerPostRequest
Consumer parameters
func (ApiV1AdminStreamStreamNameConsumerPostRequest) Execute ¶
func (r ApiV1AdminStreamStreamNameConsumerPostRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
func (ApiV1AdminStreamStreamNameConsumerPostRequest) HttpmqRequestID ¶
func (r ApiV1AdminStreamStreamNameConsumerPostRequest) HttpmqRequestID(httpmqRequestID string) ApiV1AdminStreamStreamNameConsumerPostRequest
User provided request ID to match against logs
type ApiV1AdminStreamStreamNameDeleteRequest ¶
type ApiV1AdminStreamStreamNameDeleteRequest struct { ApiService *ManagementApiService // contains filtered or unexported fields }
func (ApiV1AdminStreamStreamNameDeleteRequest) Execute ¶
func (r ApiV1AdminStreamStreamNameDeleteRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
func (ApiV1AdminStreamStreamNameDeleteRequest) HttpmqRequestID ¶
func (r ApiV1AdminStreamStreamNameDeleteRequest) HttpmqRequestID(httpmqRequestID string) ApiV1AdminStreamStreamNameDeleteRequest
User provided request ID to match against logs
type ApiV1AdminStreamStreamNameGetRequest ¶
type ApiV1AdminStreamStreamNameGetRequest struct { ApiService *ManagementApiService // contains filtered or unexported fields }
func (ApiV1AdminStreamStreamNameGetRequest) Execute ¶
func (r ApiV1AdminStreamStreamNameGetRequest) Execute() (ApisAPIRestRespOneJetStream, *_nethttp.Response, error)
func (ApiV1AdminStreamStreamNameGetRequest) HttpmqRequestID ¶
func (r ApiV1AdminStreamStreamNameGetRequest) HttpmqRequestID(httpmqRequestID string) ApiV1AdminStreamStreamNameGetRequest
User provided request ID to match against logs
type ApiV1AdminStreamStreamNameLimitPutRequest ¶
type ApiV1AdminStreamStreamNameLimitPutRequest struct { ApiService *ManagementApiService // contains filtered or unexported fields }
func (ApiV1AdminStreamStreamNameLimitPutRequest) Execute ¶
func (r ApiV1AdminStreamStreamNameLimitPutRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
func (ApiV1AdminStreamStreamNameLimitPutRequest) HttpmqRequestID ¶
func (r ApiV1AdminStreamStreamNameLimitPutRequest) HttpmqRequestID(httpmqRequestID string) ApiV1AdminStreamStreamNameLimitPutRequest
User provided request ID to match against logs
func (ApiV1AdminStreamStreamNameLimitPutRequest) Limits ¶
func (r ApiV1AdminStreamStreamNameLimitPutRequest) Limits(limits ManagementJSStreamLimits) ApiV1AdminStreamStreamNameLimitPutRequest
New stream limits
type ApiV1AdminStreamStreamNameSubjectPutRequest ¶
type ApiV1AdminStreamStreamNameSubjectPutRequest struct { ApiService *ManagementApiService // contains filtered or unexported fields }
func (ApiV1AdminStreamStreamNameSubjectPutRequest) Execute ¶
func (r ApiV1AdminStreamStreamNameSubjectPutRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
func (ApiV1AdminStreamStreamNameSubjectPutRequest) HttpmqRequestID ¶
func (r ApiV1AdminStreamStreamNameSubjectPutRequest) HttpmqRequestID(httpmqRequestID string) ApiV1AdminStreamStreamNameSubjectPutRequest
User provided request ID to match against logs
func (ApiV1AdminStreamStreamNameSubjectPutRequest) Subjects ¶
func (r ApiV1AdminStreamStreamNameSubjectPutRequest) Subjects(subjects ApisAPIRestReqStreamSubjects) ApiV1AdminStreamStreamNameSubjectPutRequest
List of new subjects
type ApiV1DataAliveGetRequest ¶
type ApiV1DataAliveGetRequest struct { ApiService *DataplaneApiService // contains filtered or unexported fields }
func (ApiV1DataAliveGetRequest) Execute ¶
func (r ApiV1DataAliveGetRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
type ApiV1DataReadyGetRequest ¶
type ApiV1DataReadyGetRequest struct { ApiService *DataplaneApiService // contains filtered or unexported fields }
func (ApiV1DataReadyGetRequest) Execute ¶
func (r ApiV1DataReadyGetRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
type ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest ¶
type ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest struct { ApiService *DataplaneApiService // contains filtered or unexported fields }
func (ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest) Execute ¶
func (r ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
func (ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest) HttpmqRequestID ¶
func (r ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest) HttpmqRequestID(httpmqRequestID string) ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest
User provided request ID to match against logs
func (ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest) SequenceNum ¶
func (r ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest) SequenceNum(sequenceNum DataplaneAckSeqNum) ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest
Message message sequence numbers
type ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest ¶
type ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest struct { ApiService *DataplaneApiService // contains filtered or unexported fields }
func (ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) DeliveryGroup ¶
func (r ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) DeliveryGroup(deliveryGroup string) ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest
Needed if consumer uses delivery groups
func (ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) Execute ¶
func (r ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) Execute() (ApisAPIRestRespDataMessage, *_nethttp.Response, error)
func (ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) HttpmqRequestID ¶
func (r ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) HttpmqRequestID(httpmqRequestID string) ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest
User provided request ID to match against logs
func (ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) MaxMsgInflight ¶
func (r ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) MaxMsgInflight(maxMsgInflight int32) ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest
Max number of inflight messages (DEFAULT: 1)
func (ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) SubjectName ¶
func (r ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) SubjectName(subjectName string) ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest
JetStream subject to subscribe to
type ApiV1DataSubjectSubjectNamePostRequest ¶
type ApiV1DataSubjectSubjectNamePostRequest struct { ApiService *DataplaneApiService // contains filtered or unexported fields }
func (ApiV1DataSubjectSubjectNamePostRequest) Execute ¶
func (r ApiV1DataSubjectSubjectNamePostRequest) Execute() (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
func (ApiV1DataSubjectSubjectNamePostRequest) HttpmqRequestID ¶
func (r ApiV1DataSubjectSubjectNamePostRequest) HttpmqRequestID(httpmqRequestID string) ApiV1DataSubjectSubjectNamePostRequest
User provided request ID to match against logs
func (ApiV1DataSubjectSubjectNamePostRequest) Message ¶
func (r ApiV1DataSubjectSubjectNamePostRequest) Message(message string) ApiV1DataSubjectSubjectNamePostRequest
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 ¶
func (o *ApisAPIRestRespAllJetStreamConsumers) GetConsumers() map[string]ApisAPIRestRespConsumerInfo
GetConsumers returns the Consumers field value if set, zero value otherwise.
func (*ApisAPIRestRespAllJetStreamConsumers) GetConsumersOk ¶
func (o *ApisAPIRestRespAllJetStreamConsumers) GetConsumersOk() (*map[string]ApisAPIRestRespConsumerInfo, bool)
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 ¶
func (o *ApisAPIRestRespAllJetStreamConsumers) GetError() GoutilsErrorDetail
GetError returns the Error field value if set, zero value otherwise.
func (*ApisAPIRestRespAllJetStreamConsumers) GetErrorOk ¶
func (o *ApisAPIRestRespAllJetStreamConsumers) GetErrorOk() (*GoutilsErrorDetail, bool)
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 ¶
func (o *ApisAPIRestRespAllJetStreamConsumers) GetSuccess() bool
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 ¶
func (o *ApisAPIRestRespAllJetStreamConsumers) HasError() bool
HasError returns a boolean if a field has been set.
func (ApisAPIRestRespAllJetStreamConsumers) MarshalJSON ¶
func (o ApisAPIRestRespAllJetStreamConsumers) MarshalJSON() ([]byte, error)
func (*ApisAPIRestRespAllJetStreamConsumers) SetConsumers ¶
func (o *ApisAPIRestRespAllJetStreamConsumers) SetConsumers(v map[string]ApisAPIRestRespConsumerInfo)
SetConsumers gets a reference to the given map[string]ApisAPIRestRespConsumerInfo and assigns it to the Consumers field.
func (*ApisAPIRestRespAllJetStreamConsumers) SetError ¶
func (o *ApisAPIRestRespAllJetStreamConsumers) SetError(v GoutilsErrorDetail)
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 ¶
func (o *ApisAPIRestRespAllJetStreams) GetError() GoutilsErrorDetail
GetError returns the Error field value if set, zero value otherwise.
func (*ApisAPIRestRespAllJetStreams) GetErrorOk ¶
func (o *ApisAPIRestRespAllJetStreams) GetErrorOk() (*GoutilsErrorDetail, bool)
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 ¶
func (o *ApisAPIRestRespAllJetStreams) GetStreams() map[string]ApisAPIRestRespStreamInfo
GetStreams returns the Streams field value if set, zero value otherwise.
func (*ApisAPIRestRespAllJetStreams) GetStreamsOk ¶
func (o *ApisAPIRestRespAllJetStreams) GetStreamsOk() (*map[string]ApisAPIRestRespStreamInfo, bool)
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 ¶
func (o *ApisAPIRestRespAllJetStreams) SetError(v GoutilsErrorDetail)
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 ¶
func (o *ApisAPIRestRespAllJetStreams) SetStreams(v map[string]ApisAPIRestRespStreamInfo)
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 ¶
func (o *ApisAPIRestRespConsumerInfo) GetAckFloor() ApisAPIRestRespSequenceInfo
GetAckFloor returns the AckFloor field value
func (*ApisAPIRestRespConsumerInfo) GetAckFloorOk ¶
func (o *ApisAPIRestRespConsumerInfo) GetAckFloorOk() (*ApisAPIRestRespSequenceInfo, bool)
GetAckFloorOk returns a tuple with the AckFloor field value and a boolean to check if the value has been set.
func (*ApisAPIRestRespConsumerInfo) GetConfig ¶
func (o *ApisAPIRestRespConsumerInfo) GetConfig() ApisAPIRestRespConsumerConfig
GetConfig returns the Config field value
func (*ApisAPIRestRespConsumerInfo) GetConfigOk ¶
func (o *ApisAPIRestRespConsumerInfo) GetConfigOk() (*ApisAPIRestRespConsumerConfig, bool)
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 ¶
func (o *ApisAPIRestRespConsumerInfo) GetDelivered() ApisAPIRestRespSequenceInfo
GetDelivered returns the Delivered field value
func (*ApisAPIRestRespConsumerInfo) GetDeliveredOk ¶
func (o *ApisAPIRestRespConsumerInfo) GetDeliveredOk() (*ApisAPIRestRespSequenceInfo, bool)
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 ¶
func (o *ApisAPIRestRespConsumerInfo) SetAckFloor(v ApisAPIRestRespSequenceInfo)
SetAckFloor sets field value
func (*ApisAPIRestRespConsumerInfo) SetConfig ¶
func (o *ApisAPIRestRespConsumerInfo) SetConfig(v ApisAPIRestRespConsumerConfig)
SetConfig sets field value
func (*ApisAPIRestRespConsumerInfo) SetCreated ¶
func (o *ApisAPIRestRespConsumerInfo) SetCreated(v string)
SetCreated sets field value
func (*ApisAPIRestRespConsumerInfo) SetDelivered ¶
func (o *ApisAPIRestRespConsumerInfo) SetDelivered(v ApisAPIRestRespSequenceInfo)
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 ¶
func (o *ApisAPIRestRespDataMessage) GetError() GoutilsErrorDetail
GetError returns the Error field value if set, zero value otherwise.
func (*ApisAPIRestRespDataMessage) GetErrorOk ¶
func (o *ApisAPIRestRespDataMessage) GetErrorOk() (*GoutilsErrorDetail, bool)
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 ¶
func (o *ApisAPIRestRespDataMessage) GetSequence() DataplaneMsgToDeliverSeq
GetSequence returns the Sequence field value
func (*ApisAPIRestRespDataMessage) GetSequenceOk ¶
func (o *ApisAPIRestRespDataMessage) GetSequenceOk() (*DataplaneMsgToDeliverSeq, bool)
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 ¶
func (o *ApisAPIRestRespDataMessage) SetError(v GoutilsErrorDetail)
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 ¶
func (o *ApisAPIRestRespDataMessage) SetSequence(v DataplaneMsgToDeliverSeq)
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 ¶
func (o *ApisAPIRestRespOneJetStream) GetError() GoutilsErrorDetail
GetError returns the Error field value if set, zero value otherwise.
func (*ApisAPIRestRespOneJetStream) GetErrorOk ¶
func (o *ApisAPIRestRespOneJetStream) GetErrorOk() (*GoutilsErrorDetail, bool)
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 ¶
func (o *ApisAPIRestRespOneJetStream) GetStream() ApisAPIRestRespStreamInfo
GetStream returns the Stream field value if set, zero value otherwise.
func (*ApisAPIRestRespOneJetStream) GetStreamOk ¶
func (o *ApisAPIRestRespOneJetStream) GetStreamOk() (*ApisAPIRestRespStreamInfo, bool)
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 ¶
func (o *ApisAPIRestRespOneJetStream) SetError(v GoutilsErrorDetail)
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 ¶
func (o *ApisAPIRestRespOneJetStream) SetStream(v ApisAPIRestRespStreamInfo)
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 ¶
func (o *ApisAPIRestRespOneJetStreamConsumer) GetConsumer() ApisAPIRestRespConsumerInfo
GetConsumer returns the Consumer field value if set, zero value otherwise.
func (*ApisAPIRestRespOneJetStreamConsumer) GetConsumerOk ¶
func (o *ApisAPIRestRespOneJetStreamConsumer) GetConsumerOk() (*ApisAPIRestRespConsumerInfo, bool)
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 ¶
func (o *ApisAPIRestRespOneJetStreamConsumer) GetError() GoutilsErrorDetail
GetError returns the Error field value if set, zero value otherwise.
func (*ApisAPIRestRespOneJetStreamConsumer) GetErrorOk ¶
func (o *ApisAPIRestRespOneJetStreamConsumer) GetErrorOk() (*GoutilsErrorDetail, bool)
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 ¶
func (o *ApisAPIRestRespOneJetStreamConsumer) HasError() bool
HasError returns a boolean if a field has been set.
func (ApisAPIRestRespOneJetStreamConsumer) MarshalJSON ¶
func (o ApisAPIRestRespOneJetStreamConsumer) MarshalJSON() ([]byte, error)
func (*ApisAPIRestRespOneJetStreamConsumer) SetConsumer ¶
func (o *ApisAPIRestRespOneJetStreamConsumer) SetConsumer(v ApisAPIRestRespConsumerInfo)
SetConsumer gets a reference to the given ApisAPIRestRespConsumerInfo and assigns it to the Consumer field.
func (*ApisAPIRestRespOneJetStreamConsumer) SetError ¶
func (o *ApisAPIRestRespOneJetStreamConsumer) SetError(v GoutilsErrorDetail)
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 ¶
func (o *ApisAPIRestRespStreamInfo) GetConfig() ApisAPIRestRespStreamConfig
GetConfig returns the Config field value
func (*ApisAPIRestRespStreamInfo) GetConfigOk ¶
func (o *ApisAPIRestRespStreamInfo) GetConfigOk() (*ApisAPIRestRespStreamConfig, bool)
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 ¶
func (o *ApisAPIRestRespStreamInfo) GetState() ApisAPIRestRespStreamState
GetState returns the State field value
func (*ApisAPIRestRespStreamInfo) GetStateOk ¶
func (o *ApisAPIRestRespStreamInfo) GetStateOk() (*ApisAPIRestRespStreamState, bool)
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 ¶
func (o *ApisAPIRestRespStreamInfo) SetConfig(v ApisAPIRestRespStreamConfig)
SetConfig sets field value
func (*ApisAPIRestRespStreamInfo) SetCreated ¶
func (o *ApisAPIRestRespStreamInfo) SetCreated(v string)
SetCreated sets field value
func (*ApisAPIRestRespStreamInfo) SetState ¶
func (o *ApisAPIRestRespStreamInfo) SetState(v ApisAPIRestRespStreamState)
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) ServerURLWithContext ¶
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 ¶
func (a *DataplaneApiService) V1DataAliveGet(ctx _context.Context) ApiV1DataAliveGetRequest
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 ¶
func (a *DataplaneApiService) V1DataAliveGetExecute(r ApiV1DataAliveGetRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
Execute executes the request
@return GoutilsRestAPIBaseResponse
func (*DataplaneApiService) V1DataReadyGet ¶
func (a *DataplaneApiService) V1DataReadyGet(ctx _context.Context) ApiV1DataReadyGetRequest
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 ¶
func (a *DataplaneApiService) V1DataReadyGetExecute(r ApiV1DataReadyGetRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
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 ¶
func (a *DataplaneApiService) V1DataStreamStreamNameConsumerConsumerNameAckPostExecute(r ApiV1DataStreamStreamNameConsumerConsumerNameAckPostRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
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 ¶
func (a *DataplaneApiService) V1DataStreamStreamNameConsumerConsumerNameGetExecute(r ApiV1DataStreamStreamNameConsumerConsumerNameGetRequest) (ApisAPIRestRespDataMessage, *_nethttp.Response, error)
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 ¶
func (a *DataplaneApiService) V1DataSubjectSubjectNamePostExecute(r ApiV1DataSubjectSubjectNamePostRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
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
func (o *GoutilsRestAPIBaseResponse) GetError() GoutilsErrorDetail
GetError returns the Error field value if set, zero value otherwise.
func (*GoutilsRestAPIBaseResponse) GetErrorOk ¶ added in v0.4.0
func (o *GoutilsRestAPIBaseResponse) GetErrorOk() (*GoutilsErrorDetail, bool)
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
func (o *GoutilsRestAPIBaseResponse) SetError(v GoutilsErrorDetail)
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 ¶
func (a *ManagementApiService) V1AdminAliveGet(ctx _context.Context) ApiV1AdminAliveGetRequest
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 ¶
func (a *ManagementApiService) V1AdminAliveGetExecute(r ApiV1AdminAliveGetRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
Execute executes the request
@return GoutilsRestAPIBaseResponse
func (*ManagementApiService) V1AdminReadyGet ¶
func (a *ManagementApiService) V1AdminReadyGet(ctx _context.Context) ApiV1AdminReadyGetRequest
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 ¶
func (a *ManagementApiService) V1AdminReadyGetExecute(r ApiV1AdminReadyGetRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
Execute executes the request
@return GoutilsRestAPIBaseResponse
func (*ManagementApiService) V1AdminStreamGet ¶
func (a *ManagementApiService) V1AdminStreamGet(ctx _context.Context) ApiV1AdminStreamGetRequest
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 ¶
func (a *ManagementApiService) V1AdminStreamGetExecute(r ApiV1AdminStreamGetRequest) (ApisAPIRestRespAllJetStreams, *_nethttp.Response, error)
Execute executes the request
@return ApisAPIRestRespAllJetStreams
func (*ManagementApiService) V1AdminStreamPost ¶
func (a *ManagementApiService) V1AdminStreamPost(ctx _context.Context) ApiV1AdminStreamPostRequest
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 ¶
func (a *ManagementApiService) V1AdminStreamPostExecute(r ApiV1AdminStreamPostRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
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 ¶
func (a *ManagementApiService) V1AdminStreamStreamNameConsumerConsumerNameDeleteExecute(r ApiV1AdminStreamStreamNameConsumerConsumerNameDeleteRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
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 ¶
func (a *ManagementApiService) V1AdminStreamStreamNameConsumerConsumerNameGetExecute(r ApiV1AdminStreamStreamNameConsumerConsumerNameGetRequest) (ApisAPIRestRespOneJetStreamConsumer, *_nethttp.Response, error)
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 ¶
func (a *ManagementApiService) V1AdminStreamStreamNameConsumerGetExecute(r ApiV1AdminStreamStreamNameConsumerGetRequest) (ApisAPIRestRespAllJetStreamConsumers, *_nethttp.Response, error)
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 ¶
func (a *ManagementApiService) V1AdminStreamStreamNameConsumerPostExecute(r ApiV1AdminStreamStreamNameConsumerPostRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
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 ¶
func (a *ManagementApiService) V1AdminStreamStreamNameDeleteExecute(r ApiV1AdminStreamStreamNameDeleteRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
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 ¶
func (a *ManagementApiService) V1AdminStreamStreamNameGetExecute(r ApiV1AdminStreamStreamNameGetRequest) (ApisAPIRestRespOneJetStream, *_nethttp.Response, error)
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 ¶
func (a *ManagementApiService) V1AdminStreamStreamNameLimitPutExecute(r ApiV1AdminStreamStreamNameLimitPutRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
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 ¶
func (a *ManagementApiService) V1AdminStreamStreamNameSubjectPutExecute(r ApiV1AdminStreamStreamNameSubjectPutRequest) (GoutilsRestAPIBaseResponse, *_nethttp.Response, error)
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 ¶
func (o *ManagementJetStreamConsumerParam) GetMode() string
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 ¶
func (o *ManagementJetStreamConsumerParam) GetName() string
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 ¶
func (o *ManagementJetStreamConsumerParam) GetNotes() string
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 ¶
func (o *ManagementJetStreamConsumerParam) SetMode(v string)
SetMode sets field value
func (*ManagementJetStreamConsumerParam) SetName ¶
func (o *ManagementJetStreamConsumerParam) SetName(v string)
SetName sets field value
func (*ManagementJetStreamConsumerParam) SetNotes ¶
func (o *ManagementJetStreamConsumerParam) SetNotes(v string)
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 NewNullableApisAPIRestReqStreamSubjects ¶
func NewNullableApisAPIRestReqStreamSubjects(val *ApisAPIRestReqStreamSubjects) *NullableApisAPIRestReqStreamSubjects
func (NullableApisAPIRestReqStreamSubjects) Get ¶
func (v NullableApisAPIRestReqStreamSubjects) Get() *ApisAPIRestReqStreamSubjects
func (NullableApisAPIRestReqStreamSubjects) IsSet ¶
func (v NullableApisAPIRestReqStreamSubjects) IsSet() bool
func (NullableApisAPIRestReqStreamSubjects) MarshalJSON ¶
func (v NullableApisAPIRestReqStreamSubjects) MarshalJSON() ([]byte, error)
func (*NullableApisAPIRestReqStreamSubjects) Set ¶
func (v *NullableApisAPIRestReqStreamSubjects) Set(val *ApisAPIRestReqStreamSubjects)
func (*NullableApisAPIRestReqStreamSubjects) UnmarshalJSON ¶
func (v *NullableApisAPIRestReqStreamSubjects) UnmarshalJSON(src []byte) error
func (*NullableApisAPIRestReqStreamSubjects) Unset ¶
func (v *NullableApisAPIRestReqStreamSubjects) Unset()
type NullableApisAPIRestRespAllJetStreamConsumers ¶
type NullableApisAPIRestRespAllJetStreamConsumers struct {
// contains filtered or unexported fields
}
func NewNullableApisAPIRestRespAllJetStreamConsumers ¶
func NewNullableApisAPIRestRespAllJetStreamConsumers(val *ApisAPIRestRespAllJetStreamConsumers) *NullableApisAPIRestRespAllJetStreamConsumers
func (NullableApisAPIRestRespAllJetStreamConsumers) IsSet ¶
func (v NullableApisAPIRestRespAllJetStreamConsumers) IsSet() bool
func (NullableApisAPIRestRespAllJetStreamConsumers) MarshalJSON ¶
func (v NullableApisAPIRestRespAllJetStreamConsumers) MarshalJSON() ([]byte, error)
func (*NullableApisAPIRestRespAllJetStreamConsumers) Set ¶
func (v *NullableApisAPIRestRespAllJetStreamConsumers) Set(val *ApisAPIRestRespAllJetStreamConsumers)
func (*NullableApisAPIRestRespAllJetStreamConsumers) UnmarshalJSON ¶
func (v *NullableApisAPIRestRespAllJetStreamConsumers) UnmarshalJSON(src []byte) error
func (*NullableApisAPIRestRespAllJetStreamConsumers) Unset ¶
func (v *NullableApisAPIRestRespAllJetStreamConsumers) Unset()
type NullableApisAPIRestRespAllJetStreams ¶
type NullableApisAPIRestRespAllJetStreams struct {
// contains filtered or unexported fields
}
func NewNullableApisAPIRestRespAllJetStreams ¶
func NewNullableApisAPIRestRespAllJetStreams(val *ApisAPIRestRespAllJetStreams) *NullableApisAPIRestRespAllJetStreams
func (NullableApisAPIRestRespAllJetStreams) Get ¶
func (v NullableApisAPIRestRespAllJetStreams) Get() *ApisAPIRestRespAllJetStreams
func (NullableApisAPIRestRespAllJetStreams) IsSet ¶
func (v NullableApisAPIRestRespAllJetStreams) IsSet() bool
func (NullableApisAPIRestRespAllJetStreams) MarshalJSON ¶
func (v NullableApisAPIRestRespAllJetStreams) MarshalJSON() ([]byte, error)
func (*NullableApisAPIRestRespAllJetStreams) Set ¶
func (v *NullableApisAPIRestRespAllJetStreams) Set(val *ApisAPIRestRespAllJetStreams)
func (*NullableApisAPIRestRespAllJetStreams) UnmarshalJSON ¶
func (v *NullableApisAPIRestRespAllJetStreams) UnmarshalJSON(src []byte) error
func (*NullableApisAPIRestRespAllJetStreams) Unset ¶
func (v *NullableApisAPIRestRespAllJetStreams) Unset()
type NullableApisAPIRestRespConsumerConfig ¶
type NullableApisAPIRestRespConsumerConfig struct {
// contains filtered or unexported fields
}
func NewNullableApisAPIRestRespConsumerConfig ¶
func NewNullableApisAPIRestRespConsumerConfig(val *ApisAPIRestRespConsumerConfig) *NullableApisAPIRestRespConsumerConfig
func (NullableApisAPIRestRespConsumerConfig) Get ¶
func (v NullableApisAPIRestRespConsumerConfig) Get() *ApisAPIRestRespConsumerConfig
func (NullableApisAPIRestRespConsumerConfig) IsSet ¶
func (v NullableApisAPIRestRespConsumerConfig) IsSet() bool
func (NullableApisAPIRestRespConsumerConfig) MarshalJSON ¶
func (v NullableApisAPIRestRespConsumerConfig) MarshalJSON() ([]byte, error)
func (*NullableApisAPIRestRespConsumerConfig) Set ¶
func (v *NullableApisAPIRestRespConsumerConfig) Set(val *ApisAPIRestRespConsumerConfig)
func (*NullableApisAPIRestRespConsumerConfig) UnmarshalJSON ¶
func (v *NullableApisAPIRestRespConsumerConfig) UnmarshalJSON(src []byte) error
func (*NullableApisAPIRestRespConsumerConfig) Unset ¶
func (v *NullableApisAPIRestRespConsumerConfig) Unset()
type NullableApisAPIRestRespConsumerInfo ¶
type NullableApisAPIRestRespConsumerInfo struct {
// contains filtered or unexported fields
}
func NewNullableApisAPIRestRespConsumerInfo ¶
func NewNullableApisAPIRestRespConsumerInfo(val *ApisAPIRestRespConsumerInfo) *NullableApisAPIRestRespConsumerInfo
func (NullableApisAPIRestRespConsumerInfo) Get ¶
func (v NullableApisAPIRestRespConsumerInfo) Get() *ApisAPIRestRespConsumerInfo
func (NullableApisAPIRestRespConsumerInfo) IsSet ¶
func (v NullableApisAPIRestRespConsumerInfo) IsSet() bool
func (NullableApisAPIRestRespConsumerInfo) MarshalJSON ¶
func (v NullableApisAPIRestRespConsumerInfo) MarshalJSON() ([]byte, error)
func (*NullableApisAPIRestRespConsumerInfo) Set ¶
func (v *NullableApisAPIRestRespConsumerInfo) Set(val *ApisAPIRestRespConsumerInfo)
func (*NullableApisAPIRestRespConsumerInfo) UnmarshalJSON ¶
func (v *NullableApisAPIRestRespConsumerInfo) UnmarshalJSON(src []byte) error
func (*NullableApisAPIRestRespConsumerInfo) Unset ¶
func (v *NullableApisAPIRestRespConsumerInfo) Unset()
type NullableApisAPIRestRespDataMessage ¶
type NullableApisAPIRestRespDataMessage struct {
// contains filtered or unexported fields
}
func NewNullableApisAPIRestRespDataMessage ¶
func NewNullableApisAPIRestRespDataMessage(val *ApisAPIRestRespDataMessage) *NullableApisAPIRestRespDataMessage
func (NullableApisAPIRestRespDataMessage) Get ¶
func (v NullableApisAPIRestRespDataMessage) Get() *ApisAPIRestRespDataMessage
func (NullableApisAPIRestRespDataMessage) IsSet ¶
func (v NullableApisAPIRestRespDataMessage) IsSet() bool
func (NullableApisAPIRestRespDataMessage) MarshalJSON ¶
func (v NullableApisAPIRestRespDataMessage) MarshalJSON() ([]byte, error)
func (*NullableApisAPIRestRespDataMessage) Set ¶
func (v *NullableApisAPIRestRespDataMessage) Set(val *ApisAPIRestRespDataMessage)
func (*NullableApisAPIRestRespDataMessage) UnmarshalJSON ¶
func (v *NullableApisAPIRestRespDataMessage) UnmarshalJSON(src []byte) error
func (*NullableApisAPIRestRespDataMessage) Unset ¶
func (v *NullableApisAPIRestRespDataMessage) Unset()
type NullableApisAPIRestRespOneJetStream ¶
type NullableApisAPIRestRespOneJetStream struct {
// contains filtered or unexported fields
}
func NewNullableApisAPIRestRespOneJetStream ¶
func NewNullableApisAPIRestRespOneJetStream(val *ApisAPIRestRespOneJetStream) *NullableApisAPIRestRespOneJetStream
func (NullableApisAPIRestRespOneJetStream) Get ¶
func (v NullableApisAPIRestRespOneJetStream) Get() *ApisAPIRestRespOneJetStream
func (NullableApisAPIRestRespOneJetStream) IsSet ¶
func (v NullableApisAPIRestRespOneJetStream) IsSet() bool
func (NullableApisAPIRestRespOneJetStream) MarshalJSON ¶
func (v NullableApisAPIRestRespOneJetStream) MarshalJSON() ([]byte, error)
func (*NullableApisAPIRestRespOneJetStream) Set ¶
func (v *NullableApisAPIRestRespOneJetStream) Set(val *ApisAPIRestRespOneJetStream)
func (*NullableApisAPIRestRespOneJetStream) UnmarshalJSON ¶
func (v *NullableApisAPIRestRespOneJetStream) UnmarshalJSON(src []byte) error
func (*NullableApisAPIRestRespOneJetStream) Unset ¶
func (v *NullableApisAPIRestRespOneJetStream) Unset()
type NullableApisAPIRestRespOneJetStreamConsumer ¶
type NullableApisAPIRestRespOneJetStreamConsumer struct {
// contains filtered or unexported fields
}
func NewNullableApisAPIRestRespOneJetStreamConsumer ¶
func NewNullableApisAPIRestRespOneJetStreamConsumer(val *ApisAPIRestRespOneJetStreamConsumer) *NullableApisAPIRestRespOneJetStreamConsumer
func (NullableApisAPIRestRespOneJetStreamConsumer) IsSet ¶
func (v NullableApisAPIRestRespOneJetStreamConsumer) IsSet() bool
func (NullableApisAPIRestRespOneJetStreamConsumer) MarshalJSON ¶
func (v NullableApisAPIRestRespOneJetStreamConsumer) MarshalJSON() ([]byte, error)
func (*NullableApisAPIRestRespOneJetStreamConsumer) Set ¶
func (v *NullableApisAPIRestRespOneJetStreamConsumer) Set(val *ApisAPIRestRespOneJetStreamConsumer)
func (*NullableApisAPIRestRespOneJetStreamConsumer) UnmarshalJSON ¶
func (v *NullableApisAPIRestRespOneJetStreamConsumer) UnmarshalJSON(src []byte) error
func (*NullableApisAPIRestRespOneJetStreamConsumer) Unset ¶
func (v *NullableApisAPIRestRespOneJetStreamConsumer) Unset()
type NullableApisAPIRestRespSequenceInfo ¶
type NullableApisAPIRestRespSequenceInfo struct {
// contains filtered or unexported fields
}
func NewNullableApisAPIRestRespSequenceInfo ¶
func NewNullableApisAPIRestRespSequenceInfo(val *ApisAPIRestRespSequenceInfo) *NullableApisAPIRestRespSequenceInfo
func (NullableApisAPIRestRespSequenceInfo) Get ¶
func (v NullableApisAPIRestRespSequenceInfo) Get() *ApisAPIRestRespSequenceInfo
func (NullableApisAPIRestRespSequenceInfo) IsSet ¶
func (v NullableApisAPIRestRespSequenceInfo) IsSet() bool
func (NullableApisAPIRestRespSequenceInfo) MarshalJSON ¶
func (v NullableApisAPIRestRespSequenceInfo) MarshalJSON() ([]byte, error)
func (*NullableApisAPIRestRespSequenceInfo) Set ¶
func (v *NullableApisAPIRestRespSequenceInfo) Set(val *ApisAPIRestRespSequenceInfo)
func (*NullableApisAPIRestRespSequenceInfo) UnmarshalJSON ¶
func (v *NullableApisAPIRestRespSequenceInfo) UnmarshalJSON(src []byte) error
func (*NullableApisAPIRestRespSequenceInfo) Unset ¶
func (v *NullableApisAPIRestRespSequenceInfo) Unset()
type NullableApisAPIRestRespStreamConfig ¶
type NullableApisAPIRestRespStreamConfig struct {
// contains filtered or unexported fields
}
func NewNullableApisAPIRestRespStreamConfig ¶
func NewNullableApisAPIRestRespStreamConfig(val *ApisAPIRestRespStreamConfig) *NullableApisAPIRestRespStreamConfig
func (NullableApisAPIRestRespStreamConfig) Get ¶
func (v NullableApisAPIRestRespStreamConfig) Get() *ApisAPIRestRespStreamConfig
func (NullableApisAPIRestRespStreamConfig) IsSet ¶
func (v NullableApisAPIRestRespStreamConfig) IsSet() bool
func (NullableApisAPIRestRespStreamConfig) MarshalJSON ¶
func (v NullableApisAPIRestRespStreamConfig) MarshalJSON() ([]byte, error)
func (*NullableApisAPIRestRespStreamConfig) Set ¶
func (v *NullableApisAPIRestRespStreamConfig) Set(val *ApisAPIRestRespStreamConfig)
func (*NullableApisAPIRestRespStreamConfig) UnmarshalJSON ¶
func (v *NullableApisAPIRestRespStreamConfig) UnmarshalJSON(src []byte) error
func (*NullableApisAPIRestRespStreamConfig) Unset ¶
func (v *NullableApisAPIRestRespStreamConfig) Unset()
type NullableApisAPIRestRespStreamInfo ¶
type NullableApisAPIRestRespStreamInfo struct {
// contains filtered or unexported fields
}
func NewNullableApisAPIRestRespStreamInfo ¶
func NewNullableApisAPIRestRespStreamInfo(val *ApisAPIRestRespStreamInfo) *NullableApisAPIRestRespStreamInfo
func (NullableApisAPIRestRespStreamInfo) Get ¶
func (v NullableApisAPIRestRespStreamInfo) Get() *ApisAPIRestRespStreamInfo
func (NullableApisAPIRestRespStreamInfo) IsSet ¶
func (v NullableApisAPIRestRespStreamInfo) IsSet() bool
func (NullableApisAPIRestRespStreamInfo) MarshalJSON ¶
func (v NullableApisAPIRestRespStreamInfo) MarshalJSON() ([]byte, error)
func (*NullableApisAPIRestRespStreamInfo) Set ¶
func (v *NullableApisAPIRestRespStreamInfo) Set(val *ApisAPIRestRespStreamInfo)
func (*NullableApisAPIRestRespStreamInfo) UnmarshalJSON ¶
func (v *NullableApisAPIRestRespStreamInfo) UnmarshalJSON(src []byte) error
func (*NullableApisAPIRestRespStreamInfo) Unset ¶
func (v *NullableApisAPIRestRespStreamInfo) Unset()
type NullableApisAPIRestRespStreamState ¶
type NullableApisAPIRestRespStreamState struct {
// contains filtered or unexported fields
}
func NewNullableApisAPIRestRespStreamState ¶
func NewNullableApisAPIRestRespStreamState(val *ApisAPIRestRespStreamState) *NullableApisAPIRestRespStreamState
func (NullableApisAPIRestRespStreamState) Get ¶
func (v NullableApisAPIRestRespStreamState) Get() *ApisAPIRestRespStreamState
func (NullableApisAPIRestRespStreamState) IsSet ¶
func (v NullableApisAPIRestRespStreamState) IsSet() bool
func (NullableApisAPIRestRespStreamState) MarshalJSON ¶
func (v NullableApisAPIRestRespStreamState) MarshalJSON() ([]byte, error)
func (*NullableApisAPIRestRespStreamState) Set ¶
func (v *NullableApisAPIRestRespStreamState) Set(val *ApisAPIRestRespStreamState)
func (*NullableApisAPIRestRespStreamState) UnmarshalJSON ¶
func (v *NullableApisAPIRestRespStreamState) UnmarshalJSON(src []byte) error
func (*NullableApisAPIRestRespStreamState) Unset ¶
func (v *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 (v NullableDataplaneAckSeqNum) Get() *DataplaneAckSeqNum
func (NullableDataplaneAckSeqNum) IsSet ¶
func (v NullableDataplaneAckSeqNum) IsSet() bool
func (NullableDataplaneAckSeqNum) MarshalJSON ¶
func (v NullableDataplaneAckSeqNum) MarshalJSON() ([]byte, error)
func (*NullableDataplaneAckSeqNum) Set ¶
func (v *NullableDataplaneAckSeqNum) Set(val *DataplaneAckSeqNum)
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 NewNullableDataplaneMsgToDeliverSeq ¶
func NewNullableDataplaneMsgToDeliverSeq(val *DataplaneMsgToDeliverSeq) *NullableDataplaneMsgToDeliverSeq
func (NullableDataplaneMsgToDeliverSeq) Get ¶
func (v NullableDataplaneMsgToDeliverSeq) Get() *DataplaneMsgToDeliverSeq
func (NullableDataplaneMsgToDeliverSeq) IsSet ¶
func (v NullableDataplaneMsgToDeliverSeq) IsSet() bool
func (NullableDataplaneMsgToDeliverSeq) MarshalJSON ¶
func (v NullableDataplaneMsgToDeliverSeq) MarshalJSON() ([]byte, error)
func (*NullableDataplaneMsgToDeliverSeq) Set ¶
func (v *NullableDataplaneMsgToDeliverSeq) Set(val *DataplaneMsgToDeliverSeq)
func (*NullableDataplaneMsgToDeliverSeq) UnmarshalJSON ¶
func (v *NullableDataplaneMsgToDeliverSeq) UnmarshalJSON(src []byte) error
func (*NullableDataplaneMsgToDeliverSeq) Unset ¶
func (v *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 (v NullableGoutilsErrorDetail) Get() *GoutilsErrorDetail
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 (v *NullableGoutilsErrorDetail) Set(val *GoutilsErrorDetail)
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 (v NullableGoutilsRestAPIBaseResponse) Get() *GoutilsRestAPIBaseResponse
func (NullableGoutilsRestAPIBaseResponse) IsSet ¶ added in v0.4.0
func (v NullableGoutilsRestAPIBaseResponse) IsSet() bool
func (NullableGoutilsRestAPIBaseResponse) MarshalJSON ¶ added in v0.4.0
func (v NullableGoutilsRestAPIBaseResponse) MarshalJSON() ([]byte, error)
func (*NullableGoutilsRestAPIBaseResponse) Set ¶ added in v0.4.0
func (v *NullableGoutilsRestAPIBaseResponse) Set(val *GoutilsRestAPIBaseResponse)
func (*NullableGoutilsRestAPIBaseResponse) UnmarshalJSON ¶ added in v0.4.0
func (v *NullableGoutilsRestAPIBaseResponse) UnmarshalJSON(src []byte) error
func (*NullableGoutilsRestAPIBaseResponse) Unset ¶ added in v0.4.0
func (v *NullableGoutilsRestAPIBaseResponse) Unset()
type NullableInt ¶
type NullableInt struct {
// contains filtered or unexported fields
}
func NewNullableInt ¶
func NewNullableInt(val *int) *NullableInt
func (NullableInt) Get ¶
func (v NullableInt) Get() *int
func (NullableInt) IsSet ¶
func (v NullableInt) IsSet() bool
func (NullableInt) MarshalJSON ¶
func (v NullableInt) MarshalJSON() ([]byte, error)
func (*NullableInt) Set ¶
func (v *NullableInt) Set(val *int)
func (*NullableInt) UnmarshalJSON ¶
func (v *NullableInt) UnmarshalJSON(src []byte) error
func (*NullableInt) Unset ¶
func (v *NullableInt) Unset()
type NullableInt32 ¶
type NullableInt32 struct {
// contains filtered or unexported fields
}
func NewNullableInt32 ¶
func NewNullableInt32(val *int32) *NullableInt32
func (NullableInt32) Get ¶
func (v NullableInt32) Get() *int32
func (NullableInt32) IsSet ¶
func (v NullableInt32) IsSet() bool
func (NullableInt32) MarshalJSON ¶
func (v NullableInt32) MarshalJSON() ([]byte, error)
func (*NullableInt32) Set ¶
func (v *NullableInt32) Set(val *int32)
func (*NullableInt32) UnmarshalJSON ¶
func (v *NullableInt32) UnmarshalJSON(src []byte) error
func (*NullableInt32) Unset ¶
func (v *NullableInt32) Unset()
type NullableInt64 ¶
type NullableInt64 struct {
// contains filtered or unexported fields
}
func NewNullableInt64 ¶
func NewNullableInt64(val *int64) *NullableInt64
func (NullableInt64) Get ¶
func (v NullableInt64) Get() *int64
func (NullableInt64) IsSet ¶
func (v NullableInt64) IsSet() bool
func (NullableInt64) MarshalJSON ¶
func (v NullableInt64) MarshalJSON() ([]byte, error)
func (*NullableInt64) Set ¶
func (v *NullableInt64) Set(val *int64)
func (*NullableInt64) UnmarshalJSON ¶
func (v *NullableInt64) UnmarshalJSON(src []byte) error
func (*NullableInt64) Unset ¶
func (v *NullableInt64) Unset()
type NullableManagementJSStreamLimits ¶
type NullableManagementJSStreamLimits struct {
// contains filtered or unexported fields
}
func NewNullableManagementJSStreamLimits ¶
func NewNullableManagementJSStreamLimits(val *ManagementJSStreamLimits) *NullableManagementJSStreamLimits
func (NullableManagementJSStreamLimits) Get ¶
func (v NullableManagementJSStreamLimits) Get() *ManagementJSStreamLimits
func (NullableManagementJSStreamLimits) IsSet ¶
func (v NullableManagementJSStreamLimits) IsSet() bool
func (NullableManagementJSStreamLimits) MarshalJSON ¶
func (v NullableManagementJSStreamLimits) MarshalJSON() ([]byte, error)
func (*NullableManagementJSStreamLimits) Set ¶
func (v *NullableManagementJSStreamLimits) Set(val *ManagementJSStreamLimits)
func (*NullableManagementJSStreamLimits) UnmarshalJSON ¶
func (v *NullableManagementJSStreamLimits) UnmarshalJSON(src []byte) error
func (*NullableManagementJSStreamLimits) Unset ¶
func (v *NullableManagementJSStreamLimits) Unset()
type NullableManagementJSStreamParam ¶
type NullableManagementJSStreamParam struct {
// contains filtered or unexported fields
}
func NewNullableManagementJSStreamParam ¶
func NewNullableManagementJSStreamParam(val *ManagementJSStreamParam) *NullableManagementJSStreamParam
func (NullableManagementJSStreamParam) Get ¶
func (v NullableManagementJSStreamParam) Get() *ManagementJSStreamParam
func (NullableManagementJSStreamParam) IsSet ¶
func (v NullableManagementJSStreamParam) IsSet() bool
func (NullableManagementJSStreamParam) MarshalJSON ¶
func (v NullableManagementJSStreamParam) MarshalJSON() ([]byte, error)
func (*NullableManagementJSStreamParam) Set ¶
func (v *NullableManagementJSStreamParam) Set(val *ManagementJSStreamParam)
func (*NullableManagementJSStreamParam) UnmarshalJSON ¶
func (v *NullableManagementJSStreamParam) UnmarshalJSON(src []byte) error
func (*NullableManagementJSStreamParam) Unset ¶
func (v *NullableManagementJSStreamParam) Unset()
type NullableManagementJetStreamConsumerParam ¶
type NullableManagementJetStreamConsumerParam struct {
// contains filtered or unexported fields
}
func NewNullableManagementJetStreamConsumerParam ¶
func NewNullableManagementJetStreamConsumerParam(val *ManagementJetStreamConsumerParam) *NullableManagementJetStreamConsumerParam
func (NullableManagementJetStreamConsumerParam) IsSet ¶
func (v NullableManagementJetStreamConsumerParam) IsSet() bool
func (NullableManagementJetStreamConsumerParam) MarshalJSON ¶
func (v NullableManagementJetStreamConsumerParam) MarshalJSON() ([]byte, error)
func (*NullableManagementJetStreamConsumerParam) Set ¶
func (v *NullableManagementJetStreamConsumerParam) Set(val *ManagementJetStreamConsumerParam)
func (*NullableManagementJetStreamConsumerParam) UnmarshalJSON ¶
func (v *NullableManagementJetStreamConsumerParam) UnmarshalJSON(src []byte) error
func (*NullableManagementJetStreamConsumerParam) Unset ¶
func (v *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
type ServerVariable ¶
ServerVariable stores the information about a server variable
Source Files ¶
- api_dataplane.go
- api_management.go
- client.go
- configuration.go
- model_apis_api_rest_req_stream_subjects.go
- model_apis_api_rest_resp_all_jet_stream_consumers.go
- model_apis_api_rest_resp_all_jet_streams.go
- model_apis_api_rest_resp_consumer_config.go
- model_apis_api_rest_resp_consumer_info.go
- model_apis_api_rest_resp_data_message.go
- model_apis_api_rest_resp_one_jet_stream.go
- model_apis_api_rest_resp_one_jet_stream_consumer.go
- model_apis_api_rest_resp_sequence_info.go
- model_apis_api_rest_resp_stream_config.go
- model_apis_api_rest_resp_stream_info.go
- model_apis_api_rest_resp_stream_state.go
- model_dataplane_ack_seq_num.go
- model_dataplane_msg_to_deliver_seq.go
- model_goutils_error_detail.go
- model_goutils_rest_api_base_response.go
- model_management_jet_stream_consumer_param.go
- model_management_js_stream_limits.go
- model_management_js_stream_param.go
- response.go
- utils.go