subscription

Documentation

Index

• func Deduplication(ctx context.Context, servers []option.Outbound) []option.Outbound
• type Manager
  • func NewSubscriptionManager(ctx context.Context, logger logger.Logger, cacheFile *cachefile.CacheFile, ...) (*Manager, error)
  • func (m *Manager) Close() error
  • func (m *Manager) PostStart() error
  • func (m *Manager) Start() error
  • func (m *Manager) Subscriptions() []*Subscription
• type ProcessOptions
  • func NewProcessOptions(options option.OutboundProcessOptions) (*ProcessOptions, error)
  • func (o *ProcessOptions) Process(outbounds []boxOption.Outbound) []boxOption.Outbound
• type Rename
• type Subscription

Functions

func Deduplication

func Deduplication(ctx context.Context, servers []option.Outbound) []option.Outbound

Types

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func NewSubscriptionManager

func NewSubscriptionManager(ctx context.Context, logger logger.Logger, cacheFile *cachefile.CacheFile, rawSubscriptions []option.Subscription) (*Manager, error)

func (*Manager) Close

func (m *Manager) Close() error

func (*Manager) PostStart

func (m *Manager) PostStart() error

func (*Manager) Start

func (m *Manager) Start() error

func (*Manager) Subscriptions

func (m *Manager) Subscriptions() []*Subscription

type ProcessOptions

type ProcessOptions struct {
	option.OutboundProcessOptions
	// contains filtered or unexported fields
}

func NewProcessOptions

func NewProcessOptions(options option.OutboundProcessOptions) (*ProcessOptions, error)

func (*ProcessOptions) Process

func (o *ProcessOptions) Process(outbounds []boxOption.Outbound) []boxOption.Outbound

type Rename

type Rename struct {
	From *regexp.Regexp
	To   string
}

type Subscription

type Subscription struct {
	option.Subscription

	Servers     []boxOption.Outbound
	LastUpdated time.Time
	LastEtag    string
	// contains filtered or unexported fields
}