api

package
v0.0.0-...-6b0c346 Latest Latest
Warning

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

Go to latest
Published: Jun 16, 2026 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Overview

Code generated by ogen, DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

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

Client implements OAS client.

func NewClient

func NewClient(serverURL string, opts ...ClientOption) (*Client, error)

NewClient initializes new Client defined by OAS.

func (*Client) V2StreamRecentchangeGet

func (c *Client) V2StreamRecentchangeGet(ctx context.Context, params V2StreamRecentchangeGetParams, options ...RequestOption) (V2StreamRecentchangeGetRes, error)

V2StreamRecentchangeGet invokes GET /v2/stream/recentchange operation.

Mediawiki.recentchange events.

(NOTE: This stream is an alias of mediawiki.recentchange)

Schema title: mediawiki/recentchange.

GET /v2/stream/recentchange

type ClientOption

type ClientOption interface {
	// contains filtered or unexported methods
}

ClientOption is client config option.

func WithClient

func WithClient(client ht.Client) ClientOption

WithClient specifies http client to use.

func WithRequestEditor

func WithRequestEditor(fn RequestEditor) ClientOption

WithRequestEditor allows setting up a callback function, which will be called right before sending the request. This can be used to mutate the request.

func WithResponseEditor

func WithResponseEditor(fn ResponseEditor) ClientOption

WithResponseEditor allows setting up a callback function, which will be called right after receiving the response. This can be used to mutate the response.

func WithSSEClientOptions

func WithSSEClientOptions(opts ...SSEClientOption) ClientOption

WithSSEClientOptions configures default SSE client behavior.

type Invoker

type Invoker interface {
	// V2StreamRecentchangeGet invokes GET /v2/stream/recentchange operation.
	//
	// Mediawiki.recentchange events.
	//
	// (NOTE: This stream is an alias of mediawiki.recentchange)
	//
	// Schema title: mediawiki/recentchange.
	//
	// GET /v2/stream/recentchange
	V2StreamRecentchangeGet(ctx context.Context, params V2StreamRecentchangeGetParams, options ...RequestOption) (V2StreamRecentchangeGetRes, error)
}

Invoker invokes operations described by OpenAPI v3 specification.

type OperationName

type OperationName = string

OperationName is the ogen operation name

const (
	V2StreamRecentchangeGetOperation OperationName = "V2StreamRecentchangeGet"
)

type OptBool

type OptBool struct {
	Value bool
	Set   bool
}

OptBool is optional bool.

func NewOptBool

func NewOptBool(v bool) OptBool

NewOptBool returns new OptBool with value set to v.

func (*OptBool) Decode

func (o *OptBool) Decode(d *jx.Decoder) error

Decode decodes bool from json.

func (OptBool) Encode

func (o OptBool) Encode(e *jx.Encoder)

Encode encodes bool as json.

func (OptBool) Get

func (o OptBool) Get() (v bool, ok bool)

Get returns value and boolean that denotes whether value was set.

func (OptBool) IsSet

func (o OptBool) IsSet() bool

IsSet returns true if OptBool was set.

func (OptBool) MarshalJSON

func (s OptBool) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (OptBool) Or

func (o OptBool) Or(d bool) bool

Or returns value if set, or given parameter if does not.

func (*OptBool) Reset

func (o *OptBool) Reset()

Reset unsets value.

func (*OptBool) SetTo

func (o *OptBool) SetTo(v bool)

SetTo sets value to v.

func (*OptBool) UnmarshalJSON

func (s *OptBool) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

type OptInt

type OptInt struct {
	Value int
	Set   bool
}

OptInt is optional int.

func NewOptInt

func NewOptInt(v int) OptInt

NewOptInt returns new OptInt with value set to v.

func (*OptInt) Decode

func (o *OptInt) Decode(d *jx.Decoder) error

Decode decodes int from json.

func (OptInt) Encode

func (o OptInt) Encode(e *jx.Encoder)

Encode encodes int as json.

func (OptInt) Get

func (o OptInt) Get() (v int, ok bool)

Get returns value and boolean that denotes whether value was set.

func (OptInt) IsSet

func (o OptInt) IsSet() bool

IsSet returns true if OptInt was set.

func (OptInt) MarshalJSON

func (s OptInt) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (OptInt) Or

func (o OptInt) Or(d int) int

Or returns value if set, or given parameter if does not.

func (*OptInt) Reset

func (o *OptInt) Reset()

Reset unsets value.

func (*OptInt) SetTo

func (o *OptInt) SetTo(v int)

SetTo sets value to v.

func (*OptInt) UnmarshalJSON

func (s *OptInt) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

type OptNilInt

type OptNilInt struct {
	Value int
	Set   bool
	Null  bool
}

OptNilInt is optional nullable int.

func NewOptNilInt

func NewOptNilInt(v int) OptNilInt

NewOptNilInt returns new OptNilInt with value set to v.

func (*OptNilInt) Decode

func (o *OptNilInt) Decode(d *jx.Decoder) error

Decode decodes int from json.

func (OptNilInt) Encode

func (o OptNilInt) Encode(e *jx.Encoder)

Encode encodes int as json.

func (OptNilInt) Get

func (o OptNilInt) Get() (v int, ok bool)

Get returns value and boolean that denotes whether value was set.

func (OptNilInt) IsEmpty

func (o OptNilInt) IsEmpty() bool

IsEmpty returns true if the field was omitted from the payload (not Set and not Null).

func (OptNilInt) IsNull

func (o OptNilInt) IsNull() bool

IsNull returns true if value is Null.

func (OptNilInt) IsSet

func (o OptNilInt) IsSet() bool

IsSet returns true if OptNilInt was set.

func (OptNilInt) MarshalJSON

func (s OptNilInt) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (OptNilInt) Or

func (o OptNilInt) Or(d int) int

Or returns value if set, or given parameter if does not.

func (*OptNilInt) Reset

func (o *OptNilInt) Reset()

Reset unsets value.

func (*OptNilInt) SetTo

func (o *OptNilInt) SetTo(v int)

SetTo sets value to v.

func (*OptNilInt) SetToNull

func (o *OptNilInt) SetToNull()

SetToNull sets value to null.

func (*OptNilInt) UnmarshalJSON

func (s *OptNilInt) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

type OptNilString

type OptNilString struct {
	Value string
	Set   bool
	Null  bool
}

OptNilString is optional nullable string.

func NewOptNilString

func NewOptNilString(v string) OptNilString

NewOptNilString returns new OptNilString with value set to v.

func (*OptNilString) Decode

func (o *OptNilString) Decode(d *jx.Decoder) error

Decode decodes string from json.

func (OptNilString) Encode

func (o OptNilString) Encode(e *jx.Encoder)

Encode encodes string as json.

func (OptNilString) Get

func (o OptNilString) Get() (v string, ok bool)

Get returns value and boolean that denotes whether value was set.

func (OptNilString) IsEmpty

func (o OptNilString) IsEmpty() bool

IsEmpty returns true if the field was omitted from the payload (not Set and not Null).

func (OptNilString) IsNull

func (o OptNilString) IsNull() bool

IsNull returns true if value is Null.

func (OptNilString) IsSet

func (o OptNilString) IsSet() bool

IsSet returns true if OptNilString was set.

func (OptNilString) MarshalJSON

func (s OptNilString) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (OptNilString) Or

func (o OptNilString) Or(d string) string

Or returns value if set, or given parameter if does not.

func (*OptNilString) Reset

func (o *OptNilString) Reset()

Reset unsets value.

func (*OptNilString) SetTo

