event

package
v1.1.1 Latest Latest
Warning

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

Go to latest
Published: Nov 21, 2023 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AbsoluteOrRelativeTimeType

type AbsoluteOrRelativeTimeType struct {
	xsd.DateTime
	xsd.Duration
}

AbsoluteOrRelativeTimeType <xsd:union memberTypes="xsd:dateTime xsd:duration"/>

type ActionType

type ActionType AttributedURIType

ActionType for AttributedURIType

type Address

type Address xsd.String

Address Alias

type AttributedURIType

AttributedURIType in ws-addr

type Capabilities

type Capabilities struct {
	WSSubscriptionPolicySupport                   xsd.Boolean `xml:"WSSubscriptionPolicySupport,attr"`
	WSPullPointSupport                            xsd.Boolean `xml:"WSPullPointSupport,attr"`
	WSPausableSubscriptionManagerInterfaceSupport xsd.Boolean `xml:"WSPausableSubscriptionManagerInterfaceSupport,attr"`
	MaxNotificationProducers                      xsd.Int     `xml:"MaxNotificationProducers,attr"`
	MaxPullPoints                                 xsd.Int     `xml:"MaxPullPoints,attr"`
	PersistentNotificationStorage                 xsd.Boolean `xml:"PersistentNotificationStorage,attr"`
}

Capabilities of event

type CreatePullPointSubscription

type CreatePullPointSubscription struct {
	XMLName                string      `xml:"tev:CreatePullPointSubscription,omitempty"`
	Filter                 *FilterType `xml:"tev:Filter,omitempty"`
	InitialTerminationTime *xsd.String `xml:"tev:InitialTerminationTime,omitempty"`
	SubscriptionPolicy     *xsd.String `xml:"tev:SubscriptionPolicy,omitempty"`
}

CreatePullPointSubscription action BUG(r) Bad AbsoluteOrRelativeTimeType type

type CreatePullPointSubscriptionFunction

type CreatePullPointSubscriptionFunction struct{}

func (*CreatePullPointSubscriptionFunction) Request

func (_ *CreatePullPointSubscriptionFunction) Request() interface{}

func (*CreatePullPointSubscriptionFunction) Response

func (_ *CreatePullPointSubscriptionFunction) Response() interface{}

type CreatePullPointSubscriptionResponse

type CreatePullPointSubscriptionResponse struct {
	SubscriptionReference SubscriptionReferenceResponse
	CurrentTime           CurrentTime
	TerminationTime       TerminationTime
}

CreatePullPointSubscriptionResponse action

type CurrentTime

CurrentTime alias

type Data

type Data struct {
	SimpleItem []SimpleItem `json:",omitempty" xml:",omitempty"`
}

type Documentation

Documentation alias

type EndpointReference

type EndpointReference EndpointReferenceType

EndpointReference alias

type EndpointReferenceType

type EndpointReferenceType struct {
	Address             AttributedURIType `xml:"wsa:Address"`
	ReferenceParameters *ReferenceParametersType
	Metadata            *MetadataType `xml:"Metadata"`
}

EndpointReferenceType in ws-addr

type ExtensibleDocumented

type ExtensibleDocumented struct {
	Documentation Documentation //к xsd-документе documentation с маленькой буквы начинается

}

ExtensibleDocumented struct

type FilterType

type FilterType struct {
	TopicExpression *TopicExpressionType `xml:"wsnt:TopicExpression,omitempty"`
	MessageContent  *QueryExpressionType `xml:"wsnt:MessageContent,omitempty"`
}

FilterType struct

type FixedTopicSet

FixedTopicSet alias

type GetEventProperties

type GetEventProperties struct {
	XMLName string `xml:"tev:GetEventProperties"`
}

GetEventProperties action

type GetEventPropertiesFunction

type GetEventPropertiesFunction struct{}

func (*GetEventPropertiesFunction) Request

func (_ *GetEventPropertiesFunction) Request() interface{}

func (*GetEventPropertiesFunction) Response

