storage

package
v0.0.0-...-a1113b1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 28, 2026 License: GPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DuplicationTypeStorageData ctypes.DuplicationKeyType = "storage-data"
)

Variables

View Source 
var (
	CreateDataFactHint = hint.MustNewHint("mitum-storage-create-data-operation-fact-v0.0.1")
	CreateDataHint     = hint.MustNewHint("mitum-storage-create-data-operation-v0.0.1")
)
View Source 
var (
	DeleteDataFactHint = hint.MustNewHint("mitum-storage-delete-data-operation-fact-v0.0.1")
	DeleteDataHint     = hint.MustNewHint("mitum-storage-delete-data-operation-v0.0.1")
)
View Source 
var (
	RegisterModelFactHint = hint.MustNewHint("mitum-storage-register-model-operation-fact-v0.0.1")
	RegisterModelHint     = hint.MustNewHint("mitum-storage-register-model-operation-v0.0.1")
)
View Source 
var (
	UpdateDataFactHint = hint.MustNewHint("mitum-storage-update-data-operation-fact-v0.0.1")
	UpdateDataHint     = hint.MustNewHint("mitum-storage-update-data-operation-v0.0.1")
)
View Source 
var CreateDataItemHint = hint.MustNewHint("mitum-storage-create-data-item-v0.0.1")
View Source 
var CreateDataItems uint = 100
View Source 
var UpdateDataItemHint = hint.MustNewHint("mitum-storage-update-data-item-v0.0.1")
View Source 
var UpdateDataItems uint = 100

Functions

func NewCreateDataProcessor 

func NewCreateDataProcessor() ctypes.GetNewProcessor

func NewDeleteDataProcessor 

func NewDeleteDataProcessor() crtypes.GetNewProcessor

func NewRegisterModelProcessor 

func NewRegisterModelProcessor() ctypes.GetNewProcessor

func NewUpdateDataProcessor 

func NewUpdateDataProcessor() ctypes.GetNewProcessor

Types

type CreateData 

type CreateData struct {
	extras.ExtendedOperation
}

func NewCreateData 

func NewCreateData(fact CreateDataFact) (CreateData, error)

func (*CreateData) DecodeBSON 

func (op *CreateData) DecodeBSON(b []byte, enc *bsonenc.Encoder) error

func (*CreateData) DecodeJSON 

func (op *CreateData) DecodeJSON(b []byte, enc encoder.Encoder) error

func (CreateData) DupKey 

func (op CreateData) DupKey() (map[ctypes.DuplicationKeyType][]string, error)

func (CreateData) MarshalBSON 

func (op CreateData) MarshalBSON() ([]byte, error)

func (CreateData) MarshalJSON 

func (op CreateData) MarshalJSON() ([]byte, error)

func (CreateData) Process 

func (CreateData) Process(
	_ context.Context, _ base.GetStateFunc,
) ([]base.StateMergeValue, base.OperationProcessReasonError, error)

type CreateDataFact 

type CreateDataFact struct {
	mitumbase.BaseFact
	// contains filtered or unexported fields
}

func NewCreateDataFact 

func NewCreateDataFact(
	token []byte,
	sender mitumbase.Address,
	items []CreateDataItem,
	currency ctypes.CurrencyID,
) CreateDataFact

func (CreateDataFact) ActiveContractOwnerHandlerOnly 

func (fact CreateDataFact) ActiveContractOwnerHandlerOnly() [][2]mitumbase.Address

func (CreateDataFact) Addresses 

func (fact CreateDataFact) Addresses() ([]mitumbase.Address, error)

func (CreateDataFact) Bytes 

func (fact CreateDataFact) Bytes() []byte

func (CreateDataFact) Currency 

func (fact CreateDataFact) Currency() ctypes.CurrencyID

func (*CreateDataFact) DecodeBSON 

func (fact *CreateDataFact) DecodeBSON(b []byte, enc *bsonenc.Encoder) error

func (*CreateDataFact) DecodeJSON 

func (fact *CreateDataFact) DecodeJSON(b []byte, enc encoder.Encoder) error

func (CreateDataFact) DupKey 

func (fact CreateDataFact) DupKey() (map[ctypes.DuplicationKeyType][]string, error)

