spacestatus

Documentation

Index

• Constants
• type ChangeVerifier
• type Config
• type DelSender
• type SpaceDeleter
• type SpaceStatus
  • func New() SpaceStatus
• type StatusChange
• type StatusEntry

Constants

const (
	SpaceStatusCreated = iota
	SpaceStatusDeletionPending
	SpaceStatusDeletionStarted
	SpaceStatusDeleted
)

const CName = "coordinator.spacestatus"

Types

type ChangeVerifier

type ChangeVerifier interface {
	Verify(rawDelete *treechangeproto.RawTreeChangeWithId, identity crypto.PubKey, peerId string) (err error)
}

type Config

type Config struct {
	RunSeconds         int `yaml:"runSeconds"`
	DeletionPeriodDays int `yaml:"deletionPeriodDays"`
}

type DelSender

type DelSender interface {
	Delete(ctx context.Context, spaceId string, raw *treechangeproto.RawTreeChangeWithId) (err error)
}

type SpaceDeleter

type SpaceDeleter interface {
	Run(spaces *mongo.Collection, delSender DelSender)
	Close()
}

type SpaceStatus

type SpaceStatus interface {
	NewStatus(ctx context.Context, spaceId string, identity, oldIdentity crypto.PubKey) (err error)
	ChangeStatus(ctx context.Context, spaceId string, change StatusChange) (entry StatusEntry, err error)
	Status(ctx context.Context, spaceId string, pubKey crypto.PubKey) (entry StatusEntry, err error)
	app.ComponentRunnable
}

func New

func New() SpaceStatus

type StatusChange

type StatusChange struct {
	DeletionPayload *treechangeproto.RawTreeChangeWithId
	Identity        crypto.PubKey
	Status          int
	PeerId          string
}

type StatusEntry

type StatusEntry struct {
	SpaceId           string `bson:"_id"`
	Identity          string `bson:"identity"`
	OldIdentity       string `bson:"oldIdentity"`
	DeletionPayload   []byte `bson:"deletionPayload"`
	DeletionTimestamp int64  `bson:"deletionTimestamp"`
	Status            int    `bson:"status"`
}