mru

Documentation

Overview

此源码被清华学神尹成大魔王专业翻译分析并修改 尹成QQ77025077 尹成微信18510341407 尹成所在QQ群721929980 尹成邮箱 yinc13@mails.tsinghua.edu.cn 尹成毕业于清华大学,微软区块链领域全球最有价值专家 https://mvp.microsoft.com/zh-cn/PublicProfile/4033620

Index

• Constants
• Variables
• func NewError(code int, s string) error
• func NewErrorf(code int, format string, args ...interface{}) error
• type DefaultTimestampProvider
  • func NewDefaultTimestampProvider() *DefaultTimestampProvider
  • func (dtp *DefaultTimestampProvider) Now() Timestamp
• type Error
  • func (e *Error) Code() int
  • func (e *Error) Error() string
• type GenericSigner
  • func NewGenericSigner(privKey *ecdsa.PrivateKey) *GenericSigner
  • func (s *GenericSigner) Address() common.Address
  • func (s *GenericSigner) Sign(data common.Hash) (signature Signature, err error)
• type Handler
  • func NewHandler(params *HandlerParams) *Handler
  • func (h *Handler) GetContent(rootAddr storage.Address) (storage.Address, []byte, error)
  • func (h *Handler) GetLastPeriod(rootAddr storage.Address) (uint32, error)
  • func (h *Handler) GetVersion(rootAddr storage.Address) (uint32, error)
  • func (h *Handler) Load(ctx context.Context, rootAddr storage.Address) (*resource, error)
  • func (h *Handler) Lookup(ctx context.Context, params *LookupParams) (*resource, error)
  • func (h *Handler) LookupPrevious(ctx context.Context, params *LookupParams) (*resource, error)
  • func (h *Handler) New(ctx context.Context, request *Request) error
  • func (h *Handler) NewUpdateRequest(ctx context.Context, rootAddr storage.Address) (updateRequest *Request, err error)
  • func (h *Handler) SetStore(store *storage.NetStore)
  • func (h *Handler) Update(ctx context.Context, r *SignedResourceUpdate) (storage.Address, error)
  • func (h *Handler) Validate(chunkAddr storage.Address, data []byte) bool
• type HandlerParams
• type LookupParams
  • func LookupLatest(rootAddr storage.Address) *LookupParams
  • func LookupLatestVersionInPeriod(rootAddr storage.Address, period uint32) *LookupParams
  • func LookupVersion(rootAddr storage.Address, period, version uint32) *LookupParams
  • func NewLookupParams(rootAddr storage.Address, period, version uint32, limit uint32) *LookupParams
  • func (r *LookupParams) RootAddr() storage.Address
• type Request
  • func NewCreateRequest(metadata *ResourceMetadata) (request *Request, err error)
  • func NewCreateUpdateRequest(metadata *ResourceMetadata) (*Request, error)
  • func (r *Request) Frequency() uint64
  • func (r *Request) IsNew() bool
  • func (r *Request) IsUpdate() bool
  • func (r *Request) MarshalJSON() (rawData []byte, err error)
  • func (r *Request) Multihash() bool
  • func (r *Request) Name() string
  • func (r *Request) Owner() common.Address
  • func (r *Request) Period() uint32
  • func (r *Request) RootAddr() storage.Address
  • func (r *Request) SetData(data []byte, multihash bool)
  • func (r *Request) Sign(signer Signer) error
  • func (r *Request) StartTime() Timestamp
  • func (r *Request) UnmarshalJSON(rawData []byte) error
  • func (r *Request) Version() uint32
• type ResourceMetadata
• type Signature
• type SignedResourceUpdate
  • func (r *SignedResourceUpdate) GetDigest() (result common.Hash, err error)
  • func (r *SignedResourceUpdate) Multihash() bool
  • func (r *SignedResourceUpdate) Sign(signer Signer) error
  • func (r *SignedResourceUpdate) Verify() (err error)
• type Signer
• type TestHandler
  • func NewTestHandler(datadir string, params *HandlerParams) (*TestHandler, error)
  • func (t *TestHandler) Close()
• type Timestamp
• type UpdateLookup
  • func (u *UpdateLookup) UpdateAddr() (updateAddr storage.Address)

Constants

const (
	ErrInit = iota
	ErrNotFound
	ErrIO
	ErrUnauthorized
	ErrInvalidValue
	ErrDataOverflow
	ErrNothingToReturn
	ErrCorruptData
	ErrInvalidSignature
	ErrNotSynced
	ErrPeriodDepth
	ErrCnt
)

Variables

var TimestampProvider timestampProvider = NewDefaultTimestampProvider()

Functions

func NewError

func NewError(code int, s string) error

func NewErrorf

func NewErrorf(code int, format string, args ...interface{}) error

Types

type DefaultTimestampProvider

type DefaultTimestampProvider struct {
}

func NewDefaultTimestampProvider

func NewDefaultTimestampProvider() *DefaultTimestampProvider

func (*DefaultTimestampProvider) Now

func (dtp *DefaultTimestampProvider) Now() Timestamp

type Error

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

func (*Error) Code

func (e *Error) Code() int

func (*Error) Error

func (e *Error) Error() string

type GenericSigner

