storage

package
v0.0.0-...-9bc5e2b Latest Latest
Warning

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

 Go to latest Published: Nov 18, 2024 License: GPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

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 (
	CreateDatasFactHint = hint.MustNewHint("mitum-storage-create-datas-operation-fact-v0.0.1")
	CreateDatasHint     = hint.MustNewHint("mitum-storage-create-datas-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 (
	UpdateDatasFactHint = hint.MustNewHint("mitum-storage-update-datas-operation-fact-v0.0.1")
	UpdateDatasHint     = hint.MustNewHint("mitum-storage-update-datas-operation-v0.0.1")
)
View Source 
var CreateDatasItemHint = hint.MustNewHint("mitum-storage-create-datas-item-v0.0.1")
View Source 
var CreateDatasItems uint = 100
View Source 
var UpdateDatasItemHint = hint.MustNewHint("mitum-storage-update-datas-item-v0.0.1")
View Source 
var UpdateDatasItems uint = 100

Functions

func NewCreateDataProcessor 

func NewCreateDataProcessor() crtypes.GetNewProcessor

func NewCreateDatasProcessor 

func NewCreateDatasProcessor() currencytypes.GetNewProcessor

func NewDeleteDataProcessor 

func NewDeleteDataProcessor() crtypes.GetNewProcessor

func NewRegisterModelProcessor 

func NewRegisterModelProcessor() currencytypes.GetNewProcessor

func NewUpdateDataProcessor 

func NewUpdateDataProcessor() crtypes.GetNewProcessor

func NewUpdateDatasProcessor 

func NewUpdateDatasProcessor() currencytypes.GetNewProcessor

Types

type CreateData 

type CreateData struct {
	common.BaseOperation
}

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) MarshalBSON 

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

func (CreateData) MarshalJSON 

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

func (CreateData) Process 

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

type CreateDataFact 

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

func NewCreateDataFact 

func NewCreateDataFact(
	token []byte, sender, contract mitumbase.Address,
	key, value string, currency currencytypes.CurrencyID) CreateDataFact

func (CreateDataFact) Addresses 

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

func (CreateDataFact) Bytes 

func (fact CreateDataFact) Bytes() []byte

func (CreateDataFact) Contract 

func (fact CreateDataFact) Contract() mitumbase.Address

func (CreateDataFact) Currency 

func (fact CreateDataFact) Currency() currencytypes.CurrencyID

func (CreateDataFact) DataKey 

func (fact CreateDataFact) DataKey() string

func (CreateDataFact) DataValue 

func (fact CreateDataFact) DataValue() string

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) 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) 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) Token 

func (fact CreateDataFact) Token() mitumbase.Token

type CreateDataFactBSONUnmarshaler 

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

type CreateDataFactJSONMarshaler 

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

type CreateDataFactJSONUnmarshaler 

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

type CreateDataProcessor 

type CreateDataProcessor struct {
	*mitumbase.BaseOperationProcessor
}

func (*CreateDataProcessor) Close 

func (opp *CreateDataProcessor) Close() error

func (*CreateDataProcessor) PreProcess 

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

func (*CreateDataProcessor) Process 

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

type CreateDatas 

type CreateDatas struct {
	common.BaseOperation
}

func NewCreateDatas 

func NewCreateDatas(fact CreateDatasFact) (CreateDatas, error)

func (*CreateDatas) DecodeBSON 

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

func (*CreateDatas) DecodeJSON 

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

func (CreateDatas) MarshalBSON 

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

func (CreateDatas) MarshalJSON 

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

func (CreateDatas) Process 

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

type CreateDatasFact 

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

func NewCreateDatasFact 

func NewCreateDatasFact(
	token []byte, sender mitumbase.Address, items []CreateDatasItem) CreateDatasFact

func (CreateDatasFact) Addresses 

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

func (CreateDatasFact) Bytes 

func (fact CreateDatasFact) Bytes() []byte

func (*CreateDatasFact) DecodeBSON 

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

func (*CreateDatasFact) DecodeJSON 

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

func (CreateDatasFact) GenerateHash 

func (fact CreateDatasFact) GenerateHash() util.Hash

func (CreateDatasFact) Hash 

func (fact CreateDatasFact) Hash() util.Hash

func (CreateDatasFact) IsValid 

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

func (CreateDatasFact) Items 

func (fact CreateDatasFact) Items() []CreateDatasItem

func (CreateDatasFact) MarshalBSON 

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

func (CreateDatasFact) MarshalJSON 

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

func (CreateDatasFact) Sender 

func (fact CreateDatasFact) Sender() mitumbase.Address

func (CreateDatasFact) Token 

