spacestatus

Documentation

Index

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

Constants

const (
	SpaceStatusCreated = iota
	SpaceStatusDeletionPending
	SpaceStatusDeletionStarted
	SpaceStatusDeleted
)

const CName = "coordinator.spacestatus"

Variables

var (
	ErrStatusExists = errors.New("space status exists")
)

Types

type ChangeVerifier

type ChangeVerifier interface {
	Verify(change StatusChange) (err error)
}

type Config

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

type Deleter

type Deleter func(ctx context.Context, spaceId string) (err error)

type SpaceDeleter

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

type SpaceStatus

type SpaceStatus interface {
	NewStatus(ctx context.Context, spaceId string, identity, oldIdentity crypto.PubKey, force bool) (err error)
	ChangeStatus(ctx context.Context, 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 {
	DeletionPayloadType coordinatorproto.DeletionPayloadType
	DeletionPayload     []byte
	DeletionPayloadId   string
	Identity            crypto.PubKey
	Status              int
	PeerId              string
	SpaceId             string
	NetworkId           string
}

type StatusEntry

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