func (o *OptNilString) SetTo(v string)

SetTo sets value to v.

func (*OptNilString) SetToNull

func (o *OptNilString) SetToNull()

SetToNull sets value to null.

func (*OptNilString) UnmarshalJSON

func (s *OptNilString) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

type OptString

type OptString struct {
	Value string
	Set   bool
}

OptString is optional string.

func NewOptString

func NewOptString(v string) OptString

NewOptString returns new OptString with value set to v.

func (*OptString) Decode

func (o *OptString) Decode(d *jx.Decoder) error

Decode decodes string from json.

func (OptString) Encode

func (o OptString) Encode(e *jx.Encoder)

Encode encodes string as json.

func (OptString) Get

func (o OptString) Get() (v string, ok bool)

Get returns value and boolean that denotes whether value was set.

func (OptString) IsSet

func (o OptString) IsSet() bool

IsSet returns true if OptString was set.

func (OptString) MarshalJSON

func (s OptString) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (OptString) Or

func (o OptString) Or(d string) string

Or returns value if set, or given parameter if does not.

func (*OptString) Reset

func (o *OptString) Reset()

Reset unsets value.

func (*OptString) SetTo

func (o *OptString) SetTo(v string)

SetTo sets value to v.

func (*OptString) UnmarshalJSON

func (s *OptString) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

type OptV2StreamRecentchangeGetOKApplicationJSONLength

type OptV2StreamRecentchangeGetOKApplicationJSONLength struct {
	Value V2StreamRecentchangeGetOKApplicationJSONLength
	Set   bool
}

OptV2StreamRecentchangeGetOKApplicationJSONLength is optional V2StreamRecentchangeGetOKApplicationJSONLength.

func NewOptV2StreamRecentchangeGetOKApplicationJSONLength

func NewOptV2StreamRecentchangeGetOKApplicationJSONLength(v V2StreamRecentchangeGetOKApplicationJSONLength) OptV2StreamRecentchangeGetOKApplicationJSONLength

NewOptV2StreamRecentchangeGetOKApplicationJSONLength returns new OptV2StreamRecentchangeGetOKApplicationJSONLength with value set to v.

func (*OptV2StreamRecentchangeGetOKApplicationJSONLength) Decode

Decode decodes V2StreamRecentchangeGetOKApplicationJSONLength from json.

func (OptV2StreamRecentchangeGetOKApplicationJSONLength) Encode

Encode encodes V2StreamRecentchangeGetOKApplicationJSONLength as json.

func (OptV2StreamRecentchangeGetOKApplicationJSONLength) Get

Get returns value and boolean that denotes whether value was set.

func (OptV2StreamRecentchangeGetOKApplicationJSONLength) IsSet

IsSet returns true if OptV2StreamRecentchangeGetOKApplicationJSONLength was set.

func (OptV2StreamRecentchangeGetOKApplicationJSONLength) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (OptV2StreamRecentchangeGetOKApplicationJSONLength) Or

Or returns value if set, or given parameter if does not.

func (*OptV2StreamRecentchangeGetOKApplicationJSONLength) Reset

Reset unsets value.

func (*OptV2StreamRecentchangeGetOKApplicationJSONLength) SetTo

SetTo sets value to v.

func (*OptV2StreamRecentchangeGetOKApplicationJSONLength) UnmarshalJSON

UnmarshalJSON implements stdjson.Unmarshaler.

type OptV2StreamRecentchangeGetOKApplicationJSONLogParams

type OptV2StreamRecentchangeGetOKApplicationJSONLogParams struct {
	Value V2StreamRecentchangeGetOKApplicationJSONLogParams
	Set   bool
}

OptV2StreamRecentchangeGetOKApplicationJSONLogParams is optional V2StreamRecentchangeGetOKApplicationJSONLogParams.

func NewOptV2StreamRecentchangeGetOKApplicationJSONLogParams

NewOptV2StreamRecentchangeGetOKApplicationJSONLogParams returns new OptV2StreamRecentchangeGetOKApplicationJSONLogParams with value set to v.

func (*OptV2StreamRecentchangeGetOKApplicationJSONLogParams) Decode

Decode decodes V2StreamRecentchangeGetOKApplicationJSONLogParams from json.

func (OptV2StreamRecentchangeGetOKApplicationJSONLogParams) Encode

Encode encodes V2StreamRecentchangeGetOKApplicationJSONLogParams as json.

func (OptV2StreamRecentchangeGetOKApplicationJSONLogParams) Get

Get returns value and boolean that denotes whether value was set.

func (OptV2StreamRecentchangeGetOKApplicationJSONLogParams) IsSet

IsSet returns true if OptV2StreamRecentchangeGetOKApplicationJSONLogParams was set.

func (OptV2StreamRecentchangeGetOKApplicationJSONLogParams) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (OptV2StreamRecentchangeGetOKApplicationJSONLogParams) Or

Or returns value if set, or given parameter if does not.

func (*OptV2StreamRecentchangeGetOKApplicationJSONLogParams) Reset

Reset unsets value.

func (*OptV2StreamRecentchangeGetOKApplicationJSONLogParams) SetTo

SetTo sets value to v.

func (*OptV2StreamRecentchangeGetOKApplicationJSONLogParams) UnmarshalJSON

UnmarshalJSON implements stdjson.Unmarshaler.

type OptV2StreamRecentchangeGetOKApplicationJSONRevision

type OptV2StreamRecentchangeGetOKApplicationJSONRevision struct {
	Value V2StreamRecentchangeGetOKApplicationJSONRevision
	Set   bool
}

OptV2StreamRecentchangeGetOKApplicationJSONRevision is optional V2StreamRecentchangeGetOKApplicationJSONRevision.

func NewOptV2StreamRecentchangeGetOKApplicationJSONRevision

func NewOptV2StreamRecentchangeGetOKApplicationJSONRevision(v V2StreamRecentchangeGetOKApplicationJSONRevision) OptV2StreamRecentchangeGetOKApplicationJSONRevision

NewOptV2StreamRecentchangeGetOKApplicationJSONRevision returns new OptV2StreamRecentchangeGetOKApplicationJSONRevision with value set to v.

func (*OptV2StreamRecentchangeGetOKApplicationJSONRevision) Decode

Decode decodes V2StreamRecentchangeGetOKApplicationJSONRevision from json.

func (OptV2StreamRecentchangeGetOKApplicationJSONRevision) Encode

Encode encodes V2StreamRecentchangeGetOKApplicationJSONRevision as json.

func (OptV2StreamRecentchangeGetOKApplicationJSONRevision) Get

Get returns value and boolean that denotes whether value was set.

func (OptV2StreamRecentchangeGetOKApplicationJSONRevision) IsSet

IsSet returns true if OptV2StreamRecentchangeGetOKApplicationJSONRevision was set.

func (OptV2StreamRecentchangeGetOKApplicationJSONRevision) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (OptV2StreamRecentchangeGetOKApplicationJSONRevision) Or

Or returns value if set, or given parameter if does not.

func (*OptV2StreamRecentchangeGetOKApplicationJSONRevision) Reset

Reset unsets value.

func (*OptV2StreamRecentchangeGetOKApplicationJSONRevision) SetTo

SetTo sets value to v.

func (*OptV2StreamRecentchangeGetOKApplicationJSONRevision) UnmarshalJSON

UnmarshalJSON implements stdjson.Unmarshaler.

type OptV2StreamRecentchangeGetOKTextEventStreamEventDataLength

type OptV2StreamRecentchangeGetOKTextEventStreamEventDataLength struct {
	Value V2StreamRecentchangeGetOKTextEventStreamEventDataLength
	Set   bool
}

