asyncapiv3

package

Go to main page

Versions in this module

v0

v0.45.2

Feb 18, 2025

v0.45.1

Jan 20, 2025

v0.45.0

Sep 26, 2024

v0.44.0

Sep 12, 2024

v0.43.0

Jul 21, 2024

v0.42.5

Jul 1, 2024

v0.42.4

Jul 1, 2024

v0.42.3

Jun 27, 2024

v0.42.2

Jun 20, 2024

v0.42.1

Jun 20, 2024

v0.42.0

Jun 20, 2024

v0.41.3

Jun 18, 2024

v0.41.2

Jun 9, 2024

v0.41.1

Jun 6, 2024

v0.41.0

Jun 2, 2024

v0.40.0

May 14, 2024

v0.39.4

May 7, 2024

v0.39.3

May 2, 2024

v0.39.2

May 1, 2024

v0.39.1

May 1, 2024

v0.39.0

Apr 29, 2024

Changes in this version

type Specification

+ func FromUnknownVersion(s asyncapi.Specification) (*Specification, error)

+ func NewSpecification() *Specification

+ func (s *Specification) AddDependency(path string, spec asyncapi.Specification) error

v0.38.0

Apr 25, 2024

v0.37.0

Apr 16, 2024

v0.36.1

Apr 16, 2024

v0.36.0

Apr 12, 2024

v0.35.8

Apr 12, 2024

v0.35.7

Apr 7, 2024

v0.35.6

Apr 7, 2024

v0.35.5

Apr 4, 2024

v0.35.4

Apr 3, 2024

Changes in this version

+ var ErrNoMessageInChannel = fmt.Errorf("%w: no message in channel", extensions.ErrAsyncAPI)

v0.35.3

Apr 2, 2024

v0.35.2

Mar 31, 2024

Changes in this version

+ const MessageHeadersSuffix

+ const MessagePayloadSuffix

v0.35.1

Mar 29, 2024

Changes in this version

+ var ErrInvalidReference = fmt.Errorf("%w: invalid reference", extensions.ErrAsyncAPI)

+ type SchemaType string

+ const SchemaTypeIsArray

+ const SchemaTypeIsInteger

+ const SchemaTypeIsObject

+ const SchemaTypeIsString

+ func (st SchemaType) String() string

v0.35.0

Mar 27, 2024

v0.34.0

Mar 17, 2024

Changes in this version

type OperationReply

+ func (or *OperationReply) Follow() *OperationReply

v0.33.6

Mar 17, 2024

v0.33.5

Mar 13, 2024

Changes in this version

type Schema

+ func (s *Schema) Follow() *Schema

v0.33.4

Mar 13, 2024

v0.33.3

Mar 13, 2024

v0.33.2

Mar 13, 2024

v0.33.1

Mar 13, 2024

Changes in this version

type OperationTrait

+ func (ot *OperationTrait) Follow() *OperationTrait

v0.33.0

Mar 13, 2024

Changes in this version

type CorrelationID

+ func (c *CorrelationID) Exists() bool

type Message

+ func (msg Message) HaveCorrelationID() bool

type OperationReplyAddress

+ LocationRequired bool

+ LocationTo *Schema

v0.32.1

Mar 7, 2024

v0.32.0

Mar 6, 2024

Changes in this version

+ const BindingsSuffix

+ const ChannelSuffix

+ const ExternalDocsNameSuffix

+ const MajorVersion

+ type AMQP1Binding any

+ type AMQPBinding any

+ type AnyPointMqBinding any

+ type Channel struct

+ Address string

+ Bindings *ChannelBindings

+ Description string

+ ExternalDocs *ExternalDocumentation

+ Messages map[string]*Message

+ Name string

+ Parameters map[string]*Parameter

+ Reference string

+ ReferenceTo *Channel

+ Servers []*Server

+ Summary string

+ Tags []*Tag

+ Title string

+ func (ch *Channel) Follow() *Channel

+ func (ch *Channel) Process(path string, spec Specification)

+ func (ch Channel) GetMessage() *Message

+ type ChannelBindings struct

+ AMQP AMQPBinding

+ AMQP1 AMQP1Binding

+ AnyPointMQ AnyPointMqBinding

+ GooglePubSub GooglePubSubBinding

+ HTTP HTTPBinding

+ IBMMQ IBMMQBinding

+ JMS JMSBinding

+ Kafka KafkaBinding

+ MQTT MQTTBinding

+ MQTT5 MQTT5Binding

+ Mercure MercureBinding

+ NATS NATSBinding

+ Name string

+ Pulsar PulsarBinding

+ Redis RedisBinding

+ Reference string

+ ReferenceTo *ChannelBindings

+ SNS SNSBinding

+ SQS SQSBinding

+ Solace SolaceBinding

