specs

Documentation

Index

• Variables
• type OutboundConfig
• type OutboundParser
  • func NewOutboundParser() *OutboundParser
  • func (p *OutboundParser) ParseOutboundConfig(rawConfig []byte) (*OutboundConfig, error)
  • func (p *OutboundParser) ToSubscriptionServerConfig(config *OutboundConfig) (*SubscriptionServerConfig, error)
• type ServerConfiguration
  • func (*ServerConfiguration) Descriptor() ([]byte, []int)
  • func (x *ServerConfiguration) GetProtocol() string
  • func (x *ServerConfiguration) GetProtocolSettings() *anypb.Any
  • func (x *ServerConfiguration) GetSecurity() string
  • func (x *ServerConfiguration) GetSecuritySettings() *anypb.Any
  • func (x *ServerConfiguration) GetTransport() string
  • func (x *ServerConfiguration) GetTransportSettings() *anypb.Any
  • func (*ServerConfiguration) ProtoMessage()
  • func (x *ServerConfiguration) ProtoReflect() protoreflect.Message
  • func (x *ServerConfiguration) Reset()
  • func (x *ServerConfiguration) String() string
• type StreamConfig
• type SubscriptionDocument
  • func (*SubscriptionDocument) Descriptor() ([]byte, []int)
  • func (x *SubscriptionDocument) GetMetadata() map[string]string
  • func (x *SubscriptionDocument) GetServer() []*SubscriptionServerConfig
  • func (*SubscriptionDocument) ProtoMessage()
  • func (x *SubscriptionDocument) ProtoReflect() protoreflect.Message
  • func (x *SubscriptionDocument) Reset()
  • func (x *SubscriptionDocument) String() string
• type SubscriptionServerConfig
  • func (*SubscriptionServerConfig) Descriptor() ([]byte, []int)
  • func (x *SubscriptionServerConfig) GetConfiguration() *ServerConfiguration
  • func (x *SubscriptionServerConfig) GetId() string
  • func (x *SubscriptionServerConfig) GetMetadata() map[string]string
  • func (*SubscriptionServerConfig) ProtoMessage()
  • func (x *SubscriptionServerConfig) ProtoReflect() protoreflect.Message
  • func (x *SubscriptionServerConfig) Reset()
  • func (x *SubscriptionServerConfig) String() string

Variables

var File_app_subscription_specs_abstract_spec_proto protoreflect.FileDescriptor

Types

type OutboundConfig

type OutboundConfig struct {
	Protocol      string            `json:"protocol"`
	Settings      json.RawMessage   `json:"settings"`
	StreamSetting *StreamConfig     `json:"streamSettings"`
	Metadata      map[string]string `json:"metadata"`
}

type OutboundParser

type OutboundParser struct{}

func NewOutboundParser

func NewOutboundParser() *OutboundParser

func (*OutboundParser) ParseOutboundConfig

func (p *OutboundParser) ParseOutboundConfig(rawConfig []byte) (*OutboundConfig, error)

func (*OutboundParser) ToSubscriptionServerConfig

func (p *OutboundParser) ToSubscriptionServerConfig(config *OutboundConfig) (*SubscriptionServerConfig, error)

type ServerConfiguration