OptV2StreamRecentchangeGetOKTextEventStreamEventDataLength is optional V2StreamRecentchangeGetOKTextEventStreamEventDataLength.

func NewOptV2StreamRecentchangeGetOKTextEventStreamEventDataLength

NewOptV2StreamRecentchangeGetOKTextEventStreamEventDataLength returns new OptV2StreamRecentchangeGetOKTextEventStreamEventDataLength with value set to v.

func (*OptV2StreamRecentchangeGetOKTextEventStreamEventDataLength) Decode

Decode decodes V2StreamRecentchangeGetOKTextEventStreamEventDataLength from json.

func (OptV2StreamRecentchangeGetOKTextEventStreamEventDataLength) Encode

Encode encodes V2StreamRecentchangeGetOKTextEventStreamEventDataLength as json.

func (OptV2StreamRecentchangeGetOKTextEventStreamEventDataLength) Get

Get returns value and boolean that denotes whether value was set.

func (OptV2StreamRecentchangeGetOKTextEventStreamEventDataLength) IsSet

IsSet returns true if OptV2StreamRecentchangeGetOKTextEventStreamEventDataLength was set.

func (OptV2StreamRecentchangeGetOKTextEventStreamEventDataLength) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (OptV2StreamRecentchangeGetOKTextEventStreamEventDataLength) Or

Or returns value if set, or given parameter if does not.

func (*OptV2StreamRecentchangeGetOKTextEventStreamEventDataLength) Reset

Reset unsets value.

func (*OptV2StreamRecentchangeGetOKTextEventStreamEventDataLength) SetTo

SetTo sets value to v.

func (*OptV2StreamRecentchangeGetOKTextEventStreamEventDataLength) UnmarshalJSON

UnmarshalJSON implements stdjson.Unmarshaler.

type OptV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams

type OptV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams struct {
	Value V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams
	Set   bool
}

OptV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams is optional V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams.

func NewOptV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams

NewOptV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams returns new OptV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams with value set to v.

func (*OptV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) Decode

Decode decodes V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams from json.

func (OptV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) Encode

Encode encodes V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams as json.

func (OptV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) Get

Get returns value and boolean that denotes whether value was set.

func (OptV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) IsSet

IsSet returns true if OptV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams was set.