func (CreateDataFact) FactUser 

func (fact CreateDataFact) FactUser() mitumbase.Address

func (CreateDataFact) FeeBase 

func (fact CreateDataFact) FeeBase() (ctypes.CurrencyID, int, int, bool)

func (CreateDataFact) FeePayer 

func (fact CreateDataFact) FeePayer() mitumbase.Address

func (CreateDataFact) GenerateHash 

func (fact CreateDataFact) GenerateHash() util.Hash

func (CreateDataFact) Hash 

func (fact CreateDataFact) Hash() util.Hash

func (CreateDataFact) IsValid 

func (fact CreateDataFact) IsValid(b []byte) error

func (CreateDataFact) Items 

func (fact CreateDataFact) Items() []CreateDataItem

func (CreateDataFact) MarshalBSON 

func (fact CreateDataFact) MarshalBSON() ([]byte, error)

func (CreateDataFact) MarshalJSON 

func (fact CreateDataFact) MarshalJSON() ([]byte, error)

func (CreateDataFact) Sender 

func (fact CreateDataFact) Sender() mitumbase.Address

func (CreateDataFact) Signer 

func (fact CreateDataFact) Signer() mitumbase.Address

func (CreateDataFact) Token 

func (fact CreateDataFact) Token() mitumbase.Token

type CreateDataFactBSONUnmarshaler 

type CreateDataFactBSONUnmarshaler struct {
	Hint     string   `bson:"_hint"`
	Sender   string   `bson:"sender"`
	Items    bson.Raw `bson:"items"`
	Currency string   `bson:"currency"`
}

type CreateDataFactJSONMarshaler 

type CreateDataFactJSONMarshaler struct {
	base.BaseFactJSONMarshaler
	Sender   base.Address      `json:"sender"`
	Items    []CreateDataItem  `json:"items"`
	Currency ctypes.CurrencyID `json:"currency"`
}

type CreateDataFactJSONUnMarshaler 

type CreateDataFactJSONUnMarshaler struct {
	base.BaseFactJSONUnmarshaler
	Sender   string          `json:"sender"`
	Items    json.RawMessage `json:"items"`
	Currency string          `json:"currency"`
}

type CreateDataItem 

type CreateDataItem struct {
	hint.BaseHinter
	// contains filtered or unexported fields
}

func NewCreateDataItem 

func NewCreateDataItem(
	contract base.Address,
	key, value string,
) CreateDataItem

func (CreateDataItem) Addresses 

func (it CreateDataItem) Addresses() []base.Address

func (CreateDataItem) Bytes 

func (it CreateDataItem) Bytes() []byte

func (CreateDataItem) Contract 

func (it CreateDataItem) Contract() base.Address

func (CreateDataItem) DataKey 

func (it CreateDataItem) DataKey() string

func (CreateDataItem) DataValue 

func (it CreateDataItem) DataValue() string

func (*CreateDataItem) DecodeBSON 

func (it *CreateDataItem) DecodeBSON(b []byte, enc *bsonenc.Encoder) error

func (*CreateDataItem) DecodeJSON 

func (it *CreateDataItem) DecodeJSON(b []byte, enc encoder.Encoder) error

func (CreateDataItem) IsValid 

func (it CreateDataItem) IsValid([]byte) error

func (CreateDataItem) MarshalBSON 

func (it CreateDataItem) MarshalBSON() ([]byte, error)

func (CreateDataItem) MarshalJSON 

func (it CreateDataItem) MarshalJSON() ([]byte, error)

type CreateDataItemBSONUnmarshaler 

type CreateDataItemBSONUnmarshaler struct {
	Hint      string `bson:"_hint"`
	Contract  string `bson:"contract"`
	DataKey   string `bson:"data_key"`
	DataValue string `bson:"data_value"`
}

type CreateDataItemJSONMarshaler 

type CreateDataItemJSONMarshaler struct {
	hint.BaseHinter
	Contract  base.Address `json:"contract"`
	DataKey   string       `json:"dataKey"`
	DataValue string       `json:"dataValue"`
}

type CreateDataItemJSONUnMarshaler 

