version

Documentation

Index

• func GetCodec() codec.Codec
• type Service
  • func New(cfg util.CommonRingConfig, logger log.Logger, reg prometheus.Registerer) (*Service, error)
  • func (svc *Service) Shutdown()
  • func (svc *Service) Version(ctx context.Context, req *connect.Request[versionv1.VersionRequest]) (*connect.Response[versionv1.VersionResponse], error)
• type Versions
  • func (v *Versions) Clone() memberlist.Mergeable
  • func (v *Versions) Marshal() ([]byte, error)
  • func (v *Versions) Merge(incoming memberlist.Mergeable, localCAS bool) (memberlist.Mergeable, error)
  • func (d *Versions) MergeContent() []string
  • func (v *Versions) RemoveTombstones(limit time.Time) (total, removed int)
  • func (v *Versions) Unmarshal(in []byte) error

Functions

func GetCodec

func GetCodec() codec.Codec

Types

type Service

type Service struct {
	*services.BasicService
	// contains filtered or unexported fields
}

func New

func New(cfg util.CommonRingConfig, logger log.Logger, reg prometheus.Registerer) (*Service, error)

New creates a new version service.

func (*Service) Shutdown

func (svc *Service) Shutdown()

Shutdown stops version reports. This should only be called when the service is fully shutting down.

func (*Service) Version

func (svc *Service) Version(ctx context.Context, req *connect.Request[versionv1.VersionRequest]) (*connect.Response[versionv1.VersionResponse], error)

type Versions

type Versions struct {
	*versionv1.Versions
}

func (*Versions) Clone

func (v *Versions) Clone() memberlist.Mergeable

Implements memberlist.Mergeable.

func (*Versions) Marshal

func (v *Versions) Marshal() ([]byte, error)

Implements proto.Marshaler.

func (*Versions) Merge

func (v *Versions) Merge(incoming memberlist.Mergeable, localCAS bool) (memberlist.Mergeable, error)

Merge merges two versions. This is used when CASing or merging versions from other nodes. v is the local version and should be mutated to include the changes from incoming. The function should only returned changed instances.

func (*Versions) MergeContent

func (d *Versions) MergeContent() []string

MergeContent describes content of this Mergeable. Versions simply returns list of component that it includes.

func (*Versions) RemoveTombstones

func (v *Versions) RemoveTombstones(limit time.Time) (total, removed int)

RemoveTombstones is not required for version keys.

func (*Versions) Unmarshal

func (v *Versions) Unmarshal(in []byte) error

Implements proto.Unmarshaler.