func (OptV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (OptV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) Or

Or returns value if set, or given parameter if does not.

func (*OptV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) Reset

Reset unsets value.

func (*OptV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) SetTo

SetTo sets value to v.

func (*OptV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) UnmarshalJSON

UnmarshalJSON implements stdjson.Unmarshaler.

type OptV2StreamRecentchangeGetOKTextEventStreamEventDataRevision

type OptV2StreamRecentchangeGetOKTextEventStreamEventDataRevision struct {
	Value V2StreamRecentchangeGetOKTextEventStreamEventDataRevision
	Set   bool
}

OptV2StreamRecentchangeGetOKTextEventStreamEventDataRevision is optional V2StreamRecentchangeGetOKTextEventStreamEventDataRevision.

func NewOptV2StreamRecentchangeGetOKTextEventStreamEventDataRevision

NewOptV2StreamRecentchangeGetOKTextEventStreamEventDataRevision returns new OptV2StreamRecentchangeGetOKTextEventStreamEventDataRevision with value set to v.

func (*OptV2StreamRecentchangeGetOKTextEventStreamEventDataRevision) Decode

Decode decodes V2StreamRecentchangeGetOKTextEventStreamEventDataRevision from json.

func (OptV2StreamRecentchangeGetOKTextEventStreamEventDataRevision) Encode

Encode encodes V2StreamRecentchangeGetOKTextEventStreamEventDataRevision as json.

func (OptV2StreamRecentchangeGetOKTextEventStreamEventDataRevision) Get

Get returns value and boolean that denotes whether value was set.

func (OptV2StreamRecentchangeGetOKTextEventStreamEventDataRevision) IsSet

IsSet returns true if OptV2StreamRecentchangeGetOKTextEventStreamEventDataRevision was set.

func (OptV2StreamRecentchangeGetOKTextEventStreamEventDataRevision) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (OptV2StreamRecentchangeGetOKTextEventStreamEventDataRevision) Or

Or returns value if set, or given parameter if does not.

func (*OptV2StreamRecentchangeGetOKTextEventStreamEventDataRevision) Reset

Reset unsets value.

func (*OptV2StreamRecentchangeGetOKTextEventStreamEventDataRevision) SetTo

SetTo sets value to v.

func (*OptV2StreamRecentchangeGetOKTextEventStreamEventDataRevision) UnmarshalJSON

UnmarshalJSON implements stdjson.Unmarshaler.

type Option

type Option interface {
	ClientOption
}

Option is config option.

func WithAttributes

func WithAttributes(attributes ...attribute.KeyValue) Option

WithAttributes specifies default otel attributes.

func WithMeterProvider

func WithMeterProvider(provider metric.MeterProvider) Option

WithMeterProvider specifies a meter provider to use for creating a meter.

If none is specified, the otel.GetMeterProvider() is used.

func WithTracerProvider

func WithTracerProvider(provider trace.TracerProvider) Option

WithTracerProvider specifies a tracer provider to use for creating a tracer.

If none is specified, the global provider is used.

type RequestEditor

type RequestEditor func(ctx context.Context, req *http.Request) error

RequestEditor is the function signature for the RequestEditor callback function

type RequestOption

type RequestOption func(cfg *requestConfig)

RequestOption defines options for request.

func WithEditRequest

func WithEditRequest(fn func(req *http.Request) error) RequestOption

WithEditRequest sets function to edit request.

func WithEditResponse

func WithEditResponse(fn func(resp *http.Response) error) RequestOption

WithEditResponse sets function to edit response.

func WithRequestClient

func WithRequestClient(client ht.Client) RequestOption

WithRequestClient sets client for request.

func WithRequestSSEOptions

func WithRequestSSEOptions(opts ...SSEClientOption) RequestOption

WithRequestSSEOptions configures SSE behavior for request.

func WithServerURL

func WithServerURL(u *url.URL) RequestOption

WithServerURL sets client for request.

type ResponseEditor

type ResponseEditor func(ctx context.Context, resp *http.Response) error

ResponseEditor is the function signature for the ResponseEditor callback function

type SSEClientOption

type SSEClientOption func(*sseClientConfig)

func WithSSEInitialBufferCap

func WithSSEInitialBufferCap(n int) SSEClientOption

WithSSEInitialBufferCap sets the initial decoder line buffer capacity.

func WithSSELastEventID

func WithSSELastEventID(lastEventID string) SSEClientOption

WithSSELastEventID sets the initial lastEventID value for the stream.

func WithSSEMaxEventSize

func WithSSEMaxEventSize(n int) SSEClientOption

WithSSEMaxEventSize sets the maximum parsable SSE event size in bytes.

Zero disables the limit.

func WithSSEMaxRetries

func WithSSEMaxRetries(n int) SSEClientOption

WithSSEMaxRetries sets the maximum number of reconnect attempts.

Zero sets unlimited reconnect attempts.

func WithSSERetry

func WithSSERetry(delay time.Duration) SSEClientOption

WithSSERetry sets the initial SSE reconnect delay.

func WithSSERetryErrorHandler

func WithSSERetryErrorHandler(h sse.RetryErrorHandler) SSEClientOption

WithSSERetryErrorHandler sets the callback invoked after a reconnect attempt fails.

type V2StreamRecentchangeGetOKApplicationJSON

type V2StreamRecentchangeGetOKApplicationJSON struct {
	// Full page name, from Title::getPrefixedText.
	Title OptString `json:"title"`
	// A URI identifying the JSONSchema for this event. This should match an schema's $id in a schema
	// repository. E.g. /schema/title/1.0.0.
	Schema string `json:"$schema"`
	// Type of recentchange event (rc_type). One of "edit", "new", "log", "categorize", or "external"; or a
	// number. (See Manual:Recentchanges table#rc_type).
	Type OptString `json:"type"`
	// (rc_bot).
	Bot OptBool `json:"bot"`
	// (rc_comment).
	Comment OptString `json:"comment"`
	// ID of the recentchange event (rcid).
	ID OptNilInt `json:"id"`
	// Length of old and new change.
	Length OptV2StreamRecentchangeGetOKApplicationJSONLength `json:"length"`
	// (rc_log_action).
	LogAction        OptString    `json:"log_action"`
	LogActionComment OptNilString `json:"log_action_comment"`
	// (rc_log_id).
	LogID OptNilInt `json:"log_id"`
	// Property only exists if event has rc_params.
	LogParams OptV2StreamRecentchangeGetOKApplicationJSONLogParams `json:"log_params"`
	// (rc_log_type).
	LogType OptNilString                                 `json:"log_type"`
	Meta    V2StreamRecentchangeGetOKApplicationJSONMeta `json:"meta"`
	// (rc_minor).
	Minor OptBool `json:"minor"`
	// ID of relevant namespace of affected page (rc_namespace, page_namespace). This is -1 ("Special") for
	// log events.
	Namespace OptInt `json:"namespace"`
	// The rc_comment parsed into simple HTML. Optional.
	Parsedcomment OptString `json:"parsedcomment"`
	// (rc_patrolled). This property only exists if patrolling is supported for this event (based on
	// $wgUseRCPatrol, $wgUseNPPatrol).
	Patrolled OptBool `json:"patrolled"`
	// Old and new revision IDs.
	Revision OptV2StreamRecentchangeGetOKApplicationJSONRevision `json:"revision"`
	// $wgServerName.
	ServerName OptString `json:"server_name"`
	// $wgScriptPath.
	ServerScriptPath OptString `json:"server_script_path"`
	// $wgCanonicalServer.
	ServerURL OptString `json:"server_url"`
	// Unix timestamp (derived from rc_timestamp).
	Timestamp OptInt `json:"timestamp"`
	// (rc_user_text).
	User OptString `json:"user"`
	// WfWikiID ($wgDBprefix, $wgDBname).
	Wiki            OptString `json:"wiki"`
	AdditionalProps V2StreamRecentchangeGetOKApplicationJSONAdditional
}

Represents a MW RecentChange event. https://www.mediawiki.org/wiki/Manual:RCFeed.

func (*V2StreamRecentchangeGetOKApplicationJSON) Decode

Decode decodes V2StreamRecentchangeGetOKApplicationJSON from json.

func (*V2StreamRecentchangeGetOKApplicationJSON) Encode

Encode implements json.Marshaler.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetAdditionalProps

GetAdditionalProps returns the value of AdditionalProps.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetBot

GetBot returns the value of Bot.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetComment

GetComment returns the value of Comment.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetID

GetID returns the value of ID.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetLength

GetLength returns the value of Length.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetLogAction

GetLogAction returns the value of LogAction.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetLogActionComment

func (s *V2StreamRecentchangeGetOKApplicationJSON) GetLogActionComment() OptNilString

GetLogActionComment returns the value of LogActionComment.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetLogID

GetLogID returns the value of LogID.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetLogParams

GetLogParams returns the value of LogParams.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetLogType

GetLogType returns the value of LogType.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetMeta

GetMeta returns the value of Meta.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetMinor

GetMinor returns the value of Minor.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetNamespace

GetNamespace returns the value of Namespace.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetParsedcomment

GetParsedcomment returns the value of Parsedcomment.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetPatrolled

GetPatrolled returns the value of Patrolled.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetRevision

GetRevision returns the value of Revision.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetSchema

GetSchema returns the value of Schema.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetServerName

GetServerName returns the value of ServerName.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetServerScriptPath

func (s *V2StreamRecentchangeGetOKApplicationJSON) GetServerScriptPath() OptString

GetServerScriptPath returns the value of ServerScriptPath.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetServerURL

GetServerURL returns the value of ServerURL.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetTimestamp

GetTimestamp returns the value of Timestamp.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetTitle

GetTitle returns the value of Title.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetType

GetType returns the value of Type.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetUser

GetUser returns the value of User.

func (*V2StreamRecentchangeGetOKApplicationJSON) GetWiki

GetWiki returns the value of Wiki.

func (*V2StreamRecentchangeGetOKApplicationJSON) MarshalJSON

func (s *V2StreamRecentchangeGetOKApplicationJSON) MarshalJSON() ([]byte, error)

MarshalJSON implements stdjson.Marshaler.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetAdditionalProps

SetAdditionalProps sets the value of AdditionalProps.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetBot

SetBot sets the value of Bot.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetComment

SetComment sets the value of Comment.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetID

SetID sets the value of ID.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetLength

SetLength sets the value of Length.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetLogAction

SetLogAction sets the value of LogAction.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetLogActionComment

func (s *V2StreamRecentchangeGetOKApplicationJSON) SetLogActionComment(val OptNilString)

SetLogActionComment sets the value of LogActionComment.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetLogID

SetLogID sets the value of LogID.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetLogParams

SetLogParams sets the value of LogParams.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetLogType

SetLogType sets the value of LogType.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetMeta

SetMeta sets the value of Meta.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetMinor

SetMinor sets the value of Minor.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetNamespace

func (s *V2StreamRecentchangeGetOKApplicationJSON) SetNamespace(val OptInt)

SetNamespace sets the value of Namespace.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetParsedcomment

func (s *V2StreamRecentchangeGetOKApplicationJSON) SetParsedcomment(val OptString)

SetParsedcomment sets the value of Parsedcomment.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetPatrolled

SetPatrolled sets the value of Patrolled.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetRevision

SetRevision sets the value of Revision.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetSchema

SetSchema sets the value of Schema.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetServerName

SetServerName sets the value of ServerName.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetServerScriptPath

func (s *V2StreamRecentchangeGetOKApplicationJSON) SetServerScriptPath(val OptString)

SetServerScriptPath sets the value of ServerScriptPath.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetServerURL

SetServerURL sets the value of ServerURL.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetTimestamp

func (s *V2StreamRecentchangeGetOKApplicationJSON) SetTimestamp(val OptInt)

SetTimestamp sets the value of Timestamp.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetTitle

SetTitle sets the value of Title.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetType

SetType sets the value of Type.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetUser

SetUser sets the value of User.

func (*V2StreamRecentchangeGetOKApplicationJSON) SetWiki

SetWiki sets the value of Wiki.

func (*V2StreamRecentchangeGetOKApplicationJSON) UnmarshalJSON

func (s *V2StreamRecentchangeGetOKApplicationJSON) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

func (*V2StreamRecentchangeGetOKApplicationJSON) Validate

type V2StreamRecentchangeGetOKApplicationJSONAdditional

type V2StreamRecentchangeGetOKApplicationJSONAdditional map[string]jx.Raw

func (*V2StreamRecentchangeGetOKApplicationJSONAdditional) Decode

Decode decodes V2StreamRecentchangeGetOKApplicationJSONAdditional from json.

func (V2StreamRecentchangeGetOKApplicationJSONAdditional) Encode

Encode implements json.Marshaler.

func (V2StreamRecentchangeGetOKApplicationJSONAdditional) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (*V2StreamRecentchangeGetOKApplicationJSONAdditional) UnmarshalJSON

UnmarshalJSON implements stdjson.Unmarshaler.

type V2StreamRecentchangeGetOKApplicationJSONLength

type V2StreamRecentchangeGetOKApplicationJSONLength struct {
	// (rc_new_len).
	New OptNilInt `json:"new"`
	// (rc_old_len).
	Old OptNilInt `json:"old"`
}

Length of old and new change.

func (*V2StreamRecentchangeGetOKApplicationJSONLength) Decode

Decode decodes V2StreamRecentchangeGetOKApplicationJSONLength from json.

func (*V2StreamRecentchangeGetOKApplicationJSONLength) Encode

Encode implements json.Marshaler.

func (*V2StreamRecentchangeGetOKApplicationJSONLength) GetNew

GetNew returns the value of New.

func (*V2StreamRecentchangeGetOKApplicationJSONLength) GetOld

GetOld returns the value of Old.

func (*V2StreamRecentchangeGetOKApplicationJSONLength) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (*V2StreamRecentchangeGetOKApplicationJSONLength) SetNew

SetNew sets the value of New.

func (*V2StreamRecentchangeGetOKApplicationJSONLength) SetOld

SetOld sets the value of Old.

func (*V2StreamRecentchangeGetOKApplicationJSONLength) UnmarshalJSON

UnmarshalJSON implements stdjson.Unmarshaler.

type V2StreamRecentchangeGetOKApplicationJSONLogParams

type V2StreamRecentchangeGetOKApplicationJSONLogParams struct {
	// Type selects the active sum variant, switch on this field.
	Type                                               V2StreamRecentchangeGetOKApplicationJSONLogParamsType
	AnyArray                                           []jx.Raw
	V2StreamRecentchangeGetOKApplicationJSONLogParams1 V2StreamRecentchangeGetOKApplicationJSONLogParams1
	String                                             string
}

Property only exists if event has rc_params. V2StreamRecentchangeGetOKApplicationJSONLogParams represents sum type.

func NewAnyArrayV2StreamRecentchangeGetOKApplicationJSONLogParams

func NewAnyArrayV2StreamRecentchangeGetOKApplicationJSONLogParams(v []jx.Raw) V2StreamRecentchangeGetOKApplicationJSONLogParams

NewAnyArrayV2StreamRecentchangeGetOKApplicationJSONLogParams returns new V2StreamRecentchangeGetOKApplicationJSONLogParams from []jx.Raw.

func NewStringV2StreamRecentchangeGetOKApplicationJSONLogParams

func NewStringV2StreamRecentchangeGetOKApplicationJSONLogParams(v string) V2StreamRecentchangeGetOKApplicationJSONLogParams

NewStringV2StreamRecentchangeGetOKApplicationJSONLogParams returns new V2StreamRecentchangeGetOKApplicationJSONLogParams from string.

func NewV2StreamRecentchangeGetOKApplicationJSONLogParams1V2StreamRecentchangeGetOKApplicationJSONLogParams

func NewV2StreamRecentchangeGetOKApplicationJSONLogParams1V2StreamRecentchangeGetOKApplicationJSONLogParams(v V2StreamRecentchangeGetOKApplicationJSONLogParams1) V2StreamRecentchangeGetOKApplicationJSONLogParams

NewV2StreamRecentchangeGetOKApplicationJSONLogParams1V2StreamRecentchangeGetOKApplicationJSONLogParams returns new V2StreamRecentchangeGetOKApplicationJSONLogParams from V2StreamRecentchangeGetOKApplicationJSONLogParams1.

func (*V2StreamRecentchangeGetOKApplicationJSONLogParams) Decode

Decode decodes V2StreamRecentchangeGetOKApplicationJSONLogParams from json.

func (V2StreamRecentchangeGetOKApplicationJSONLogParams) Encode

Encode encodes V2StreamRecentchangeGetOKApplicationJSONLogParams as json.

func (V2StreamRecentchangeGetOKApplicationJSONLogParams) GetAnyArray

GetAnyArray returns []jx.Raw and true boolean if V2StreamRecentchangeGetOKApplicationJSONLogParams is []jx.Raw.

func (V2StreamRecentchangeGetOKApplicationJSONLogParams) GetString

GetString returns string and true boolean if V2StreamRecentchangeGetOKApplicationJSONLogParams is string.

func (V2StreamRecentchangeGetOKApplicationJSONLogParams) GetV2StreamRecentchangeGetOKApplicationJSONLogParams1

func (s V2StreamRecentchangeGetOKApplicationJSONLogParams) GetV2StreamRecentchangeGetOKApplicationJSONLogParams1() (v V2StreamRecentchangeGetOKApplicationJSONLogParams1, ok bool)

GetV2StreamRecentchangeGetOKApplicationJSONLogParams1 returns V2StreamRecentchangeGetOKApplicationJSONLogParams1 and true boolean if V2StreamRecentchangeGetOKApplicationJSONLogParams is V2StreamRecentchangeGetOKApplicationJSONLogParams1.

func (V2StreamRecentchangeGetOKApplicationJSONLogParams) IsAnyArray

IsAnyArray reports whether V2StreamRecentchangeGetOKApplicationJSONLogParams is []jx.Raw.

func (V2StreamRecentchangeGetOKApplicationJSONLogParams) IsString

IsString reports whether V2StreamRecentchangeGetOKApplicationJSONLogParams is string.

func (V2StreamRecentchangeGetOKApplicationJSONLogParams) IsV2StreamRecentchangeGetOKApplicationJSONLogParams1

func (s V2StreamRecentchangeGetOKApplicationJSONLogParams) IsV2StreamRecentchangeGetOKApplicationJSONLogParams1() bool

IsV2StreamRecentchangeGetOKApplicationJSONLogParams1 reports whether V2StreamRecentchangeGetOKApplicationJSONLogParams is V2StreamRecentchangeGetOKApplicationJSONLogParams1.

func (V2StreamRecentchangeGetOKApplicationJSONLogParams) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (*V2StreamRecentchangeGetOKApplicationJSONLogParams) SetAnyArray

SetAnyArray sets V2StreamRecentchangeGetOKApplicationJSONLogParams to []jx.Raw.

func (*V2StreamRecentchangeGetOKApplicationJSONLogParams) SetString

SetString sets V2StreamRecentchangeGetOKApplicationJSONLogParams to string.

func (*V2StreamRecentchangeGetOKApplicationJSONLogParams) SetV2StreamRecentchangeGetOKApplicationJSONLogParams1

func (s *V2StreamRecentchangeGetOKApplicationJSONLogParams) SetV2StreamRecentchangeGetOKApplicationJSONLogParams1(v V2StreamRecentchangeGetOKApplicationJSONLogParams1)

SetV2StreamRecentchangeGetOKApplicationJSONLogParams1 sets V2StreamRecentchangeGetOKApplicationJSONLogParams to V2StreamRecentchangeGetOKApplicationJSONLogParams1.

func (*V2StreamRecentchangeGetOKApplicationJSONLogParams) UnmarshalJSON

UnmarshalJSON implements stdjson.Unmarshaler.

func (V2StreamRecentchangeGetOKApplicationJSONLogParams) Validate

type V2StreamRecentchangeGetOKApplicationJSONLogParams1

type V2StreamRecentchangeGetOKApplicationJSONLogParams1 map[string]jx.Raw

func (*V2StreamRecentchangeGetOKApplicationJSONLogParams1) Decode

Decode decodes V2StreamRecentchangeGetOKApplicationJSONLogParams1 from json.

func (V2StreamRecentchangeGetOKApplicationJSONLogParams1) Encode

Encode implements json.Marshaler.

func (V2StreamRecentchangeGetOKApplicationJSONLogParams1) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (*V2StreamRecentchangeGetOKApplicationJSONLogParams1) UnmarshalJSON

UnmarshalJSON implements stdjson.Unmarshaler.

type V2StreamRecentchangeGetOKApplicationJSONLogParamsType

type V2StreamRecentchangeGetOKApplicationJSONLogParamsType string

V2StreamRecentchangeGetOKApplicationJSONLogParamsType is oneOf type of V2StreamRecentchangeGetOKApplicationJSONLogParams.

const (
	AnyArrayV2StreamRecentchangeGetOKApplicationJSONLogParams                                           V2StreamRecentchangeGetOKApplicationJSONLogParamsType = "[]jx.Raw"
	V2StreamRecentchangeGetOKApplicationJSONLogParams1V2StreamRecentchangeGetOKApplicationJSONLogParams V2StreamRecentchangeGetOKApplicationJSONLogParamsType = "V2StreamRecentchangeGetOKApplicationJSONLogParams1"
	StringV2StreamRecentchangeGetOKApplicationJSONLogParams                                             V2StreamRecentchangeGetOKApplicationJSONLogParamsType = "string"
)

Possible values for V2StreamRecentchangeGetOKApplicationJSONLogParamsType.

type V2StreamRecentchangeGetOKApplicationJSONMeta

type V2StreamRecentchangeGetOKApplicationJSONMeta struct {
	// Domain the event or entity pertains to.
	Domain OptString `json:"domain"`
	// UTC event datetime, in ISO-8601 format.
	Dt time.Time `json:"dt"`
	// Unique ID of this event.
	ID OptString `json:"id"`
	// Unique ID of the request that caused the event.
	RequestID OptString `json:"request_id"`
	// Name of the stream/queue/dataset that this event belongs in.
	Stream string `json:"stream"`
	// Unique URI identifying the event or entity.
	URI OptString `json:"uri"`
}

func (*V2StreamRecentchangeGetOKApplicationJSONMeta) Decode

Decode decodes V2StreamRecentchangeGetOKApplicationJSONMeta from json.

func (*V2StreamRecentchangeGetOKApplicationJSONMeta) Encode

Encode implements json.Marshaler.

func (*V2StreamRecentchangeGetOKApplicationJSONMeta) GetDomain

GetDomain returns the value of Domain.

func (*V2StreamRecentchangeGetOKApplicationJSONMeta) GetDt

GetDt returns the value of Dt.

func (*V2StreamRecentchangeGetOKApplicationJSONMeta) GetID

GetID returns the value of ID.

func (*V2StreamRecentchangeGetOKApplicationJSONMeta) GetRequestID

GetRequestID returns the value of RequestID.

func (*V2StreamRecentchangeGetOKApplicationJSONMeta) GetStream

GetStream returns the value of Stream.

func (*V2StreamRecentchangeGetOKApplicationJSONMeta) GetURI

GetURI returns the value of URI.

func (*V2StreamRecentchangeGetOKApplicationJSONMeta) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (*V2StreamRecentchangeGetOKApplicationJSONMeta) SetDomain

SetDomain sets the value of Domain.

func (*V2StreamRecentchangeGetOKApplicationJSONMeta) SetDt

SetDt sets the value of Dt.

func (*V2StreamRecentchangeGetOKApplicationJSONMeta) SetID

SetID sets the value of ID.

func (*V2StreamRecentchangeGetOKApplicationJSONMeta) SetRequestID

SetRequestID sets the value of RequestID.

func (*V2StreamRecentchangeGetOKApplicationJSONMeta) SetStream

SetStream sets the value of Stream.

func (*V2StreamRecentchangeGetOKApplicationJSONMeta) SetURI

SetURI sets the value of URI.

func (*V2StreamRecentchangeGetOKApplicationJSONMeta) UnmarshalJSON

func (s *V2StreamRecentchangeGetOKApplicationJSONMeta) UnmarshalJSON(data []byte) error

UnmarshalJSON implements stdjson.Unmarshaler.

func (*V2StreamRecentchangeGetOKApplicationJSONMeta) Validate

type V2StreamRecentchangeGetOKApplicationJSONRevision

type V2StreamRecentchangeGetOKApplicationJSONRevision struct {
	// (rc_last_oldid).
	New OptNilInt `json:"new"`
	// (rc_this_oldid).
	Old OptNilInt `json:"old"`
}

Old and new revision IDs.

func (*V2StreamRecentchangeGetOKApplicationJSONRevision) Decode

Decode decodes V2StreamRecentchangeGetOKApplicationJSONRevision from json.

func (*V2StreamRecentchangeGetOKApplicationJSONRevision) Encode

Encode implements json.Marshaler.

func (*V2StreamRecentchangeGetOKApplicationJSONRevision) GetNew

GetNew returns the value of New.

func (*V2StreamRecentchangeGetOKApplicationJSONRevision) GetOld

GetOld returns the value of Old.

func (*V2StreamRecentchangeGetOKApplicationJSONRevision) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (*V2StreamRecentchangeGetOKApplicationJSONRevision) SetNew

SetNew sets the value of New.

func (*V2StreamRecentchangeGetOKApplicationJSONRevision) SetOld

SetOld sets the value of Old.

func (*V2StreamRecentchangeGetOKApplicationJSONRevision) UnmarshalJSON

UnmarshalJSON implements stdjson.Unmarshaler.

type V2StreamRecentchangeGetOKTextEventStream

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

V2StreamRecentchangeGetOKTextEventStream is a Server-Sent Events response stream.

func (*V2StreamRecentchangeGetOKTextEventStream) All

All iterates over stream events until the stream is closed, reconnecting when needed.

func (*V2StreamRecentchangeGetOKTextEventStream) Close

Close closes the current stream and stops further reconnect attempts.

func (*V2StreamRecentchangeGetOKTextEventStream) Next

Next returns the next event from the stream, reconnecting when needed.

func (*V2StreamRecentchangeGetOKTextEventStream) State

func (s *V2StreamRecentchangeGetOKTextEventStream) State() (state sse.State, latestErr error)

State returns the current stream state and the latest terminal or current reconnect error.

type V2StreamRecentchangeGetOKTextEventStreamClient

type V2StreamRecentchangeGetOKTextEventStreamClient interface {
	sse.Client[V2StreamRecentchangeGetOKTextEventStreamEvent]
}

V2StreamRecentchangeGetOKTextEventStreamClient reads events from the V2StreamRecentchangeGetOKTextEventStream SSE stream.

type V2StreamRecentchangeGetOKTextEventStreamEvent

type V2StreamRecentchangeGetOKTextEventStreamEvent struct {
	ID    string                                            `json:"id"`
	Type  string                                            `json:"event"`
	Data  V2StreamRecentchangeGetOKTextEventStreamEventData `json:"data"`
	Retry OptInt                                            `json:"retry"`
}

V2StreamRecentchangeGetOKTextEventStreamEvent is a parsed Server-Sent Event.

func (*V2StreamRecentchangeGetOKTextEventStreamEvent) GetData

GetData returns the value of Data.

func (*V2StreamRecentchangeGetOKTextEventStreamEvent) GetID

GetID returns the value of ID.

func (*V2StreamRecentchangeGetOKTextEventStreamEvent) GetRetry

GetRetry returns the value of Retry.

func (*V2StreamRecentchangeGetOKTextEventStreamEvent) GetType

GetType returns the value of Type.

func (*V2StreamRecentchangeGetOKTextEventStreamEvent) SetData

SetData sets the value of Data.

func (*V2StreamRecentchangeGetOKTextEventStreamEvent) SetID

SetID sets the value of ID.

func (*V2StreamRecentchangeGetOKTextEventStreamEvent) SetRetry

SetRetry sets the value of Retry.

func (*V2StreamRecentchangeGetOKTextEventStreamEvent) SetType

SetType sets the value of Type.

func (*V2StreamRecentchangeGetOKTextEventStreamEvent) Validate

type V2StreamRecentchangeGetOKTextEventStreamEventData

type V2StreamRecentchangeGetOKTextEventStreamEventData struct {
	// Full page name, from Title::getPrefixedText.
	Title OptString `json:"title"`
	// A URI identifying the JSONSchema for this event. This should match an schema's $id in a schema
	// repository. E.g. /schema/title/1.0.0.
	Schema string `json:"$schema"`
	// Type of recentchange event (rc_type). One of "edit", "new", "log", "categorize", or "external"; or a
	// number. (See Manual:Recentchanges table#rc_type).
	Type OptString `json:"type"`
	// (rc_bot).
	Bot OptBool `json:"bot"`
	// (rc_comment).
	Comment OptString `json:"comment"`
	// ID of the recentchange event (rcid).
	ID OptNilInt `json:"id"`
	// Length of old and new change.
	Length OptV2StreamRecentchangeGetOKTextEventStreamEventDataLength `json:"length"`
	// (rc_log_action).
	LogAction        OptString    `json:"log_action"`
	LogActionComment OptNilString `json:"log_action_comment"`
	// (rc_log_id).
	LogID OptNilInt `json:"log_id"`
	// Property only exists if event has rc_params.
	LogParams OptV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams `json:"log_params"`
	// (rc_log_type).
	LogType OptNilString                                          `json:"log_type"`
	Meta    V2StreamRecentchangeGetOKTextEventStreamEventDataMeta `json:"meta"`
	// (rc_minor).
	Minor OptBool `json:"minor"`
	// ID of relevant namespace of affected page (rc_namespace, page_namespace). This is -1 ("Special") for
	// log events.
	Namespace OptInt `json:"namespace"`
	// The rc_comment parsed into simple HTML. Optional.
	Parsedcomment OptString `json:"parsedcomment"`
	// (rc_patrolled). This property only exists if patrolling is supported for this event (based on
	// $wgUseRCPatrol, $wgUseNPPatrol).
	Patrolled OptBool `json:"patrolled"`
	// Old and new revision IDs.
	Revision OptV2StreamRecentchangeGetOKTextEventStreamEventDataRevision `json:"revision"`
	// $wgServerName.
	ServerName OptString `json:"server_name"`
	// $wgScriptPath.
	ServerScriptPath OptString `json:"server_script_path"`
	// $wgCanonicalServer.
	ServerURL OptString `json:"server_url"`
	// Unix timestamp (derived from rc_timestamp).
	Timestamp OptInt `json:"timestamp"`
	// (rc_user_text).
	User OptString `json:"user"`
	// WfWikiID ($wgDBprefix, $wgDBname).
	Wiki            OptString `json:"wiki"`
	AdditionalProps V2StreamRecentchangeGetOKTextEventStreamEventDataAdditional
}

Represents a MW RecentChange event. https://www.mediawiki.org/wiki/Manual:RCFeed.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) Decode

Decode decodes V2StreamRecentchangeGetOKTextEventStreamEventData from json.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) Encode