type CreateDataItemJSONUnMarshaler struct {
	Hint      hint.Hint `json:"_hint"`
	Contract  string    `json:"contract"`
	DataKey   string    `json:"dataKey"`
	DataValue string    `json:"dataValue"`
}

type CreateDataItemProcessor 

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

func (*CreateDataItemProcessor) Close 

func (ipp *CreateDataItemProcessor) Close()

func (*CreateDataItemProcessor) PreProcess 

func (ipp *CreateDataItemProcessor) PreProcess(
	_ context.Context, _ base.Operation, getStateFunc base.GetStateFunc,
) error

func (*CreateDataItemProcessor) Process 

func (ipp *CreateDataItemProcessor) Process(
	_ context.Context, _ base.Operation, _ base.GetStateFunc,
) ([]base.StateMergeValue, error)

type CreateDataProcessor 

type CreateDataProcessor struct {
	*base.BaseOperationProcessor
}

func (*CreateDataProcessor) Close 

func (opp *CreateDataProcessor) Close() error

func (*CreateDataProcessor) PreProcess 

func (opp *CreateDataProcessor) PreProcess(
	ctx context.Context, op base.Operation, getStateFunc base.GetStateFunc,
) (context.Context, base.OperationProcessReasonError, error)

func (*CreateDataProcessor) Process 

func (opp *CreateDataProcessor) Process(
	ctx context.Context, op base.Operation, getStateFunc base.GetStateFunc) (
	[]base.StateMergeValue, base.OperationProcessReasonError, error,
)

type DataItem 

type DataItem interface {
	util.Byter
	util.IsValider
}

type DeleteData 

type DeleteData struct {
	extras.ExtendedOperation
}

func NewDeleteData 

func NewDeleteData(fact DeleteDataFact) (DeleteData, error)

func (*DeleteData) DecodeBSON 

func (op *DeleteData) DecodeBSON(b []byte, enc *bsonenc.Encoder) error

func (*DeleteData) DecodeJSON 

func (op *DeleteData) DecodeJSON(b []byte, enc encoder.Encoder) error

func (DeleteData) DupKey 

func (op DeleteData) DupKey() (map[ctypes.DuplicationKeyType][]string, error)

func (DeleteData) MarshalBSON 

func (op DeleteData) MarshalBSON() ([]byte, error)

func (DeleteData) MarshalJSON 

func (op DeleteData) MarshalJSON() ([]byte, error)

func (DeleteData) Process 

func (DeleteData) Process(
	_ context.Context, _ mitumbase.GetStateFunc,
) ([]mitumbase.StateMergeValue, mitumbase.OperationProcessReasonError, error)

type DeleteDataFact 

type DeleteDataFact struct {
	mitumbase.BaseFact
	// contains filtered or unexported fields
}

func NewDeleteDataFact 

func NewDeleteDataFact(
	token []byte, sender, contract mitumbase.Address,
	key string, currency ctypes.CurrencyID) DeleteDataFact

func (DeleteDataFact) ActiveContractOwnerHandlerOnly 

func (fact DeleteDataFact) ActiveContractOwnerHandlerOnly() [][2]mitumbase.Address

func (DeleteDataFact) Addresses 

func (fact DeleteDataFact) Addresses() ([]mitumbase.Address, error)

func (DeleteDataFact) Bytes 

func (fact DeleteDataFact) Bytes() []byte

func (DeleteDataFact) Contract 

func (fact DeleteDataFact) Contract() mitumbase.Address

func (DeleteDataFact) Currency 

func (fact DeleteDataFact) Currency() ctypes.CurrencyID

func (DeleteDataFact) DataKey 

func (fact DeleteDataFact) DataKey() string

func (*DeleteDataFact) DecodeBSON 

func (fact *DeleteDataFact) DecodeBSON(b []byte, enc *bsonenc.Encoder) error

func (*DeleteDataFact) DecodeJSON 

func (fact *DeleteDataFact) DecodeJSON(b []byte, enc encoder.Encoder) error

func (DeleteDataFact) DupKey 

func (fact DeleteDataFact) DupKey() (map[ctypes.DuplicationKeyType][]string, error)

func (DeleteDataFact) FactUser 