+ Stomp StompBinding

+ WS WsBinding

+ func (chb *ChannelBindings) Process(name string, spec Specification)

+ type Components struct

+ ChannelBindings map[string]*ChannelBindings

+ Channels map[string]*Channel

+ CorrelationIDs map[string]*CorrelationID

+ ExternalDocs map[string]*ExternalDocumentation

+ MessageBindings map[string]*MessageBindings

+ MessageTraits map[string]*MessageTrait

+ Messages map[string]*Message

+ OperationBindings map[string]*OperationBindings

+ OperationTraits map[string]*OperationTrait

+ Operations map[string]*Operation

+ Parameters map[string]*Parameter

+ Replies map[string]*OperationReply

+ ReplyAddresses map[string]*OperationReplyAddress

+ Schemas map[string]*Schema

+ SecuritySchemes map[string]*SecurityScheme

+ ServerBindings map[string]*ServerBindings

+ ServerVariables map[string]*ServerVariable

+ Servers map[string]*Server

+ Tags map[string]*Tag

+ func (c *Components) Process(spec Specification)

+ type Contact struct

+ Email string

+ Name string

+ URL string

+ type CorrelationID struct

+ Description string

+ Location string

+ Name string

+ Reference string

+ ReferenceTo *Channel

+ func (c *CorrelationID) Process(path string, spec Specification)

+ type Extensions struct

+ ExtGoType string

+ ExtGoTypeImport *GoTypeImportExtension

+ type ExternalDocumentation struct

+ Description string

+ Name string

+ Reference string

+ ReferenceTo *ExternalDocumentation

+ URL string

+ func (doc *ExternalDocumentation) Process(name string, spec Specification)

+ type GoTypeImportExtension struct

+ Name GoTypeImportName

+ Path GoTypeImportPath

+ type GoTypeImportName string

+ type GoTypeImportPath string

+ type GooglePubSubBinding any

+ type HTTPBinding any

+ type IBMMQBinding any

+ type Info struct

+ Contact *Contact

+ Description string

+ ExternalDocs *ExternalDocumentation

+ License *License

+ Tags []*Tag

+ TermsOfService string

+ Title string

+ Version string

+ func (info *Info) Process(spec Specification)

+ type JMSBinding any

+ type KafkaBinding any

+ type License struct

+ Name string

+ URL string

+ type MQTT5Binding any

+ type MQTTBinding any

+ type MercureBinding any

+ type Message struct

+ Bindings *MessageBindings

+ ContentType string

+ CorrelationID *CorrelationID

+ CorrelationIDLocation string

+ CorrelationIDRequired bool

+ Description string

+ Examples []*MessageExample

+ ExternalDocs *ExternalDocumentation

+ Headers *Schema

+ Name string

+ OneOf []*Message

+ Payload *Schema

+ Reference string

+ ReferenceTo *Message

+ Summary string

+ Tags []*Tag

+ Title string

+ Traits []*MessageTrait

+ func (msg *Message) ApplyTrait(mt *MessageTrait, spec Specification)

+ func (msg *Message) Follow() *Message

+ func (msg *Message) MergeWith(spec Specification, msg2 Message)

+ func (msg *Message) Process(name string, spec Specification)

+ type MessageBindings struct

+ AMQP AMQPBinding

+ AMQP1 AMQP1Binding

+ AnyPointMQ AnyPointMqBinding

+ GooglePubSub GooglePubSubBinding

+ HTTP HTTPBinding

+ IBMMQ IBMMQBinding

+ JMS JMSBinding

+ Kafka KafkaBinding

+ MQTT MQTTBinding

+ MQTT5 MQTT5Binding

+ Mercure MercureBinding

+ NATS NATSBinding

+ Name string

+ Pulsar PulsarBinding

+ Redis RedisBinding

+ Reference string

+ ReferenceTo *MessageBindings

+ SNS SNSBinding

+ SQS SQSBinding

+ Solace SolaceBinding

+ Stomp StompBinding

+ WS WsBinding

+ func (mb *MessageBindings) Process(name string, spec Specification)

+ type MessageExample struct

+ Headers map[string]any

+ Name string

+ Payload map[string]any

+ Reference string

+ ReferenceTo *MessageExample

+ Summary string

+ func (me *MessageExample) Process(path string, spec Specification)

+ type MessageField string

+ const MessageFieldIsHeader

+ const MessageFieldIsPayload

+ func (t MessageField) String() string

+ type MessageTrait struct

+ Bindings *MessageBindings

+ ContentType string

+ CorrelationID *CorrelationID

+ CorrelationIDLocation string

+ CorrelationIDRequired bool

+ Description string

+ Examples []*MessageExample

+ ExternalDocs *ExternalDocumentation

+ Headers *Schema