Encode implements json.Marshaler.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetAdditionalProps

GetAdditionalProps returns the value of AdditionalProps.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetBot

GetBot returns the value of Bot.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetComment

GetComment returns the value of Comment.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetID

GetID returns the value of ID.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetLength

GetLength returns the value of Length.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetLogAction

GetLogAction returns the value of LogAction.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetLogActionComment

GetLogActionComment returns the value of LogActionComment.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetLogID

GetLogID returns the value of LogID.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetLogParams

GetLogParams returns the value of LogParams.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetLogType

GetLogType returns the value of LogType.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetMeta

GetMeta returns the value of Meta.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetMinor

GetMinor returns the value of Minor.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetNamespace

GetNamespace returns the value of Namespace.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetParsedcomment

GetParsedcomment returns the value of Parsedcomment.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetPatrolled

GetPatrolled returns the value of Patrolled.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetRevision

GetRevision returns the value of Revision.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetSchema

GetSchema returns the value of Schema.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetServerName

GetServerName returns the value of ServerName.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetServerScriptPath

GetServerScriptPath returns the value of ServerScriptPath.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetServerURL

GetServerURL returns the value of ServerURL.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetTimestamp

GetTimestamp returns the value of Timestamp.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetTitle

GetTitle returns the value of Title.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetType

GetType returns the value of Type.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetUser

GetUser returns the value of User.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) GetWiki

GetWiki returns the value of Wiki.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetAdditionalProps

SetAdditionalProps sets the value of AdditionalProps.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetBot

SetBot sets the value of Bot.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetComment

SetComment sets the value of Comment.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetID

SetID sets the value of ID.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetLength

SetLength sets the value of Length.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetLogAction

SetLogAction sets the value of LogAction.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetLogActionComment

SetLogActionComment sets the value of LogActionComment.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetLogID

SetLogID sets the value of LogID.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetLogParams

SetLogParams sets the value of LogParams.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetLogType

SetLogType sets the value of LogType.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetMeta

SetMeta sets the value of Meta.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetMinor

SetMinor sets the value of Minor.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetNamespace

SetNamespace sets the value of Namespace.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetParsedcomment

SetParsedcomment sets the value of Parsedcomment.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetPatrolled

SetPatrolled sets the value of Patrolled.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetRevision

SetRevision sets the value of Revision.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetSchema

SetSchema sets the value of Schema.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetServerName

SetServerName sets the value of ServerName.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetServerScriptPath

SetServerScriptPath sets the value of ServerScriptPath.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetServerURL

SetServerURL sets the value of ServerURL.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetTimestamp

SetTimestamp sets the value of Timestamp.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetTitle

SetTitle sets the value of Title.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetType

SetType sets the value of Type.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetUser

SetUser sets the value of User.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) SetWiki

SetWiki sets the value of Wiki.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) UnmarshalJSON

UnmarshalJSON implements stdjson.Unmarshaler.

func (*V2StreamRecentchangeGetOKTextEventStreamEventData) Validate

type V2StreamRecentchangeGetOKTextEventStreamEventDataAdditional

type V2StreamRecentchangeGetOKTextEventStreamEventDataAdditional map[string]jx.Raw

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataAdditional) Decode

Decode decodes V2StreamRecentchangeGetOKTextEventStreamEventDataAdditional from json.

func (V2StreamRecentchangeGetOKTextEventStreamEventDataAdditional) Encode

Encode implements json.Marshaler.

func (V2StreamRecentchangeGetOKTextEventStreamEventDataAdditional) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataAdditional) UnmarshalJSON

UnmarshalJSON implements stdjson.Unmarshaler.

type V2StreamRecentchangeGetOKTextEventStreamEventDataLength

type V2StreamRecentchangeGetOKTextEventStreamEventDataLength struct {
	// (rc_new_len).
	New OptNilInt `json:"new"`
	// (rc_old_len).
	Old OptNilInt `json:"old"`
}

Length of old and new change.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataLength) Decode