func (_ *GetEventPropertiesFunction) Response() interface{}

type GetEventPropertiesResponse

type GetEventPropertiesResponse struct {
	TopicNamespaceLocation          *xsd.AnyURI             `json:",omitempty" xml:",omitempty"`
	FixedTopicSet                   *FixedTopicSet          `json:",omitempty" xml:",omitempty"`
	TopicSet                        *TopicSet               `json:",omitempty" xml:",omitempty"`
	TopicExpressionDialect          *TopicExpressionDialect `json:",omitempty" xml:",omitempty"`
	MessageContentFilterDialect     *xsd.AnyURI             `json:",omitempty" xml:",omitempty"`
	ProducerPropertiesFilterDialect *xsd.AnyURI             `json:",omitempty" xml:",omitempty"`
	MessageContentSchemaLocation    *xsd.AnyURI             `json:",omitempty" xml:",omitempty"`
}

GetEventPropertiesResponse action

type GetServiceCapabilities

type GetServiceCapabilities struct {
	XMLName string `xml:"tev:GetServiceCapabilities"`
}

GetServiceCapabilities action

type GetServiceCapabilitiesFunction added in v0.1.4

type GetServiceCapabilitiesFunction struct{}

func (*GetServiceCapabilitiesFunction) Request added in v0.1.4

func (_ *GetServiceCapabilitiesFunction) Request() interface{}

func (*GetServiceCapabilitiesFunction) Response added in v0.1.4

func (_ *GetServiceCapabilitiesFunction) Response() interface{}

type GetServiceCapabilitiesResponse

type GetServiceCapabilitiesResponse struct {
	Capabilities Capabilities
}

GetServiceCapabilitiesResponse type

type InvalidFilterFault

type InvalidFilterFault struct {
}

InvalidFilterFault response type

type InvalidMessageContentExpressionFault

type InvalidMessageContentExpressionFault struct {
}

InvalidMessageContentExpressionFault response type

type InvalidProducerPropertiesExpressionFault

type InvalidProducerPropertiesExpressionFault struct {
}

InvalidProducerPropertiesExpressionFault response type

type InvalidTopicExpressionFault

type InvalidTopicExpressionFault struct {
}

InvalidTopicExpressionFault response type

type Message

type Message xsd.AnyType

Message alias

type MessageBody

type MessageBody struct {
	Message MessageDescription
}

type MessageContentType

type MessageContentType QueryExpressionType

MessageContentType Alias

type MessageDescription

type MessageDescription struct {
	PropertyOperation xsd.AnyType `xml:"PropertyOperation,attr"`
	Source            Source      `json:",omitempty" xml:",omitempty"`
	Data              Data        `json:",omitempty" xml:",omitempty"`
}

type Metadata

Metadata in ws-addr

type MetadataType

type MetadataType struct {
}

MetadataType in ws-addr

type Node

type Node struct {
	XMLName xml.Name
	Content []byte `xml:",innerxml"`
}

type NotificationMessage

NotificationMessage Alias

type NotificationMessageHolderType

type NotificationMessageHolderType struct {
	SubscriptionReference SubscriptionReference //wsnt http://docs.oasis-open.org/wsn/b-2.xsd
	Topic                 Topic
	ProducerReference     ProducerReference
	Message               MessageBody
}

NotificationMessageHolderType Alias

type Notify

type Notify struct {
	NotificationMessage []NotificationMessage `json:",omitempty" xml:",omitempty"`
}

Notify type

type NotifyMessageNotSupportedFault

type NotifyMessageNotSupportedFault struct {
}

NotifyMessageNotSupportedFault response type

type ProducerReference

type ProducerReference EndpointReferenceType

ProducerReference Alias

type PullMessages

type PullMessages struct {
	XMLName      string       `xml:"tev:PullMessages"`
	Timeout      xsd.Duration `xml:"tev:Timeout"`
	MessageLimit xsd.Int      `xml:"tev:MessageLimit"`
}

