storage

package
v0.0.0-...-0136f3d Latest Latest
Warning

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

 Go to latest Published: Sep 20, 2024 License: GPL-3.0 Imports: 17 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 (
	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")
)

Functions

func NewCreateDataProcessor 

func NewCreateDataProcessor() crtypes.GetNewProcessor

func NewDeleteDataProcessor 

func NewDeleteDataProcessor() crtypes.GetNewProcessor

func NewRegisterModelProcessor 

func NewRegisterModelProcessor() currencytypes.GetNewProcessor

func NewUpdateDataProcessor 

func NewUpdateDataProcessor() crtypes.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 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,
)

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.