audit

Documentation

Index

• type Report
  • func NewReport(cnr cid.ID) *Report
  • func (r *Report) Complete()
  • func (r *Report) FailedPoR(sg oid.ID)
  • func (r *Report) PassedPoR(sg oid.ID)
  • func (r *Report) Result() *audit.Result
  • func (r *Report) SetPDPResults(passed, failed [][]byte)
  • func (r *Report) SetPlacementCounters(hit, miss, fail uint32)
  • func (r *Report) SetPoRCounters(requests, retries uint32)
• type Reporter
• type Task
  • func (t *Task) CancelChannel() <-chan struct{}
  • func (t *Task) ContainerID() cid.ID
  • func (t *Task) ContainerNodes() [][]netmap.NodeInfo
  • func (t *Task) ContainerStructure() container.Container
  • func (t *Task) NetworkMap() *netmap.NetMap
  • func (t *Task) Reporter() Reporter
  • func (t *Task) StorageGroupList() []storagegroup.StorageGroup
  • func (t *Task) WithCancelChannel(ch <-chan struct{}) *Task
  • func (t *Task) WithContainerID(cnr cid.ID) *Task
  • func (t *Task) WithContainerNodes(cnrNodes [][]netmap.NodeInfo) *Task
  • func (t *Task) WithContainerStructure(cnr container.Container) *Task
  • func (t *Task) WithNetworkMap(nm *netmap.NetMap) *Task
  • func (t *Task) WithReporter(r Reporter) *Task
  • func (t *Task) WithStorageGroupList(sgList []storagegroup.StorageGroup) *Task

Types

type Report

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

Report tracks the progress of auditing container data.

func NewReport

func NewReport(cnr cid.ID) *Report

NewReport creates and returns blank Report instance.

func (*Report) Complete

func (r *Report) Complete()

Complete completes audit report.

func (*Report) FailedPoR

func (r *Report) FailedPoR(sg oid.ID)

FailedPoR updates list of failed storage groups.

func (*Report) PassedPoR

func (r *Report) PassedPoR(sg oid.ID)

PassedPoR updates list of passed storage groups.

func (*Report) Result

func (r *Report) Result() *audit.Result

Result forms the structure of the data audit result.

func (*Report) SetPDPResults

func (r *Report) SetPDPResults(passed, failed [][]byte)

SetPDPResults sets lists of nodes according to their PDP results.

func (*Report) SetPlacementCounters

func (r *Report) SetPlacementCounters(hit, miss, fail uint32)

SetPlacementCounters sets counters of compliance with placement.

func (*Report) SetPoRCounters

func (r *Report) SetPoRCounters(requests, retries uint32)

SetPoRCounters sets amounts of head requests and retries at PoR audit stage.

type Reporter

type Reporter interface {
	WriteReport(r *Report) error
}

Reporter is an interface of the entity that records the data audit report.

type Task

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

Task groups groups the container audit parameters.

func (*Task) CancelChannel

func (t *Task) CancelChannel() <-chan struct{}

func (*Task) ContainerID

func (t *Task) ContainerID() cid.ID

ContainerID returns identifier of the container under audit.

func (*Task) ContainerNodes

func (t *Task) ContainerNodes() [][]netmap.NodeInfo

ContainerNodes returns nodes in the container under audit.

func (*Task) ContainerStructure

func (t *Task) ContainerStructure() container.Container

ContainerStructure returns structure of the container under audit.

func (*Task) NetworkMap

func (t *Task) NetworkMap() *netmap.NetMap

NetworkMap returns network map of audit epoch.

func (*Task) Reporter

func (t *Task) Reporter() Reporter

Reporter returns audit report writer.

func (*Task) StorageGroupList

func (t *Task) StorageGroupList() []storagegroup.StorageGroup

StorageGroupList returns list of storage groups from container under audit.

func (*Task) WithCancelChannel

func (t *Task) WithCancelChannel(ch <-chan struct{}) *Task

func (*Task) WithContainerID

func (t *Task) WithContainerID(cnr cid.ID) *Task

WithContainerID sets identifier of the container under audit.

func (*Task) WithContainerNodes

func (t *Task) WithContainerNodes(cnrNodes [][]netmap.NodeInfo) *Task

WithContainerNodes sets nodes in the container under audit.

func (*Task) WithContainerStructure

func (t *Task) WithContainerStructure(cnr container.Container) *Task

WithContainerStructure sets structure of the container under audit.

func (*Task) WithNetworkMap

func (t *Task) WithNetworkMap(nm *netmap.NetMap) *Task

WithNetworkMap sets network map of audit epoch.

func (*Task) WithReporter

func (t *Task) WithReporter(r Reporter) *Task

WithReporter sets audit report writer.

func (*Task) WithStorageGroupList

func (t *Task) WithStorageGroupList(sgList []storagegroup.StorageGroup) *Task

WithStorageGroupList sets a list of storage groups from container under audit.