func (fact DeleteDataFact) FactUser() mitumbase.Address

func (DeleteDataFact) FeeBase 

func (fact DeleteDataFact) FeeBase() (ctypes.CurrencyID, int, int, bool)

func (DeleteDataFact) FeePayer 

func (fact DeleteDataFact) FeePayer() mitumbase.Address

func (DeleteDataFact) GenerateHash 

func (fact DeleteDataFact) GenerateHash() util.Hash

func (DeleteDataFact) Hash 

func (fact DeleteDataFact) Hash() util.Hash

func (DeleteDataFact) IsValid 

func (fact DeleteDataFact) IsValid(b []byte) error

func (DeleteDataFact) MarshalBSON 

func (fact DeleteDataFact) MarshalBSON() ([]byte, error)

func (DeleteDataFact) MarshalJSON 

func (fact DeleteDataFact) MarshalJSON() ([]byte, error)

func (DeleteDataFact) Sender 

func (fact DeleteDataFact) Sender() mitumbase.Address

func (DeleteDataFact) Signer 

func (fact DeleteDataFact) Signer() mitumbase.Address

func (DeleteDataFact) Token 

func (fact DeleteDataFact) Token() mitumbase.Token

type DeleteDataFactBSONUnmarshaler 

type DeleteDataFactBSONUnmarshaler struct {
	Hint     string `bson:"_hint"`
	Sender   string `bson:"sender"`
	Contract string `bson:"contract"`
	DataKey  string `bson:"data_key"`
	Currency string `bson:"currency"`
}

type DeleteDataFactJSONMarshaler 

type DeleteDataFactJSONMarshaler struct {
	mitumbase.BaseFactJSONMarshaler
	Sender   mitumbase.Address `json:"sender"`
	Contract mitumbase.Address `json:"contract"`
	DataKey  string            `json:"dataKey"`
	Currency types.CurrencyID  `json:"currency"`
}

type DeleteDataFactJSONUnmarshaler 

type DeleteDataFactJSONUnmarshaler struct {
	mitumbase.BaseFactJSONUnmarshaler
	Sender   string `json:"sender"`
	Contract string `json:"contract"`
	DataKey  string `json:"dataKey"`
	Currency string `json:"currency"`
}

type DeleteDataProcessor 

type DeleteDataProcessor struct {
	*mitumbase.BaseOperationProcessor
}

func (*DeleteDataProcessor) Close 

func (opp *DeleteDataProcessor) Close() error

func (*DeleteDataProcessor) PreProcess 

func (opp *DeleteDataProcessor) PreProcess(
	ctx context.Context, op mitumbase.Operation, getStateFunc mitumbase.GetStateFunc,
) (context.Context, mitumbase.OperationProcessReasonError, error)

func (*DeleteDataProcessor) Process 

func (opp *DeleteDataProcessor) Process(
	_ context.Context, op mitumbase.Operation, getStateFunc mitumbase.GetStateFunc) (
	[]mitumbase.StateMergeValue, mitumbase.OperationProcessReasonError, error,
)

type OperationMarshaler 

type OperationMarshaler struct {
	common.BaseOperationJSONMarshaler
	extras.BaseOperationExtensionsJSONMarshaler
}

type RegisterModel 

type RegisterModel struct {
	extras.ExtendedOperation
}

func NewRegisterModel 

func NewRegisterModel(fact RegisterModelFact) RegisterModel

func (*RegisterModel) DecodeBSON 

func (op *RegisterModel) DecodeBSON(b []byte, enc *bsonenc.Encoder) error

func (*RegisterModel) DecodeJSON 

func (op *RegisterModel) DecodeJSON(b []byte, enc encoder.Encoder) error

func (RegisterModel) DupKey 

func (op RegisterModel) DupKey() (map[ctypes.DuplicationKeyType][]string, error)

func (RegisterModel) MarshalBSON 

func (op RegisterModel) MarshalBSON() ([]byte, error)

func (RegisterModel) MarshalJSON 

func (op RegisterModel) MarshalJSON() ([]byte, error)

type RegisterModelFact 

type RegisterModelFact struct {
	mitumbase.BaseFact
	// contains filtered or unexported fields
}