Decode decodes V2StreamRecentchangeGetOKTextEventStreamEventDataLength from json.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataLength) Encode

Encode implements json.Marshaler.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataLength) GetNew

GetNew returns the value of New.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataLength) GetOld

GetOld returns the value of Old.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataLength) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataLength) SetNew

SetNew sets the value of New.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataLength) SetOld

SetOld sets the value of Old.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataLength) UnmarshalJSON

UnmarshalJSON implements stdjson.Unmarshaler.

type V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams

type V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams struct {
	// Type selects the active sum variant, switch on this field.
	Type                                                        V2StreamRecentchangeGetOKTextEventStreamEventDataLogParamsType
	AnyArray                                                    []jx.Raw
	V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1 V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1
	String                                                      string
}

Property only exists if event has rc_params. V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams represents sum type.

func NewAnyArrayV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams

func NewAnyArrayV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams(v []jx.Raw) V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams

NewAnyArrayV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams returns new V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams from []jx.Raw.

func NewStringV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams

func NewStringV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams(v string) V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams

NewStringV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams returns new V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams from string.

func NewV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams

func NewV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams(v V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1) V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams

NewV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams returns new V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams from V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) Decode

Decode decodes V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams from json.

func (V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) Encode

Encode encodes V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams as json.

func (V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) GetAnyArray

GetAnyArray returns []jx.Raw and true boolean if V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams is []jx.Raw.

func (V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) GetString

GetString returns string and true boolean if V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams is string.

func (V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) GetV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1

func (s V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) GetV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1() (v V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1, ok bool)

GetV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1 returns V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1 and true boolean if V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams is V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1.

func (V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) IsAnyArray

IsAnyArray reports whether V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams is []jx.Raw.

func (V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) IsString

IsString reports whether V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams is string.

func (V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) IsV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1

func (s V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) IsV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1() bool

IsV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1 reports whether V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams is V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1.

func (V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) SetAnyArray

SetAnyArray sets V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams to []jx.Raw.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) SetString

SetString sets V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams to string.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) SetV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1

func (s *V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) SetV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1(v V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1)

SetV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1 sets V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams to V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) UnmarshalJSON

UnmarshalJSON implements stdjson.Unmarshaler.

func (V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams) Validate

type V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1

type V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1 map[string]jx.Raw

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1) Decode

Decode decodes V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1 from json.

func (V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1) Encode

Encode implements json.Marshaler.

func (V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1) UnmarshalJSON

UnmarshalJSON implements stdjson.Unmarshaler.

type V2StreamRecentchangeGetOKTextEventStreamEventDataLogParamsType

type V2StreamRecentchangeGetOKTextEventStreamEventDataLogParamsType string

V2StreamRecentchangeGetOKTextEventStreamEventDataLogParamsType is oneOf type of V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams.

const (
	AnyArrayV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams                                                    V2StreamRecentchangeGetOKTextEventStreamEventDataLogParamsType = "[]jx.Raw"
	V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams V2StreamRecentchangeGetOKTextEventStreamEventDataLogParamsType = "V2StreamRecentchangeGetOKTextEventStreamEventDataLogParams1"
	StringV2StreamRecentchangeGetOKTextEventStreamEventDataLogParams                                                      V2StreamRecentchangeGetOKTextEventStreamEventDataLogParamsType = "string"
)

Possible values for V2StreamRecentchangeGetOKTextEventStreamEventDataLogParamsType.

type V2StreamRecentchangeGetOKTextEventStreamEventDataMeta

type V2StreamRecentchangeGetOKTextEventStreamEventDataMeta struct {
	// Domain the event or entity pertains to.
	Domain OptString `json:"domain"`
	// UTC event datetime, in ISO-8601 format.
	Dt time.Time `json:"dt"`
	// Unique ID of this event.
	ID OptString `json:"id"`
	// Unique ID of the request that caused the event.
	RequestID OptString `json:"request_id"`
	// Name of the stream/queue/dataset that this event belongs in.
	Stream string `json:"stream"`
	// Unique URI identifying the event or entity.
	URI OptString `json:"uri"`
}

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataMeta) Decode

Decode decodes V2StreamRecentchangeGetOKTextEventStreamEventDataMeta from json.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataMeta) Encode

Encode implements json.Marshaler.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataMeta) GetDomain

GetDomain returns the value of Domain.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataMeta) GetDt

GetDt returns the value of Dt.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataMeta) GetID

GetID returns the value of ID.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataMeta) GetRequestID

GetRequestID returns the value of RequestID.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataMeta) GetStream

GetStream returns the value of Stream.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataMeta) GetURI

GetURI returns the value of URI.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataMeta) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataMeta) SetDomain

SetDomain sets the value of Domain.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataMeta) SetDt

SetDt sets the value of Dt.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataMeta) SetID

SetID sets the value of ID.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataMeta) SetRequestID

SetRequestID sets the value of RequestID.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataMeta) SetStream

SetStream sets the value of Stream.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataMeta) SetURI

SetURI sets the value of URI.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataMeta) UnmarshalJSON

UnmarshalJSON implements stdjson.Unmarshaler.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataMeta) Validate

type V2StreamRecentchangeGetOKTextEventStreamEventDataRevision

type V2StreamRecentchangeGetOKTextEventStreamEventDataRevision struct {
	// (rc_last_oldid).
	New OptNilInt `json:"new"`
	// (rc_this_oldid).
	Old OptNilInt `json:"old"`
}

Old and new revision IDs.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataRevision) Decode

Decode decodes V2StreamRecentchangeGetOKTextEventStreamEventDataRevision from json.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataRevision) Encode

Encode implements json.Marshaler.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataRevision) GetNew

GetNew returns the value of New.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataRevision) GetOld

GetOld returns the value of Old.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataRevision) MarshalJSON

MarshalJSON implements stdjson.Marshaler.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataRevision) SetNew

SetNew sets the value of New.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataRevision) SetOld

SetOld sets the value of Old.

func (*V2StreamRecentchangeGetOKTextEventStreamEventDataRevision) UnmarshalJSON

UnmarshalJSON implements stdjson.Unmarshaler.

type V2StreamRecentchangeGetParams

type V2StreamRecentchangeGetParams struct {
	// Specifies the Kafka topics, partitions and offsets from which to begin streaming. You may not
	// specify topics that are not configured to be part of this stream endpoint. Example:
	// `[{topic: datacenter1.topic, partition: 0, offset: 12345}, ...]`.
	LastEventID OptString `json:",omitempty,omitzero"`
	// If given, this timestamp will be used as the historical starting position in each the requested
	// streams. since should either be an integer UTC milliseconds unix epoch timestamp, or a string
	// timestamp parseable by `Date.parse()`. If the timestamp given does not have any corresponding
	// offsets, it will be ignored, and the data will begin streaming from the latest position in the
	// stream. This parameter is ignored if `Last-Event-ID` is set with offsets (or timestamps) for
	// individual topic partition assignments, e.g. when resuming after a disconnect. NOTE: Historical
	// timestamp assignment is not supported indefinitely. Depending on backend stream configuration, will
	// likely be only one or a few weeks.
	Since OptString `json:",omitempty,omitzero"`
}

V2StreamRecentchangeGetParams is parameters of GET /v2/stream/recentchange operation.

type V2StreamRecentchangeGetRes

type V2StreamRecentchangeGetRes interface {
	// contains filtered or unexported methods
}

Jump to

Keyboard shortcuts

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