journal

Documentation

Index

• type Entry
• type Journal
• type Observer
  • func (o *Observer) OnEvent(e shiftlock.Event)

Types

type Entry

type Entry struct {
	Seq        uint64                     `json:"seq"`
	Time       time.Time                  `json:"time"`
	Service    string                     `json:"service"`
	Claim      string                     `json:"claim,omitempty"`
	Generation string                     `json:"generation,omitempty"`
	Type       string                     `json:"type"`
	Token      shiftlock.FencingToken     `json:"fencing_token,omitempty"`
	Reason     shiftlock.TransitionReason `json:"reason,omitempty"`
	OpID       shiftlock.OperationID      `json:"operation_id,omitempty"`
	Attrs      map[string]string          `json:"attrs,omitempty"`
}

Entry is a sanitized ownership history record (no secrets).

type Journal

type Journal interface {
	Append(ctx context.Context, e Entry) error
	Read(ctx context.Context, fromSeq uint64, limit int) ([]Entry, error)
	Export(ctx context.Context, fromSeq uint64) ([]Entry, error)
	Close() error
}

Journal is an append-only ownership event log.

type Observer

type Observer struct {
	J       Journal
	Service string
	// contains filtered or unexported fields
}

Observer adapts a Journal to shiftlock.Observer.

func (*Observer) OnEvent

func (o *Observer) OnEvent(e shiftlock.Event)