+ Name string

+ Payload *Schema

+ Reference string

+ ReferenceTo *MessageTrait

+ Summary string

+ Tags []*Tag

+ Title string

+ func (mt *MessageTrait) Follow() *MessageTrait

+ func (mt *MessageTrait) Process(name string, spec Specification)

+ type MessageType string

+ const MessageTypeIsArray

+ const MessageTypeIsHeader

+ const MessageTypeIsInteger

+ const MessageTypeIsObject

+ const MessageTypeIsPayload

+ const MessageTypeIsString

+ func (t MessageType) String() string

+ type NATSBinding any

+ type OAuthFlow struct

+ AuthorizationURL string

+ AvailableScopes map[string]string

+ RefreshURL string

+ TokenURL string

+ type OAuthFlows struct

+ AuthorizationCode OAuthFlow

+ ClientCredentials OAuthFlow

+ Implicit OAuthFlow

+ Password OAuthFlow

+ type Operation struct

+ Action OperationAction

+ Bindings *OperationBindings

+ Channel *Channel

+ Description string

+ ExternalDocs *ExternalDocumentation

+ Messages []*Message

+ Name string

+ Reference string

+ ReferenceTo *Operation

+ Reply *OperationReply

+ ReplyIs *Operation

+ ReplyOf *Operation

+ Security []*SecurityScheme

+ Summary string

+ Tags []*Tag

+ Title string

+ Traits *OperationTrait

+ func (op *Operation) ApplyTrait(ot *OperationTrait, spec Specification)

+ func (op *Operation) Follow() *Operation

+ func (op *Operation) Process(name string, spec Specification)

+ func (op Operation) GetMessage() *Message

+ type OperationAction string

+ const OperationActionIsReceive

+ const OperationActionIsSend

+ func (oa OperationAction) IsReceive() bool

+ func (oa OperationAction) IsSend() bool

+ type OperationBindings struct

+ AMQP AMQPBinding

+ AMQP1 AMQP1Binding

+ AnyPointMQ AnyPointMqBinding

+ GooglePubSub GooglePubSubBinding

+ HTTP HTTPBinding

+ IBMMQ IBMMQBinding

+ JMS JMSBinding

+ Kafka KafkaBinding

+ MQTT MQTTBinding

+ MQTT5 MQTT5Binding

+ Mercure MercureBinding

+ NATS NATSBinding

+ Name string

+ Pulsar PulsarBinding

+ Redis RedisBinding

+ Reference string

+ ReferenceTo *OperationBindings

+ SNS SNSBinding

+ SQS SQSBinding

+ Solace SolaceBinding

+ Stomp StompBinding

+ WS WsBinding

+ func (ob *OperationBindings) Process(name string, spec Specification)

+ type OperationReply struct

+ Address *OperationReplyAddress

+ Channel *Channel

+ Messages []*Message

+ Name string

+ Reference string

+ ReferenceTo *OperationReply

+ func (or *OperationReply) Process(name string, spec Specification)

+ type OperationReplyAddress struct

+ Description string

+ Location string

+ Name string

+ Reference string

+ ReferenceTo *OperationReplyAddress

+ func (ora *OperationReplyAddress) Process(path string, spec Specification)

+ type OperationTrait struct

+ Bindings *OperationBindings

+ Description string

+ ExternalDocs *ExternalDocumentation

+ Name string

+ Reference string

+ ReferenceTo *OperationTrait

+ Security []*SecurityScheme

+ Summary string

+ Tags []*Tag

+ Title string

+ func (ot *OperationTrait) Process(name string, spec Specification)

+ type Parameter struct

+ Default string

+ Description string

+ Enum []string

+ Examples []string

+ Location string

+ Name string

+ Reference string

+ ReferenceTo *Parameter

+ func (p *Parameter) Process(name string, spec Specification)

+ type PulsarBinding any

+ type RedisBinding any

+ type SNSBinding any

+ type SQSBinding any

+ type Schema struct

+ AdditionalItems []*Schema

+ AdditionalProperties map[string]*Schema

+ AllOf []*Schema

+ AnyOf []*Schema

+ Const any

+ Contains []*Schema

+ Default []string

+ Description string

+ Enum []any

+ Examples map[string]any

+ ExclusiveMaximum float64

+ ExclusiveMinimum float64

+ Format string

+ IsRequired bool

+ Items *Schema

+ MaxItems uint

+ MaxLength uint

+ MaxProperties uint

+ Maximum string

+ MinItems uint

+ MinLength uint

+ MinProperties uint

+ Minimum string

+ MultipleOf []string

+ Name string

+ Not *Schema

+ OneOf []*Schema

+ Pattern string

+ PatternProperties map[string]*Schema

+ Properties map[string]*Schema

+ PropertyNames []string