type ServerConfiguration struct {
	Protocol          string     `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"`
	ProtocolSettings  *anypb.Any `protobuf:"bytes,2,opt,name=protocol_settings,json=protocolSettings,proto3" json:"protocol_settings,omitempty"`
	Transport         string     `protobuf:"bytes,3,opt,name=transport,proto3" json:"transport,omitempty"`
	TransportSettings *anypb.Any `protobuf:"bytes,4,opt,name=transport_settings,json=transportSettings,proto3" json:"transport_settings,omitempty"`
	Security          string     `protobuf:"bytes,5,opt,name=security,proto3" json:"security,omitempty"`
	SecuritySettings  *anypb.Any `protobuf:"bytes,6,opt,name=security_settings,json=securitySettings,proto3" json:"security_settings,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerConfiguration) Descriptor

func (*ServerConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use ServerConfiguration.ProtoReflect.Descriptor instead.

func (*ServerConfiguration) GetProtocol

func (x *ServerConfiguration) GetProtocol() string

func (*ServerConfiguration) GetProtocolSettings

func (x *ServerConfiguration) GetProtocolSettings() *anypb.Any

func (*ServerConfiguration) GetSecurity

func (x *ServerConfiguration) GetSecurity() string

func (*ServerConfiguration) GetSecuritySettings

func (x *ServerConfiguration) GetSecuritySettings() *anypb.Any

func (*ServerConfiguration) GetTransport

func (x *ServerConfiguration) GetTransport() string

func (*ServerConfiguration) GetTransportSettings

func (x *ServerConfiguration) GetTransportSettings() *anypb.Any

func (*ServerConfiguration) ProtoMessage

func (*ServerConfiguration) ProtoMessage()

func (*ServerConfiguration) ProtoReflect

func (x *ServerConfiguration) ProtoReflect() protoreflect.Message

func (*ServerConfiguration) Reset

func (x *ServerConfiguration) Reset()

func (*ServerConfiguration) String

func (x *ServerConfiguration) String() string

type StreamConfig

type StreamConfig struct {
	Transport         string          `json:"transport"`
	TransportSettings json.RawMessage `json:"transportSettings"`
	Security          string          `json:"security"`
	SecuritySettings  json.RawMessage `json:"securitySettings"`
}

type SubscriptionDocument

type SubscriptionDocument struct {
	Metadata map[string]string           `` /* 157-byte string literal not displayed */
	Server   []*SubscriptionServerConfig `protobuf:"bytes,3,rep,name=server,proto3" json:"server,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionDocument) Descriptor

func (*SubscriptionDocument) Descriptor() ([]byte, []int)

Deprecated: Use SubscriptionDocument.ProtoReflect.Descriptor instead.

func (*SubscriptionDocument) GetMetadata

func (x *SubscriptionDocument) GetMetadata() map[string]string

func (*SubscriptionDocument) GetServer

func (x *SubscriptionDocument) GetServer() []*SubscriptionServerConfig

func (*SubscriptionDocument) ProtoMessage

func (*SubscriptionDocument) ProtoMessage()

func (*SubscriptionDocument) ProtoReflect

func (x *SubscriptionDocument) ProtoReflect() protoreflect.Message

func (*SubscriptionDocument) Reset

func (x *SubscriptionDocument) Reset()

func (*SubscriptionDocument) String

func (x *SubscriptionDocument) String() string

type SubscriptionServerConfig

type SubscriptionServerConfig struct {
	Id            string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Metadata      map[string]string    `` /* 157-byte string literal not displayed */
	Configuration *ServerConfiguration `protobuf:"bytes,3,opt,name=configuration,proto3" json:"configuration,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionServerConfig) Descriptor

func (*SubscriptionServerConfig) Descriptor() ([]byte, []int)

Deprecated: Use SubscriptionServerConfig.ProtoReflect.Descriptor instead.

func (*SubscriptionServerConfig) GetConfiguration

func (x *SubscriptionServerConfig) GetConfiguration() *ServerConfiguration

func (*SubscriptionServerConfig) GetId

func (x *SubscriptionServerConfig) GetId() string

func (*SubscriptionServerConfig) GetMetadata

func (x *SubscriptionServerConfig) GetMetadata() map[string]string

func (*SubscriptionServerConfig) ProtoMessage

func (*SubscriptionServerConfig) ProtoMessage()

func (*SubscriptionServerConfig) ProtoReflect

func (x *SubscriptionServerConfig) ProtoReflect() protoreflect.Message

func (*SubscriptionServerConfig) Reset

func (x *SubscriptionServerConfig) Reset()

func (*SubscriptionServerConfig) String

func (x *SubscriptionServerConfig) String() string