specs

package
v5.23.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 8, 2024 License: MIT Imports: 12 Imported by: 0

Documentation

Index

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           `` /* 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 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    `` /* 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 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.