PullMessages Action

type PullMessagesFaultResponse

type PullMessagesFaultResponse struct {
	MaxTimeout      xsd.Duration
	MaxMessageLimit xsd.Int
}

PullMessagesFaultResponse response type

type PullMessagesFunction

type PullMessagesFunction struct{}

func (*PullMessagesFunction) Request

func (_ *PullMessagesFunction) Request() interface{}

func (*PullMessagesFunction) Response

func (_ *PullMessagesFunction) Response() interface{}

type PullMessagesResponse

type PullMessagesResponse struct {
	CurrentTime         *xsd.String           `json:",omitempty" xml:",omitempty"`
	TerminationTime     *xsd.String           `json:",omitempty" xml:",omitempty"`
	NotificationMessage []NotificationMessage `json:",omitempty" xml:",omitempty"`
}

PullMessagesResponse response type

type QueryExpression

type QueryExpression QueryExpressionType

QueryExpression Alias

type QueryExpressionType

type QueryExpressionType struct {
	MessageKind xsd.String `xml:",chardata"` // boolean(ncex:Producer="15")
}

QueryExpressionType struct for wsnt:MessageContent

type ReferenceParametersType

type ReferenceParametersType struct {
}

ReferenceParametersType in ws-addr

type Renew

type Renew struct {
	XMLName         string     `xml:"wsnt:Renew"`
	TerminationTime xsd.String `xml:"wsnt:TerminationTime"`
}

Renew action for refresh event topic subscription

type RenewFunction

type RenewFunction struct{}

func (*RenewFunction) Request

func (_ *RenewFunction) Request() interface{}

func (*RenewFunction) Response

func (_ *RenewFunction) Response() interface{}

type RenewResponse

type RenewResponse struct {
	TerminationTime TerminationTime `xml:"wsnt:TerminationTime"`
	CurrentTime     CurrentTime     `xml:"wsnt:CurrentTime"`
}

RenewResponse for Renew action

type ResourceUnknownFault

type ResourceUnknownFault struct {
}

ResourceUnknownFault response type

type Seek

type Seek struct {
	XMLName string       `xml:"tev:Seek"`
	UtcTime xsd.DateTime `xml:"tev:UtcTime"`
	Reverse xsd.Boolean  `xml:"tev:Reverse"`
}

Seek action

type SeekFunction added in v0.1.4

type SeekFunction struct{}

func (*SeekFunction) Request added in v0.1.4

func (_ *SeekFunction) Request() interface{}

func (*SeekFunction) Response added in v0.1.4

func (_ *SeekFunction) Response() interface{}

type SeekResponse

type SeekResponse struct {
}

SeekResponse action

type SetSynchronizationPoint

type SetSynchronizationPoint struct {
	XMLName string `xml:"tev:SetSynchronizationPoint"`
}

SetSynchronizationPoint action

type SetSynchronizationPointFunction added in v0.1.4

type SetSynchronizationPointFunction struct{}

func (*SetSynchronizationPointFunction) Request added in v0.1.4

func (_ *SetSynchronizationPointFunction) Request() interface{}

func (*SetSynchronizationPointFunction) Response added in v0.1.4

func (_ *SetSynchronizationPointFunction) Response() interface{}

type SetSynchronizationPointResponse

type SetSynchronizationPointResponse struct {
}

SetSynchronizationPointResponse action

type SimpleItem

type SimpleItem struct {
	Name  xsd.AnyType `xml:"Name,attr"`
	Value xsd.AnyType `xml:"Value,attr"`
}

type Source

type Source struct {
	SimpleItem []SimpleItem `json:",omitempty" xml:",omitempty"`
}

type Subscribe

type Subscribe struct {
	XMLName            struct{}               `xml:"wsnt:Subscribe"`
	ConsumerReference  *EndpointReferenceType `xml:"wsnt:ConsumerReference"`
	Filter             *FilterType            `xml:"wsnt:Filter"`
	SubscriptionPolicy *xsd.String            `xml:"wsnt:SubscriptionPolicy"`
	TerminationTime    *xsd.String            `xml:"wsnt:TerminationTime"`
}