func NewRegisterModelFact 

func NewRegisterModelFact(token []byte, sender, contract mitumbase.Address, project string, currency ctypes.CurrencyID) RegisterModelFact

func (RegisterModelFact) Addresses 

func (fact RegisterModelFact) Addresses() ([]mitumbase.Address, error)

func (RegisterModelFact) Bytes 

func (fact RegisterModelFact) Bytes() []byte

func (RegisterModelFact) Contract 

func (fact RegisterModelFact) Contract() mitumbase.Address

func (RegisterModelFact) Currency 

func (fact RegisterModelFact) Currency() ctypes.CurrencyID

func (*RegisterModelFact) DecodeBSON 

func (fact *RegisterModelFact) DecodeBSON(b []byte, enc *bsonenc.Encoder) error

func (*RegisterModelFact) DecodeJSON 

func (fact *RegisterModelFact) DecodeJSON(b []byte, enc encoder.Encoder) error

func (RegisterModelFact) DupKey 

func (fact RegisterModelFact) DupKey() (map[ctypes.DuplicationKeyType][]string, error)

func (RegisterModelFact) FactUser 

func (fact RegisterModelFact) FactUser() mitumbase.Address

func (RegisterModelFact) FeeBase 

func (fact RegisterModelFact) FeeBase() (ctypes.CurrencyID, int, int, bool)

func (RegisterModelFact) FeePayer 

func (fact RegisterModelFact) FeePayer() mitumbase.Address

func (RegisterModelFact) GenerateHash 

func (fact RegisterModelFact) GenerateHash() util.Hash

func (RegisterModelFact) Hash 

func (fact RegisterModelFact) Hash() util.Hash

func (RegisterModelFact) InActiveContractOwnerHandlerOnly 

func (fact RegisterModelFact) InActiveContractOwnerHandlerOnly() [][2]mitumbase.Address

func (RegisterModelFact) IsValid 

func (fact RegisterModelFact) IsValid(b []byte) error

func (RegisterModelFact) MarshalBSON 

func (fact RegisterModelFact) MarshalBSON() ([]byte, error)

func (RegisterModelFact) MarshalJSON 

func (fact RegisterModelFact) MarshalJSON() ([]byte, error)

func (RegisterModelFact) Project 

func (fact RegisterModelFact) Project() string

func (RegisterModelFact) Sender 

func (fact RegisterModelFact) Sender() mitumbase.Address

func (RegisterModelFact) Signer 

func (fact RegisterModelFact) Signer() mitumbase.Address

func (RegisterModelFact) Token 

func (fact RegisterModelFact) Token() mitumbase.Token

type RegisterModelFactBSONUnmarshaler 

type RegisterModelFactBSONUnmarshaler struct {
	Hint     string `bson:"_hint"`
	Sender   string `bson:"sender"`
	Contract string `bson:"contract"`
	Project  string `bson:"project"`
	Currency string `bson:"currency"`
}

type RegisterModelFactJSONMarshaler 

type RegisterModelFactJSONMarshaler struct {
	mitumbase.BaseFactJSONMarshaler
	Sender   mitumbase.Address `json:"sender"`
	Contract mitumbase.Address `json:"contract"`
	Project  string            `json:"project"`
	Currency types.CurrencyID  `json:"currency"`
}

type RegisterModelFactJSONUnmarshaler 

type RegisterModelFactJSONUnmarshaler struct {
	mitumbase.BaseFactJSONUnmarshaler
	Sender   string `json:"sender"`
	Contract string `json:"contract"`
	Project  string `json:"project"`
	Currency string `json:"currency"`
}

type RegisterModelProcessor 

type RegisterModelProcessor struct {
	*mitumbase.BaseOperationProcessor
}

func (*RegisterModelProcessor) Close 

func (opp *RegisterModelProcessor) Close() error

func (*RegisterModelProcessor) PreProcess 

func (opp *RegisterModelProcessor) PreProcess(
	ctx context.Context, op mitumbase.Operation, getStateFunc mitumbase.GetStateFunc,
) (context.Context, mitumbase.OperationProcessReasonError, error)

func (*RegisterModelProcessor) Process 