func (fact CreateDatasFact) Token() mitumbase.Token

type CreateDatasFactBSONUnmarshaler 

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

type CreateDatasFactJSONMarshaler 

type CreateDatasFactJSONMarshaler struct {
	base.BaseFactJSONMarshaler
	Sender base.Address      `json:"sender"`
	Items  []CreateDatasItem `json:"items"`
}

type CreateDatasFactJSONUnMarshaler 

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

type CreateDatasItem 

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

func NewCreateDatasItem 

func NewCreateDatasItem(
	contract base.Address,
	key, value string,
	currency crcytypes.CurrencyID,
) CreateDatasItem

func (CreateDatasItem) Addresses 

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

func (CreateDatasItem) Bytes 

func (it CreateDatasItem) Bytes() []byte

func (CreateDatasItem) Contract 

func (it CreateDatasItem) Contract() base.Address

func (CreateDatasItem) Currency 

func (it CreateDatasItem) Currency() crcytypes.CurrencyID

func (CreateDatasItem) DataKey 

func (it CreateDatasItem) DataKey() string

func (CreateDatasItem) DataValue 

func (it CreateDatasItem) DataValue() string

func (*CreateDatasItem) DecodeBSON 

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

func (*CreateDatasItem) DecodeJSON 

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

func (CreateDatasItem) IsValid 

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

func (CreateDatasItem) MarshalBSON 

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

func (CreateDatasItem) MarshalJSON 

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

type CreateDatasItemBSONUnmarshaler 

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

type CreateDatasItemJSONMarshaler 

type CreateDatasItemJSONMarshaler struct {
	hint.BaseHinter
	Contract  base.Address             `json:"contract"`
	DataKey   string                   `json:"dataKey"`
	DataValue string                   `json:"dataValue"`
	Currency  currencytypes.CurrencyID `json:"currency"`
}

type CreateDatasItemJSONUnMarshaler 

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

type CreateDatasItemProcessor 

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

func (*CreateDatasItemProcessor) Close 

func (ipp *CreateDatasItemProcessor) Close()

func (*CreateDatasItemProcessor) PreProcess 

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

func (*CreateDatasItemProcessor) Process 

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

type CreateDatasMarshaler 

type CreateDatasMarshaler struct {
	common.BaseOperationJSONMarshaler
}

type CreateDatasProcessor 

type CreateDatasProcessor struct {
	*base.BaseOperationProcessor
}

func (*CreateDatasProcessor) Close 

func (opp *CreateDatasProcessor) Close() error

func (*CreateDatasProcessor) PreProcess 

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

func (*CreateDatasProcessor) Process 

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

type DataItem 

type DataItem interface {
	util.Byter
	util.IsValider
	Currency() currencytypes.CurrencyID
}

type DeleteData 

type DeleteData struct {
	common.BaseOperation
}

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) 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 currencytypes.CurrencyID) DeleteDataFact

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() currencytypes.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) 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) 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 RegisterModel 

type RegisterModel struct {
	common.BaseOperation
}

func NewRegisterModel 

func NewRegisterModel(fact RegisterModelFact) (RegisterModel, error)

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) 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 types.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() types.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) GenerateHash 

func (fact RegisterModelFact) GenerateHash() util.Hash

func (RegisterModelFact) Hash 

func (fact RegisterModelFact) Hash() util.Hash

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) 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 {
	common.BaseOperation
}

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) MarshalBSON 

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

func (UpdateData) MarshalJSON 

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

func (UpdateData) Process 

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

type UpdateDataFact 

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

func NewUpdateDataFact 

func NewUpdateDataFact(
	token []byte, sender, contract mitumbase.Address,
	key, value string, currency currencytypes.CurrencyID) UpdateDataFact

func (UpdateDataFact) Addresses 

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

func (UpdateDataFact) Bytes 

func (fact UpdateDataFact) Bytes() []byte

func (UpdateDataFact) Contract 

func (fact UpdateDataFact) Contract() mitumbase.Address

func (UpdateDataFact) Currency 

func (fact UpdateDataFact) Currency() currencytypes.CurrencyID

func (UpdateDataFact) DataKey 

func (fact UpdateDataFact) DataKey() string

func (UpdateDataFact) DataValue 

func (fact UpdateDataFact) DataValue() string

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) 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) 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) Token 

func (fact UpdateDataFact) Token() mitumbase.Token

type UpdateDataFactBSONUnmarshaler 

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

type UpdateDataFactJSONMarshaler 

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

type UpdateDataFactJSONUnmarshaler 

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

type UpdateDataProcessor 

