bindings

Documentation

Index

• Constants
• type HttpChannel
  • func (*HttpChannel) Validate(context.Context) error
• type HttpMessage
  • func (value *HttpMessage) MarshalJSON() ([]byte, error)
  • func (value *HttpMessage) UnmarshalJSON(data []byte) error
  • func (value *HttpMessage) Validate(ctx context.Context) error
• type HttpOperation
  • func (binding *HttpOperation) MarshalJSON() ([]byte, error)
  • func (binding *HttpOperation) UnmarshalJSON(data []byte) error
  • func (binding *HttpOperation) Validate(ctx context.Context) error
• type HttpOperationBindingType
• type HttpServer
  • func (*HttpServer) Validate(context.Context) error
• type KafkaChannel
  • func (*KafkaChannel) Validate(context.Context) error
• type KafkaMessage
  • func (value *KafkaMessage) MarshalJSON() ([]byte, error)
  • func (value *KafkaMessage) UnmarshalJSON(data []byte) error
  • func (value *KafkaMessage) Validate(ctx context.Context) error
• type KafkaOperation
  • func (binding *KafkaOperation) MarshalJSON() ([]byte, error)
  • func (binding *KafkaOperation) UnmarshalJSON(data []byte) error
  • func (binding *KafkaOperation) Validate(ctx context.Context) error
• type KafkaServer
  • func (binding *KafkaServer) Validate(ctx context.Context) error
• type WsChannel
  • func (binding *WsChannel) MarshalJSON() ([]byte, error)
  • func (binding *WsChannel) UnmarshalJSON(data []byte) error
  • func (binding *WsChannel) Validate(ctx context.Context) error
• type WsMessage
  • func (*WsMessage) Validate(context.Context) error
• type WsOperation
  • func (*WsOperation) Validate(context.Context) error
• type WsServer
  • func (*WsServer) Validate(_ context.Context) error

Constants

const (
	HttpOperationBindingRequest  = "request"
	HttpOperationBindingResponse = "response"
)

Types

type HttpChannel

type HttpChannel struct {
}

HttpChannel is defined in AsyncAPI spec: https://github.com/asyncapi/bindings/tree/master/http#channel-binding-object

func (*HttpChannel) Validate

func (*HttpChannel) Validate(context.Context) error

type HttpMessage

type HttpMessage struct {
	Extensions map[string]interface{} `json:"-" yaml:"-"`

	Headers        *openapi3.Schema `json:"headers,omitempty" yaml:"headers,omitempty"`
	BindingVersion string           `json:"bindingVersion,omitempty" yaml:"bindingVersion,omitempty"`
}

HttpMessage is defined in AsyncAPI spec: https://github.com/asyncapi/bindings/tree/master/http#message-binding-object

func (*HttpMessage) MarshalJSON

func (value *HttpMessage) MarshalJSON() ([]byte, error)

func (*HttpMessage) UnmarshalJSON

func (value *HttpMessage) UnmarshalJSON(data []byte) error

func (*HttpMessage) Validate

func (value *HttpMessage) Validate(ctx context.Context) error

type HttpOperation

type HttpOperation struct {
	Extensions map[string]interface{} `json:"-" yaml:"-"`

	Type           HttpOperationBindingType `json:"type,omitempty" yaml:"type,omitempty"`
	Method         string                   `json:"method,omitempty" yaml:"method,omitempty"`
	Query          *openapi3.Schema         `json:"query,omitempty" yaml:"query,omitempty"`
	BindingVersion string                   `json:"bindingVersion,omitempty" yaml:"bindingVersion,omitempty"`
}

HttpOperation is defined in AsyncAPI spec: https://github.com/asyncapi/bindings/tree/master/http#operation-binding-object

func (*HttpOperation) MarshalJSON

func (binding *HttpOperation) MarshalJSON() ([]byte, error)

func (*HttpOperation) UnmarshalJSON

func (binding *HttpOperation) UnmarshalJSON(data []byte) error

func (*HttpOperation) Validate

func (binding *HttpOperation) Validate(ctx context.Context) error

type HttpOperationBindingType

type HttpOperationBindingType string

type HttpServer

type HttpServer struct {
}