Subscribe action for subscribe event topic

type SubscribeCreationFailedFault

type SubscribeCreationFailedFault struct {
}

SubscribeCreationFailedFault response type

type SubscribeFunction

type SubscribeFunction struct{}

func (*SubscribeFunction) Request

func (_ *SubscribeFunction) Request() interface{}

func (*SubscribeFunction) Response

func (_ *SubscribeFunction) Response() interface{}

type SubscribeResponse

type SubscribeResponse struct {
	SubscriptionReference SubscriptionReferenceResponse
	CurrentTime           *xsd.String
	TerminationTime       *xsd.String
}

SubscribeResponse message for subscribe event topic

type SubscriptionPolicy

type SubscriptionPolicy struct {
	ChangedOnly xsd.Boolean `xml:"ChangedOnly,attr"`
	// contains filtered or unexported fields
}

SubscriptionPolicy action

type SubscriptionReference

type SubscriptionReference EndpointReferenceType

SubscriptionReference Alias

type SubscriptionReferenceFunction added in v0.1.4

type SubscriptionReferenceFunction struct{}

func (*SubscriptionReferenceFunction) Request added in v0.1.4

func (_ *SubscriptionReferenceFunction) Request() interface{}

func (*SubscriptionReferenceFunction) Response added in v0.1.4

func (_ *SubscriptionReferenceFunction) Response() interface{}

type SubscriptionReferenceResponse

type SubscriptionReferenceResponse struct {
	Address             AttributedURIType
	ReferenceParameters *ReferenceParametersType
	Metadata            *MetadataType
}

type TerminationTime

TerminationTime alias

type Topic

type Topic TopicExpressionType

Topic Alias

type TopicExpressionDialect

type TopicExpressionDialect xsd.AnyURI

TopicExpressionDialect alias

type TopicExpressionDialectUnknownFault

type TopicExpressionDialectUnknownFault struct {
}

TopicExpressionDialectUnknownFault response type

type TopicExpressionType

type TopicExpressionType struct {
	TopicKinds xsd.String `xml:",chardata"`
}

TopicExpressionType struct for wsnt:TopicExpression

type TopicNotSupportedFault

type TopicNotSupportedFault struct {
}

TopicNotSupportedFault response type

type TopicSet

type TopicSet map[string]interface{} //wstop http://docs.oasis-open.org/wsn/t-1.xsd

TopicSet alias

func (*TopicSet) UnmarshalXML

func (n *TopicSet) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error

type TopicSetType

type TopicSetType struct {

	//here can be any element
	RuleEngine *topic.RuleEngine `json:"tns:RuleEngine,omitempty" xml:",omitempty"`
}

TopicSetType alias

type UnacceptableInitialTerminationTimeFault

type UnacceptableInitialTerminationTimeFault struct {
}

UnacceptableInitialTerminationTimeFault response type

type UnrecognizedPolicyRequestFault

type UnrecognizedPolicyRequestFault struct {
}

UnrecognizedPolicyRequestFault response type

type Unsubscribe

type Unsubscribe struct {
	XMLName string `xml:"tev:Unsubscribe"`
	Any     string
}

Unsubscribe action for Unsubscribe event topic

type UnsubscribeFunction

type UnsubscribeFunction struct{}

func (*UnsubscribeFunction) Request

func (_ *UnsubscribeFunction) Request() interface{}

func (*UnsubscribeFunction) Response

func (_ *UnsubscribeFunction) Response() interface{}

type UnsubscribeResponse

type UnsubscribeResponse struct {
	Any string
}

UnsubscribeResponse message for Unsubscribe event topic

type UnsupportedPolicyRequestFault

type UnsupportedPolicyRequestFault struct {
}

UnsupportedPolicyRequestFault response type

Notes

Bugs

  • Bad AbsoluteOrRelativeTimeType type

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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