+ ReadOnly bool

+ Reference string

+ ReferenceTo *Schema

+ Required []string

+ Title string

+ Type string

+ UniqueItems bool

+ WriteOnly bool

+ func NewSchema() Schema

+ func (s *Schema) MergeWith(spec Specification, s2 Schema)

+ func (s *Schema) Process(name string, spec Specification, isRequired bool)

+ func (s Schema) IsFieldRequired(field string) bool

+ type SecurityScheme struct

+ BearerFormat string

+ Description string

+ Flows OAuthFlows

+ In string

+ Name string

+ OpenIDConnectURL string

+ Reference string

+ ReferenceTo *SecurityScheme

+ Scheme string

+ Scopes []string

+ Type string

+ func RemoveDuplicateSecuritySchemes(securities []*SecurityScheme) []*SecurityScheme

+ func (s *SecurityScheme) Process(name string, spec Specification)

+ type Server struct

+ Bindings *ServerBindings

+ Description string

+ ExternalDocs *ExternalDocumentation

+ Host string

+ Name string

+ PathName string

+ Protocol string

+ ProtocolVersion string

+ Reference string

+ ReferenceTo *Server

+ Security *SecurityScheme

+ Summary string

+ Tags []*Tag

+ Title string

+ Variables map[string]*ServerVariable

+ func (srv *Server) Process(name string, spec Specification)

+ type ServerBindings struct

+ AMQP AMQPBinding

+ AMQP1 AMQP1Binding

+ AnyPointMQ AnyPointMqBinding

+ GooglePubSub GooglePubSubBinding

+ HTTP HTTPBinding

+ IBMMQ IBMMQBinding

+ JMS JMSBinding

+ Kafka KafkaBinding

+ MQTT MQTTBinding

+ MQTT5 MQTT5Binding

+ Mercure MercureBinding

+ NATS NATSBinding

+ Name string

+ Pulsar PulsarBinding

+ Redis RedisBinding

+ Reference string

+ ReferenceTo *ServerBindings

+ SNS SNSBinding

+ SQS SQSBinding

+ Solace SolaceBinding

+ Stomp StompBinding

+ WS WsBinding

+ func (ob *ServerBindings) Process(name string, spec Specification)

+ type ServerVariable struct

+ Default string

+ Description string

+ Enum []string

+ Examples []string

+ Name string

+ Reference string

+ ReferenceTo *ServerVariable

+ func (sv *ServerVariable) Process(path string, spec Specification)

+ type SolaceBinding any

+ type Specification struct

+ Channels map[string]*Channel

+ Components Components

+ DefaultContentType string

+ ID string

+ Info Info

+ Operations map[string]*Operation

+ Servers []*Server

+ Version string

+ func (s *Specification) Process()

+ func (s Specification) CustomImports() ([]string, error)

+ func (s Specification) GetOperationCountByAction() (sendCount, receiveCount uint)

+ func (s Specification) MajorVersion() int

+ func (s Specification) ReferenceChannel(ref string) *Channel

+ func (s Specification) ReferenceChannelBindings(ref string) *ChannelBindings

+ func (s Specification) ReferenceExternalDocumentation(ref string) *ExternalDocumentation

+ func (s Specification) ReferenceMessage(ref string) *Message

+ func (s Specification) ReferenceMessageBindings(ref string) *MessageBindings

+ func (s Specification) ReferenceMessageExample(ref string) *MessageExample

+ func (s Specification) ReferenceMessageTrait(ref string) *MessageTrait

+ func (s Specification) ReferenceOperation(ref string) *Operation

+ func (s Specification) ReferenceOperationBindings(ref string) *OperationBindings

+ func (s Specification) ReferenceOperationReply(ref string) *OperationReply

+ func (s Specification) ReferenceOperationReplyAddress(ref string) *OperationReplyAddress

+ func (s Specification) ReferenceOperationTrait(ref string) *OperationTrait

+ func (s Specification) ReferenceParameter(ref string) *Parameter

+ func (s Specification) ReferenceSchema(ref string) *Schema

+ func (s Specification) ReferenceSecurity(ref string) *SecurityScheme

+ func (s Specification) ReferenceServer(ref string) *Server

+ func (s Specification) ReferenceServerBindings(ref string) *ServerBindings

+ func (s Specification) ReferenceServerVariable(ref string) *ServerVariable

+ func (s Specification) ReferenceTag(ref string) *Tag

+ type StompBinding any

+ type Tag struct

+ Description string

+ ExternalDocs *ExternalDocumentation

+ Name string

+ Reference string

+ ReferenceTo *Tag

+ func RemoveDuplicateTags(tags []*Tag) []*Tag

+ func (t *Tag) Process(path string, spec Specification)

+ type WsBinding any

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