func (opp *RegisterModelProcessor) Process(
	_ context.Context, op mitumbase.Operation, getStateFunc mitumbase.GetStateFunc) (
	[]mitumbase.StateMergeValue, mitumbase.OperationProcessReasonError, error,
)

type UpdateData 

type UpdateData struct {
	extras.ExtendedOperation
}

func NewUpdateData 

func NewUpdateData(fact UpdateDataFact) (UpdateData, error)

func (*UpdateData) DecodeBSON 

func (op *UpdateData) DecodeBSON(b []byte, enc *bsonenc.Encoder) error

func (*UpdateData) DecodeJSON 

func (op *UpdateData) DecodeJSON(b []byte, enc encoder.Encoder) error

func (UpdateData) DupKey 

func (op UpdateData) DupKey() (map[types.DuplicationKeyType][]string, error)

func (UpdateData) MarshalBSON 

func (op UpdateData) MarshalBSON() ([]byte, error)

func (UpdateData) MarshalJSON 

func (op UpdateData) MarshalJSON() ([]byte, error)

func (UpdateData) Process 

func (UpdateData) Process(
	_ context.Context, _ base.GetStateFunc,
) ([]base.StateMergeValue, base.OperationProcessReasonError, error)

type UpdateDataFact 

type UpdateDataFact struct {
	mitumbase.BaseFact
	// contains filtered or unexported fields
}

func NewUpdateDataFact 

func NewUpdateDataFact(
	token []byte,
	sender mitumbase.Address,
	items []UpdateDataItem,
	currency types.CurrencyID,
) UpdateDataFact

func (UpdateDataFact) ActiveContractOwnerHandlerOnly 

func (fact UpdateDataFact) ActiveContractOwnerHandlerOnly() [][2]mitumbase.Address

func (UpdateDataFact) Addresses 

func (fact UpdateDataFact) Addresses() ([]mitumbase.Address, error)

func (UpdateDataFact) Bytes 

func (fact UpdateDataFact) Bytes() []byte

func (UpdateDataFact) Currency 

func (fact UpdateDataFact) Currency() types.CurrencyID

func (*UpdateDataFact) DecodeBSON 

func (fact *UpdateDataFact) DecodeBSON(b []byte, enc *bsonenc.Encoder) error

func (*UpdateDataFact) DecodeJSON 

func (fact *UpdateDataFact) DecodeJSON(b []byte, enc encoder.Encoder) error

func (UpdateDataFact) DupKey 

func (fact UpdateDataFact) DupKey() (map[types.DuplicationKeyType][]string, error)

func (UpdateDataFact) FactUser 

func (fact UpdateDataFact) FactUser() mitumbase.Address

func (UpdateDataFact) FeeBase 

func (fact UpdateDataFact) FeeBase() (types.CurrencyID, int, int, bool)

func (UpdateDataFact) FeePayer 

func (fact UpdateDataFact) FeePayer() mitumbase.Address

func (UpdateDataFact) GenerateHash 

func (fact UpdateDataFact) GenerateHash() util.Hash

func (UpdateDataFact) Hash 

func (fact UpdateDataFact) Hash() util.Hash

func (UpdateDataFact) IsValid 

func (fact UpdateDataFact) IsValid(b []byte) error

func (UpdateDataFact) Items 

func (fact UpdateDataFact) Items() []UpdateDataItem

func (UpdateDataFact) MarshalBSON 

func (fact UpdateDataFact) MarshalBSON() ([]byte, error)

func (UpdateDataFact) MarshalJSON 

func (fact UpdateDataFact) MarshalJSON() ([]byte, error)

func (UpdateDataFact) Sender 

func (fact UpdateDataFact) Sender() mitumbase.Address

func (UpdateDataFact) Signer 

func (fact UpdateDataFact) Signer() mitumbase.Address

func (UpdateDataFact) Token 

func (fact UpdateDataFact) Token() mitumbase.Token

type UpdateDataFactBSONUnmarshaler 

type UpdateDataFactBSONUnmarshaler struct {
	Hint     string   `bson:"_hint"`
	Sender   string   `bson:"sender"`
	Items    bson.Raw `bson:"items"`
	Currency string   `bson:"currency"`
}

