api

Documentation

Index

• func MarshalArgs(args ...interface{}) (core.Arguments, error)
• func UnMarshalResponse(resp []byte, typeHolders []interface{}) ([]interface{}, error)
• type Params
• type QueryType
  • func QTypeFromString(strQType string) QueryType
• type RequestHandler
  • func NewRequestHandler(params *Params, router core.MessageRouter, rootDomainReference core.RecordRef) *RequestHandler
  • func (rh *RequestHandler) ProcessCreateMember() (map[string]interface{}, error)
  • func (rh *RequestHandler) ProcessDumpUsers(all bool) (map[string]interface{}, error)
  • func (rh *RequestHandler) ProcessGetBalance() (map[string]interface{}, error)
  • func (rh *RequestHandler) ProcessSendMoney() (map[string]interface{}, error)
• type Runner
  • func NewRunner(cfg *configuration.APIRunner) (*Runner, error)
  • func (ar *Runner) Start(c core.Components) error
  • func (ar *Runner) Stop() error

Functions

func MarshalArgs

func MarshalArgs(args ...interface{}) (core.Arguments, error)

MarshalArgs marshals arguments by cbor

func UnMarshalResponse

func UnMarshalResponse(resp []byte, typeHolders []interface{}) ([]interface{}, error)

UnMarshalResponse unmarshals return values by cbor

Types

type Params

type Params struct {
	QType     string `json:"query_type"`
	Name      string `json:"name"`
	Reference string `json:"reference"`
	From      string `json:"from"`
	To        string `json:"to"`
	QID       string `json:"qid"`
	Amount    int    `json:"amount"`
}

Params contains supported query params

type QueryType

type QueryType int

QueryType represents type of query

const (
	UNDEFINED QueryType = iota
	CreateMember
	DumpUserInfo
	GetBalance
	SendMoney
	DumpAllUsers
)

Supported query types

func QTypeFromString

func QTypeFromString(strQType string) QueryType

QTypeFromString converts string representation to enum

type RequestHandler

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

RequestHandler encapsulate processing of request

func NewRequestHandler

func NewRequestHandler(params *Params, router core.MessageRouter, rootDomainReference core.RecordRef) *RequestHandler

NewRequestHandler creates new query handler

func (*RequestHandler) ProcessCreateMember

func (rh *RequestHandler) ProcessCreateMember() (map[string]interface{}, error)

ProcessCreateMember processes CreateMember query type

func (*RequestHandler) ProcessDumpUsers

func (rh *RequestHandler) ProcessDumpUsers(all bool) (map[string]interface{}, error)

ProcessDumpUsers processes Dump users query type

func (*RequestHandler) ProcessGetBalance

func (rh *RequestHandler) ProcessGetBalance() (map[string]interface{}, error)

ProcessGetBalance processes get_balance query type

func (*RequestHandler) ProcessSendMoney

func (rh *RequestHandler) ProcessSendMoney() (map[string]interface{}, error)

ProcessSendMoney processes send_money query type

type Runner

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

Runner implements Component for API

func NewRunner

func NewRunner(cfg *configuration.APIRunner) (*Runner, error)

NewRunner is C-tor for API Runner

func (*Runner) Start

func (ar *Runner) Start(c core.Components) error

Start runs api server

func (*Runner) Stop

func (ar *Runner) Stop() error

Stop stops api server