rpc

Documentation

Overview

This package is a wrapper around github.com/cadmean-ru/goRPCKit library adapted for Amphion tasks system.

Index

• func Initialize(url string)
• type FunctionCallBuilder
  • func F(fName string) *FunctionCallBuilder
  • func (f *FunctionCallBuilder) Call(args ...interface{})
  • func (f *FunctionCallBuilder) Err(onError func(err error)) *FunctionCallBuilder
  • func (f *FunctionCallBuilder) Then(onSuccess func(res interface{})) *FunctionCallBuilder

Functions

func Initialize

func Initialize(url string)

Initialize creates a new instance of rpc client with specified url.

Types

type FunctionCallBuilder

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

func F

func F(fName string) *FunctionCallBuilder

Creates a new call builder to call an RPC function with the specified name.

func (*FunctionCallBuilder) Call

func (f *FunctionCallBuilder) Call(args ...interface{})

Creates and runs task, calling the RPC function with given arguments.

func (*FunctionCallBuilder) Err

func (f *FunctionCallBuilder) Err(onError func(err error)) *FunctionCallBuilder

Specifies callback to be called when the RPC call finishes with an error.

func (*FunctionCallBuilder) Then

func (f *FunctionCallBuilder) Then(onSuccess func(res interface{})) *FunctionCallBuilder

Specifies callback to be called when the RPC call finishes successfully.