Documentation
¶
Index ¶
- Variables
- type OutboundConfig
- type OutboundParser
- type ServerConfiguration
- func (*ServerConfiguration) Descriptor() ([]byte, []int)deprecated
- 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)deprecated
- 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)deprecated
- 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
Constants ¶
This section is empty.
Variables ¶
View Source
var File_app_subscription_specs_abstract_spec_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
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
deprecated
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 `` /* 143-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
deprecated
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 `` /* 143-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
deprecated
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
Click to show internal directories.
Click to hide internal directories.