type UpdateDataFactJSONMarshaler 

type UpdateDataFactJSONMarshaler struct {
	base.BaseFactJSONMarshaler
	Sender   base.Address     `json:"sender"`
	Items    []UpdateDataItem `json:"items"`
	Currency types.CurrencyID `json:"currency"`
}

type UpdateDataFactJSONUnMarshaler 

type UpdateDataFactJSONUnMarshaler struct {
	base.BaseFactJSONUnmarshaler
	Sender   string          `json:"sender"`
	Items    json.RawMessage `json:"items"`
	Currency string          `json:"currency"`
}

type UpdateDataItem 

type UpdateDataItem struct {
	hint.BaseHinter
	// contains filtered or unexported fields
}

func NewUpdateDataItem 

func NewUpdateDataItem(
	contract base.Address,
	key, value string,
) UpdateDataItem

func (UpdateDataItem) Addresses 

func (it UpdateDataItem) Addresses() []base.Address

func (UpdateDataItem) Bytes 

func (it UpdateDataItem) Bytes() []byte

func (UpdateDataItem) Contract 

func (it UpdateDataItem) Contract() base.Address

func (UpdateDataItem) DataKey 

func (it UpdateDataItem) DataKey() string

func (UpdateDataItem) DataValue 

func (it UpdateDataItem) DataValue() string

func (*UpdateDataItem) DecodeBSON 

func (it *UpdateDataItem) DecodeBSON(b []byte, enc *bsonenc.Encoder) error

func (*UpdateDataItem) DecodeJSON 

func (it *UpdateDataItem) DecodeJSON(b []byte, enc encoder.Encoder) error

func (UpdateDataItem) IsValid 

func (it UpdateDataItem) IsValid([]byte) error

func (UpdateDataItem) MarshalBSON 

func (it UpdateDataItem) MarshalBSON() ([]byte, error)

func (UpdateDataItem) MarshalJSON 

func (it UpdateDataItem) MarshalJSON() ([]byte, error)

type UpdateDataItemBSONUnmarshaler 

type UpdateDataItemBSONUnmarshaler struct {
	Hint      string `bson:"_hint"`
	Contract  string `bson:"contract"`
	DataKey   string `bson:"data_key"`
	DataValue string `bson:"data_value"`
}

type UpdateDataItemJSONMarshaler 

type UpdateDataItemJSONMarshaler struct {
	hint.BaseHinter
	Contract  base.Address `json:"contract"`
	DataKey   string       `json:"dataKey"`
	DataValue string       `json:"dataValue"`
}

type UpdateDataItemJSONUnMarshaler 

type UpdateDataItemJSONUnMarshaler struct {
	Hint      hint.Hint `json:"_hint"`
	Contract  string    `json:"contract"`
	DataKey   string    `json:"dataKey"`
	DataValue string    `json:"dataValue"`
}

type UpdateDataItemProcessor 

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

func (*UpdateDataItemProcessor) Close 

func (ipp *UpdateDataItemProcessor) Close()

func (*UpdateDataItemProcessor) PreProcess 

func (ipp *UpdateDataItemProcessor) PreProcess(
	_ context.Context, _ base.Operation, getStateFunc base.GetStateFunc,
) error

func (*UpdateDataItemProcessor) Process 

func (ipp *UpdateDataItemProcessor) Process(
	_ context.Context, _ base.Operation, getStateFunc base.GetStateFunc,
) ([]base.StateMergeValue, error)

type UpdateDataProcessor 

type UpdateDataProcessor struct {
	*base.BaseOperationProcessor
}

func (*UpdateDataProcessor) Close 

func (opp *UpdateDataProcessor) Close() error

func (*UpdateDataProcessor) PreProcess 

func (opp *UpdateDataProcessor) PreProcess(
	ctx context.Context, op base.Operation, getStateFunc base.GetStateFunc,
) (context.Context, base.OperationProcessReasonError, error)

func (*UpdateDataProcessor) Process 

func (opp *UpdateDataProcessor) Process(
	ctx context.Context, op base.Operation, getStateFunc base.GetStateFunc) (
	[]base.StateMergeValue, base.OperationProcessReasonError, error,
)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.