type UpdateDataProcessor struct {
	*mitumbase.BaseOperationProcessor
}

func (*UpdateDataProcessor) Close 

func (opp *UpdateDataProcessor) Close() error

func (*UpdateDataProcessor) PreProcess 

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

func (*UpdateDataProcessor) Process 

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

type UpdateDatas 

type UpdateDatas struct {
	common.BaseOperation
}

func NewUpdateDatas 

func NewUpdateDatas(fact UpdateDatasFact) (UpdateDatas, error)

func (*UpdateDatas) DecodeBSON 

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

func (*UpdateDatas) DecodeJSON 

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

func (UpdateDatas) MarshalBSON 

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

func (UpdateDatas) MarshalJSON 

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

func (UpdateDatas) Process 

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

type UpdateDatasFact 

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

func NewUpdateDatasFact 

func NewUpdateDatasFact(
	token []byte, sender mitumbase.Address, items []UpdateDatasItem) UpdateDatasFact

func (UpdateDatasFact) Addresses 

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

func (UpdateDatasFact) Bytes 

func (fact UpdateDatasFact) Bytes() []byte

func (*UpdateDatasFact) DecodeBSON 

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

func (*UpdateDatasFact) DecodeJSON 

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

func (UpdateDatasFact) GenerateHash 

func (fact UpdateDatasFact) GenerateHash() util.Hash

func (UpdateDatasFact) Hash 

func (fact UpdateDatasFact) Hash() util.Hash

func (UpdateDatasFact) IsValid 

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

func (UpdateDatasFact) Items 

func (fact UpdateDatasFact) Items() []UpdateDatasItem

func (UpdateDatasFact) MarshalBSON 

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

func (UpdateDatasFact) MarshalJSON 

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

func (UpdateDatasFact) Sender 

func (fact UpdateDatasFact) Sender() mitumbase.Address

func (UpdateDatasFact) Token 

func (fact UpdateDatasFact) Token() mitumbase.Token

type UpdateDatasFactBSONUnmarshaler 

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

type UpdateDatasFactJSONMarshaler 

type UpdateDatasFactJSONMarshaler struct {
	base.BaseFactJSONMarshaler
	Sender base.Address      `json:"sender"`
	Items  []UpdateDatasItem `json:"items"`
}

type UpdateDatasFactJSONUnMarshaler 

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

type UpdateDatasItem 

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

func NewUpdateDatasItem 

func NewUpdateDatasItem(
	contract base.Address,
	key, value string,
	currency crcytypes.CurrencyID,
) UpdateDatasItem

func (UpdateDatasItem) Addresses 

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

func (UpdateDatasItem) Bytes 

func (it UpdateDatasItem) Bytes() []byte

func (UpdateDatasItem) Contract 

func (it UpdateDatasItem) Contract() base.Address

func (UpdateDatasItem) Currency 

func (it UpdateDatasItem) Currency() crcytypes.CurrencyID

func (UpdateDatasItem) DataKey 

func (it UpdateDatasItem) DataKey() string

func (UpdateDatasItem) DataValue 

func (it UpdateDatasItem) DataValue() string

func (*UpdateDatasItem) DecodeBSON 

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

func (*UpdateDatasItem) DecodeJSON 

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

func (UpdateDatasItem) IsValid 

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

func (UpdateDatasItem) MarshalBSON 

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

func (UpdateDatasItem) MarshalJSON 

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

type UpdateDatasItemBSONUnmarshaler 

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

type UpdateDatasItemJSONMarshaler 

type UpdateDatasItemJSONMarshaler struct {
	hint.BaseHinter
	Contract  base.Address             `json:"contract"`
	DataKey   string                   `json:"dataKey"`
	DataValue string                   `json:"dataValue"`
	Currency  currencytypes.CurrencyID `json:"currency"`
}

type UpdateDatasItemJSONUnMarshaler 

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

type UpdateDatasItemProcessor 

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

func (*UpdateDatasItemProcessor) Close 

func (ipp *UpdateDatasItemProcessor) Close()

func (*UpdateDatasItemProcessor) PreProcess 

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

func (*UpdateDatasItemProcessor) Process 

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

type UpdateDatasMarshaler 

type UpdateDatasMarshaler struct {
	common.BaseOperationJSONMarshaler
}

type UpdateDatasProcessor 

type UpdateDatasProcessor struct {
	*base.BaseOperationProcessor
}

func (*UpdateDatasProcessor) Close 

func (opp *UpdateDatasProcessor) Close() error

func (*UpdateDatasProcessor) PreProcess 

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

func (*UpdateDatasProcessor) Process 

func (opp *UpdateDatasProcessor) 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.