ucloudflare

package

v0.10.6 Latest Latest Go to latest Published: Jun 10, 2025 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Option func(*Upstream)

func WithZoneID(zoneID string) Option

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

func RuleFromCF(r cloudflare.DNSRecord) (Rule, error)

func RuleFromUpstream(r upstream.Rule) (Rule, error)

func (r *Rule) Same(other Rule) bool

func (r *Rule) SameUpstream(other upstream.Rule) bool

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

func NewCFStorage(records []cloudflare.DNSRecord) (*Storage, error)

func (s *Storage) Append(r upstream.Rule) error

func (s *Storage) Delete(q upstream.Rule) ([]upstream.Rule, error)

func (s *Storage) Query(q upstream.Rule) []upstream.Rule

func (s *Storage) Rules() []upstream.Rule

func (s *Storage) ToAdd() []cloudflare.DNSRecord

func (s *Storage) ToDelete() []cloudflare.DNSRecord

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

func (t *Tx) Append(r upstream.Rule) error

func (t *Tx) Close()

func (t *Tx) Commit(ctx context.Context) error

func (t *Tx) Delete(r upstream.Rule) error

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

func NewUpstream(token string, opts ...Option) (*Upstream, error)

func NewUpstreamWithCFC(cfc *cloudflare.API, opts ...Option) (*Upstream, error)

func (c *Upstream) Query(ctx context.Context, r upstream.Rule) ([]upstream.Rule, error)

func (c *Upstream) Tx(ctx context.Context) (upstream.Tx, error)