rpcstandards

Documentation

Index

• Variables
• type RpcService
  • func NewRpcService(db db.Adapter, pool *clients.ClientPool, nats *nats.Conn, cache *cache.Redis) *RpcService
  • func (s RpcService) All(ctx context.Context, networkId utils.NetworkID, limit uint, offset uint) ([]*rpctypes.Standard, *zenrpc.Error)
  • func (s RpcService) AllByConfidence(ctx context.Context, networkId utils.NetworkID, confidences []string, ...) ([]*rpctypes.Standard, *zenrpc.Error)
  • func (s RpcService) AllByTypes(ctx context.Context, networkId utils.NetworkID, types []string, limit uint, ...) ([]*rpctypes.Standard, *zenrpc.Error)
  • func (s RpcService) AllByTypesAndConfidence(ctx context.Context, networkId utils.NetworkID, types []string, ...) ([]*rpctypes.Standard, *zenrpc.Error)
  • func (s RpcService) GetByContract(ctx context.Context, networkId utils.NetworkID, address common.Address, ...) ([]*rpctypes.Standard, *zenrpc.Error)
  • func (s RpcService) GetByContractAndConfidence(ctx context.Context, networkId utils.NetworkID, address common.Address, ...) ([]*rpctypes.Standard, *zenrpc.Error)
  • func (s RpcService) GetByContractAndType(ctx context.Context, networkId utils.NetworkID, address common.Address, ...) ([]*rpctypes.Standard, *zenrpc.Error)
  • func (s RpcService) GetByContractAndTypeAndConfidence(ctx context.Context, networkId utils.NetworkID, address common.Address, ...) ([]*rpctypes.Standard, *zenrpc.Error)
  • func (s RpcService) Invoke(ctx context.Context, w http.ResponseWriter, method string, ...) zenrpc.Response
  • func (RpcService) SMD() smd.ServiceInfo

Variables

var RPC = struct {
	RpcService struct{ All, AllByTypes, AllByConfidence, AllByTypesAndConfidence, GetByContract, GetByContractAndType, GetByContractAndConfidence, GetByContractAndTypeAndConfidence string }
}{
	RpcService: struct{ All, AllByTypes, AllByConfidence, AllByTypesAndConfidence, GetByContract, GetByContractAndType, GetByContractAndConfidence, GetByContractAndTypeAndConfidence string }{
		All:                               "all",
		AllByTypes:                        "allbytypes",
		AllByConfidence:                   "allbyconfidence",
		AllByTypesAndConfidence:           "allbytypesandconfidence",
		GetByContract:                     "getbycontract",
		GetByContractAndType:              "getbycontractandtype",
		GetByContractAndConfidence:        "getbycontractandconfidence",
		GetByContractAndTypeAndConfidence: "getbycontractandtypeandconfidence",
	},
}

Types

type RpcService

type RpcService struct {
	zenrpc.Service
	// contains filtered or unexported fields
}

func NewRpcService

func NewRpcService(db db.Adapter, pool *clients.ClientPool, nats *nats.Conn, cache *cache.Redis) *RpcService

func (RpcService) All

func (s RpcService) All(ctx context.Context, networkId utils.NetworkID, limit uint, offset uint) ([]*rpctypes.Standard, *zenrpc.Error)

func (RpcService) AllByConfidence

func (s RpcService) AllByConfidence(ctx context.Context, networkId utils.NetworkID, confidences []string, limit uint, offset uint) ([]*rpctypes.Standard, *zenrpc.Error)

func (RpcService) AllByTypes

func (s RpcService) AllByTypes(ctx context.Context, networkId utils.NetworkID, types []string, limit uint, offset uint) ([]*rpctypes.Standard, *zenrpc.Error)

func (RpcService) AllByTypesAndConfidence

func (s RpcService) AllByTypesAndConfidence(ctx context.Context, networkId utils.NetworkID, types []string, confidences []string, limit uint, offset uint) ([]*rpctypes.Standard, *zenrpc.Error)

func (RpcService) GetByContract

func (s RpcService) GetByContract(ctx context.Context, networkId utils.NetworkID, address common.Address, limit uint, offset uint) ([]*rpctypes.Standard, *zenrpc.Error)

func (RpcService) GetByContractAndConfidence

func (s RpcService) GetByContractAndConfidence(ctx context.Context, networkId utils.NetworkID, address common.Address, confidences []string, limit uint, offset uint) ([]*rpctypes.Standard, *zenrpc.Error)

func (RpcService) GetByContractAndType

func (s RpcService) GetByContractAndType(ctx context.Context, networkId utils.NetworkID, address common.Address, types []string, limit uint, offset uint) ([]*rpctypes.Standard, *zenrpc.Error)

func (RpcService) GetByContractAndTypeAndConfidence

func (s RpcService) GetByContractAndTypeAndConfidence(ctx context.Context, networkId utils.NetworkID, address common.Address, types []string, confidences []string, limit uint, offset uint) ([]*rpctypes.Standard, *zenrpc.Error)

func (RpcService) Invoke

func (s RpcService) Invoke(ctx context.Context, w http.ResponseWriter, method string, params json.RawMessage) zenrpc.Response

Invoke is as generated code from zenrpc cmd

func (RpcService) SMD

func (RpcService) SMD() smd.ServiceInfo