contractrequester

Documentation

Index

• type ContractRequester
  • func New() (*ContractRequester, error)
  • func (cr *ContractRequester) CallConstructor(ctx context.Context, base core.Message, async bool, prototype *core.RecordRef, ...) (*core.RecordRef, error)
  • func (cr *ContractRequester) CallMethod(ctx context.Context, base core.Message, async bool, ref *core.RecordRef, ...) (core.Reply, error)
  • func (cr *ContractRequester) ReceiveResult(ctx context.Context, parcel core.Parcel) (core.Reply, error)
  • func (cr *ContractRequester) SendRequest(ctx context.Context, ref *core.RecordRef, method string, argsIn []interface{}) (core.Reply, error)
  • func (cr *ContractRequester) Start(ctx context.Context) error

Types

type ContractRequester

type ContractRequester struct {
	MessageBus   core.MessageBus   `inject:""`
	PulseStorage core.PulseStorage `inject:""`
	ResultMutex  sync.Mutex
	ResultMap    map[uint64]chan *message.ReturnResults
	Sequence     uint64
}

ContractRequester helps to call contracts

func New

func New() (*ContractRequester, error)

New creates new ContractRequester

func (*ContractRequester) CallConstructor

func (cr *ContractRequester) CallConstructor(ctx context.Context, base core.Message, async bool,
	prototype *core.RecordRef, to *core.RecordRef, method string,
	argsIn core.Arguments, saveAs int) (*core.RecordRef, error)

func (*ContractRequester) CallMethod

func (cr *ContractRequester) CallMethod(ctx context.Context, base core.Message, async bool, ref *core.RecordRef, method string, argsIn core.Arguments, mustPrototype *core.RecordRef) (core.Reply, error)

func (*ContractRequester) ReceiveResult

func (cr *ContractRequester) ReceiveResult(ctx context.Context, parcel core.Parcel) (core.Reply, error)

func (*ContractRequester) SendRequest

func (cr *ContractRequester) SendRequest(ctx context.Context, ref *core.RecordRef, method string, argsIn []interface{}) (core.Reply, error)

SendRequest makes synchronously call to method of contract by its ref without additional information

func (*ContractRequester) Start

func (cr *ContractRequester) Start(ctx context.Context) error