type GenericSigner struct {
	PrivKey *ecdsa.PrivateKey
	// contains filtered or unexported fields
}

func NewGenericSigner

func NewGenericSigner(privKey *ecdsa.PrivateKey) *GenericSigner

func (*GenericSigner) Address

func (s *GenericSigner) Address() common.Address

func (*GenericSigner) Sign

func (s *GenericSigner) Sign(data common.Hash) (signature Signature, err error)

type Handler

type Handler struct {
	HashSize int
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(params *HandlerParams) *Handler

func (*Handler) GetContent

func (h *Handler) GetContent(rootAddr storage.Address) (storage.Address, []byte, error)

func (*Handler) GetLastPeriod

func (h *Handler) GetLastPeriod(rootAddr storage.Address) (uint32, error)

func (*Handler) GetVersion

func (h *Handler) GetVersion(rootAddr storage.Address) (uint32, error)

func (*Handler) Load

func (h *Handler) Load(ctx context.Context, rootAddr storage.Address) (*resource, error)

func (*Handler) Lookup

func (h *Handler) Lookup(ctx context.Context, params *LookupParams) (*resource, error)

func (*Handler) LookupPrevious

func (h *Handler) LookupPrevious(ctx context.Context, params *LookupParams) (*resource, error)

func (*Handler) New

func (h *Handler) New(ctx context.Context, request *Request) error

func (*Handler) NewUpdateRequest

func (h *Handler) NewUpdateRequest(ctx context.Context, rootAddr storage.Address) (updateRequest *Request, err error)

func (*Handler) SetStore

func (h *Handler) SetStore(store *storage.NetStore)

func (*Handler) Update

func (h *Handler) Update(ctx context.Context, r *SignedResourceUpdate) (storage.Address, error)

func (*Handler) Validate

func (h *Handler) Validate(chunkAddr storage.Address, data []byte) bool

type HandlerParams

type HandlerParams struct {
	QueryMaxPeriods uint32
}

type LookupParams

type LookupParams struct {
	UpdateLookup
	Limit uint32
}

func LookupLatest

func LookupLatest(rootAddr storage.Address) *LookupParams

func LookupLatestVersionInPeriod

func LookupLatestVersionInPeriod(rootAddr storage.Address, period uint32) *LookupParams

func LookupVersion

func LookupVersion(rootAddr storage.Address, period, version uint32) *LookupParams

func NewLookupParams

func NewLookupParams(rootAddr storage.Address, period, version uint32, limit uint32) *LookupParams

func (*LookupParams) RootAddr

func (r *LookupParams) RootAddr() storage.Address

type Request

type Request struct {
	SignedResourceUpdate
	// contains filtered or unexported fields
}

func NewCreateRequest

func NewCreateRequest(metadata *ResourceMetadata) (request *Request, err error)

func NewCreateUpdateRequest

func NewCreateUpdateRequest(metadata *ResourceMetadata) (*Request, error)

func (*Request) Frequency

func (r *Request) Frequency() uint64

func (*Request) IsNew

func (r *Request) IsNew() bool

func (*Request) IsUpdate

func (r *Request) IsUpdate() bool

func (*Request) MarshalJSON

func (r *Request) MarshalJSON() (rawData []byte, err error)

func (*Request) Multihash

func (r *Request) Multihash() bool

func (*Request) Name

func (r *Request) Name() string

func (*Request) Owner

func (r *Request) Owner() common.Address

func (*Request) Period

func (r *Request) Period() uint32

func (*Request) RootAddr

func (r *Request) RootAddr() storage.Address

func (*Request) SetData

func (r *Request) SetData(data []byte, multihash bool)

func (*Request) Sign

func (r *Request) Sign(signer Signer) error

func (*Request) StartTime

func (r *Request) StartTime() Timestamp

func (*Request) UnmarshalJSON

func (r *Request) UnmarshalJSON(rawData []byte) error

func (*Request) Version

func (r *Request) Version() uint32

type ResourceMetadata

type ResourceMetadata struct {
	StartTime Timestamp      //
	Frequency uint64         //
	Name      string         //
	Owner     common.Address //
}

type Signature

type Signature [signatureLength]byte

type SignedResourceUpdate

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

func (*SignedResourceUpdate) GetDigest

func (r *SignedResourceUpdate) GetDigest() (result common.Hash, err error)

func (*SignedResourceUpdate) Multihash

func (r *SignedResourceUpdate) Multihash() bool

func (*SignedResourceUpdate) Sign

func (r *SignedResourceUpdate) Sign(signer Signer) error

func (*SignedResourceUpdate) Verify

func (r *SignedResourceUpdate) Verify() (err error)

type Signer

type Signer interface {
	Sign(common.Hash) (Signature, error)
	Address() common.Address
}

type TestHandler

type TestHandler struct {
	*Handler
}

func NewTestHandler

func NewTestHandler(datadir string, params *HandlerParams) (*TestHandler, error)

func (*TestHandler) Close

func (t *TestHandler) Close()

type Timestamp

type Timestamp struct {
	Time uint64 //
}

type UpdateLookup

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

func (*UpdateLookup) UpdateAddr

func (u *UpdateLookup) UpdateAddr() (updateAddr storage.Address)