subscription

package
v5.25.0 Latest Latest
Warning

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

 Go to latest Published: Jan 18, 2025 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_app_subscription_config_proto protoreflect.FileDescriptor
View Source 
var File_app_subscription_subscription_rpc_proto protoreflect.FileDescriptor

Functions

func SubscriptionManagerType added in v5.25.0 

func SubscriptionManagerType() interface{}

Types

type Config 

type Config struct {
	Imports                       []*ImportSource `protobuf:"bytes,1,rep,name=imports,proto3" json:"imports,omitempty"`
	NonnativeConverterOverlay     []byte          `` /* 138-byte string literal not displayed */
	NonnativeConverterOverlayFile string          `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

Config is the settings for Subscription Manager.

func (*Config) Descriptor deprecated 

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetImports 

func (x *Config) GetImports() []*ImportSource

func (*Config) GetNonnativeConverterOverlay 

func (x *Config) GetNonnativeConverterOverlay() []byte

func (*Config) GetNonnativeConverterOverlayFile 

func (x *Config) GetNonnativeConverterOverlayFile() string

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) ProtoReflect 

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

func (*Config) Reset 

func (x *Config) Reset()

func (*Config) String 

func (x *Config) String() string

type ImportSource 

type ImportSource struct {
	Name                 string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Url                  string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	TagPrefix            string `protobuf:"bytes,3,opt,name=tag_prefix,json=tagPrefix,proto3" json:"tag_prefix,omitempty"`
	ImportUsingTag       string `protobuf:"bytes,4,opt,name=import_using_tag,json=importUsingTag,proto3" json:"import_using_tag,omitempty"`
	DefaultExpireSeconds uint64 `protobuf:"varint,5,opt,name=default_expire_seconds,json=defaultExpireSeconds,proto3" json:"default_expire_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportSource) Descriptor deprecated 

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

Deprecated: Use ImportSource.ProtoReflect.Descriptor instead.

func (*ImportSource) GetDefaultExpireSeconds 

func (x *ImportSource) GetDefaultExpireSeconds() uint64

func (*ImportSource) GetImportUsingTag 

func (x *ImportSource) GetImportUsingTag() string

func (*ImportSource) GetName 

func (x *ImportSource) GetName() string

func (*ImportSource) GetTagPrefix 

func (x *ImportSource) GetTagPrefix() string

func (*ImportSource) GetUrl 

func (x *ImportSource) GetUrl() string

func (*ImportSource) ProtoMessage 

func (*ImportSource) ProtoMessage()

func (*ImportSource) ProtoReflect 

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

func (*ImportSource) Reset 

func (x *ImportSource) Reset()

func (*ImportSource) String 

func (x *ImportSource) String() string

type SubscriptionManager added in v5.25.0 

type SubscriptionManager interface {
	features.Feature
	AddTrackedSubscriptionFromImportSource(importSource *ImportSource) error
	RemoveTrackedSubscription(name string) error
	ListTrackedSubscriptions() []string
	GetTrackedSubscriptionStatus(name string) (*TrackedSubscriptionStatus, error)
}

type SubscriptionServer added in v5.25.0 

type SubscriptionServer struct {
	ServerMetadata map[string]string `` /* 155-byte string literal not displayed */
	Tag            string            `protobuf:"bytes,3,opt,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionServer) Descriptor deprecated added in v5.25.0 

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

Deprecated: Use SubscriptionServer.ProtoReflect.Descriptor instead.

func (*SubscriptionServer) GetServerMetadata added in v5.25.0 

func (x *SubscriptionServer) GetServerMetadata() map[string]string

func (*SubscriptionServer) GetTag added in v5.25.0 

func (x *SubscriptionServer) GetTag() string

func (*SubscriptionServer) ProtoMessage added in v5.25.0 

func (*SubscriptionServer) ProtoMessage()

func (*SubscriptionServer) ProtoReflect added in v5.25.0 

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

func (*SubscriptionServer) Reset added in v5.25.0 

func (x *SubscriptionServer) Reset()

func (*SubscriptionServer) String added in v5.25.0 

func (x *SubscriptionServer) String() string

type TrackedSubscriptionStatus added in v5.25.0 

type TrackedSubscriptionStatus struct {
	Servers          map[string]*SubscriptionServer `` /* 141-byte string literal not displayed */
	DocumentMetadata map[string]string              `` /* 159-byte string literal not displayed */
	ImportSource     *ImportSource                  `protobuf:"bytes,3,opt,name=importSource,proto3" json:"importSource,omitempty"`
	// contains filtered or unexported fields
}

func (*TrackedSubscriptionStatus) Descriptor deprecated added in v5.25.0 

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

Deprecated: Use TrackedSubscriptionStatus.ProtoReflect.Descriptor instead.

func (*TrackedSubscriptionStatus) GetDocumentMetadata added in v5.25.0 

func (x *TrackedSubscriptionStatus) GetDocumentMetadata() map[string]string

func (*TrackedSubscriptionStatus) GetImportSource added in v5.25.0 

func (x *TrackedSubscriptionStatus) GetImportSource() *ImportSource

func (*TrackedSubscriptionStatus) GetServers added in v5.25.0 

func (x *TrackedSubscriptionStatus) GetServers() map[string]*SubscriptionServer

func (*TrackedSubscriptionStatus) ProtoMessage added in v5.25.0 

func (*TrackedSubscriptionStatus) ProtoMessage()

func (*TrackedSubscriptionStatus) ProtoReflect added in v5.25.0 

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

func (*TrackedSubscriptionStatus) Reset added in v5.25.0 

func (x *TrackedSubscriptionStatus) Reset()

func (*TrackedSubscriptionStatus) String added in v5.25.0 

func (x *TrackedSubscriptionStatus) String() string

Source Files

View all Source files

Directories

Path Synopsis
base64urlline
dataurlsingle
jsonfieldarray
jsonfieldarray/jsonified
urlline
dataurlfetcher
httpfetcher
nonnative
nonnative/nonnativeifce
outbound
command

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.