Versions in this module Expand all Collapse all v1 v1.0.0 Dec 9, 2024 Changes in this version + var File_app_subscription_specs_abstract_spec_proto protoreflect.FileDescriptor + type OutboundConfig struct + Metadata map[string]string + Protocol string + Settings json.RawMessage + StreamSetting *StreamConfig + type OutboundParser struct + func NewOutboundParser() *OutboundParser + func (p *OutboundParser) ParseOutboundConfig(rawConfig []byte) (*OutboundConfig, error) + func (p *OutboundParser) ToSubscriptionServerConfig(config *OutboundConfig) (*SubscriptionServerConfig, error) + type ServerConfiguration struct + Protocol string + ProtocolSettings *anypb.Any + Security string + SecuritySettings *anypb.Any + Transport string + TransportSettings *anypb.Any + func (*ServerConfiguration) Descriptor() ([]byte, []int) + func (*ServerConfiguration) ProtoMessage() + 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 (x *ServerConfiguration) ProtoReflect() protoreflect.Message + func (x *ServerConfiguration) Reset() + func (x *ServerConfiguration) String() string + type StreamConfig struct + Security string + SecuritySettings json.RawMessage + Transport string + TransportSettings json.RawMessage + type SubscriptionDocument struct + Metadata map[string]string + Server []*SubscriptionServerConfig + func (*SubscriptionDocument) Descriptor() ([]byte, []int) + func (*SubscriptionDocument) ProtoMessage() + func (x *SubscriptionDocument) GetMetadata() map[string]string + func (x *SubscriptionDocument) GetServer() []*SubscriptionServerConfig + func (x *SubscriptionDocument) ProtoReflect() protoreflect.Message + func (x *SubscriptionDocument) Reset() + func (x *SubscriptionDocument) String() string + type SubscriptionServerConfig struct + Configuration *ServerConfiguration + Id string + Metadata map[string]string + func (*SubscriptionServerConfig) Descriptor() ([]byte, []int) + func (*SubscriptionServerConfig) ProtoMessage() + func (x *SubscriptionServerConfig) GetConfiguration() *ServerConfiguration + func (x *SubscriptionServerConfig) GetId() string + func (x *SubscriptionServerConfig) GetMetadata() map[string]string + func (x *SubscriptionServerConfig) ProtoReflect() protoreflect.Message + func (x *SubscriptionServerConfig) Reset() + func (x *SubscriptionServerConfig) String() string
Go to main page