HttpServer is defined in AsyncAPI spec: https://github.com/asyncapi/bindings/tree/master/http#server-binding-object

func (*HttpServer) Validate

func (*HttpServer) Validate(context.Context) error

type KafkaChannel

type KafkaChannel struct {
}

KafkaChannel is defined in AsyncAPI spec: https://github.com/asyncapi/bindings/tree/master/kafka#channel-binding-object

func (*KafkaChannel) Validate

func (*KafkaChannel) Validate(context.Context) error

type KafkaMessage

type KafkaMessage struct {
	Extensions map[string]interface{} `json:"-" yaml:"-"`

	Key            *openapi3.Schema `json:"key" yaml:"key"`
	BindingVersion string           `json:"bindingVersion" yaml:"bindingVersion"`
}

KafkaMessage is defined in AsyncAPI spec: https://github.com/asyncapi/bindings/tree/master/kafka#message-binding-object

func (*KafkaMessage) MarshalJSON

func (value *KafkaMessage) MarshalJSON() ([]byte, error)

func (*KafkaMessage) UnmarshalJSON

func (value *KafkaMessage) UnmarshalJSON(data []byte) error

func (*KafkaMessage) Validate

func (value *KafkaMessage) Validate(ctx context.Context) error

type KafkaOperation

type KafkaOperation struct {
	Extensions map[string]interface{} `json:"-" yaml:"-"`

	GroupID        *openapi3.Schema `json:"groupId" yaml:"groupId"`
	ClientID       *openapi3.Schema `json:"clientId" yaml:"clientId"`
	BindingVersion string           `json:"bindingVersion" yaml:"bindingVersion"`
}

KafkaOperation is defined in AsyncAPI spec: https://github.com/asyncapi/bindings/tree/master/kafka#operation-binding-object

func (*KafkaOperation) MarshalJSON

func (binding *KafkaOperation) MarshalJSON() ([]byte, error)

func (*KafkaOperation) UnmarshalJSON

func (binding *KafkaOperation) UnmarshalJSON(data []byte) error

func (*KafkaOperation) Validate

func (binding *KafkaOperation) Validate(ctx context.Context) error

type KafkaServer

type KafkaServer struct {
}

KafkaServer is defined in AsyncAPI spec: https://github.com/asyncapi/bindings/tree/master/kafka#server-binding-object

func (*KafkaServer) Validate

func (binding *KafkaServer) Validate(ctx context.Context) error

type WsChannel

type WsChannel struct {
	Extensions map[string]interface{} `json:"-" yaml:"-"`

	Method         string           `json:"method,omitempty" yaml:"method,omitempty"`
	Query          *openapi3.Schema `json:"query,omitempty" yaml:"query,omitempty"`
	Headers        *openapi3.Schema `json:"headers,omitempty" yaml:"headers,omitempty"`
	BindingVersion string           `json:"bindingVersion,omitempty" yaml:"bindingVersion,omitempty"`
}

WsChannel is defined in AsyncAPI spec: https://github.com/asyncapi/bindings/tree/master/websockets#channel-binding-object

func (*WsChannel) MarshalJSON

func (binding *WsChannel) MarshalJSON() ([]byte, error)

func (*WsChannel) UnmarshalJSON

func (binding *WsChannel) UnmarshalJSON(data []byte) error

func (*WsChannel) Validate

func (binding *WsChannel) Validate(ctx context.Context) error

type WsMessage

type WsMessage struct {
}

WsMessage is defined in AsyncAPI spec: https://github.com/asyncapi/bindings/tree/master/websockets#message-binding-object

func (*WsMessage) Validate

func (*WsMessage) Validate(context.Context) error

type WsOperation

type WsOperation struct {
}

WsOperation is defined in AsyncAPI spec: https://github.com/asyncapi/bindings/tree/master/websockets#operation-binding-object

func (*WsOperation) Validate

func (*WsOperation) Validate(context.Context) error

type WsServer

type WsServer struct {
}

WsServer is defined in AsyncAPI spec: https://github.com/asyncapi/bindings/tree/master/websockets#server-binding-object

func (*WsServer) Validate

func (*WsServer) Validate(_ context.Context) error