rpcx

type Client ¶

type Client interface {
	Call(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error
	Close() error
}

Client defines interface for a client to make contextual remote calls.

type ClientMock ¶

type ClientMock struct {
	// CallFunc mocks the Call method.
	CallFunc func(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error

	// CloseFunc mocks the Close method.
	CloseFunc func() error
	// contains filtered or unexported fields
}

ClientMock is a mock implementation of Client.

func TestSomethingThatUsesClient(t *testing.T) {

	// make and configure a mocked Client
	mockedClient := &ClientMock{
		CallFunc: func(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error {
			panic("mock out the Call method")
		},
		CloseFunc: func() error {
			panic("mock out the Close method")
		},
	}

	// use mockedClient in code that requires Client
	// and then make assertions.

}

func (mock *ClientMock) Call(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error

func (mock *ClientMock) CallCalls() []struct {
	Ctx           context.Context
	ServiceMethod string
	Args          interface{}
	Reply         interface{}
}

len(mockedClient.CallCalls())

func (mock *ClientMock) Close() error

func (mock *ClientMock) CloseCalls() []struct {
}

len(mockedClient.CloseCalls())

type Dialer ¶

type Dialer interface {
	Dial(network, address string) (RPCClient, error)
}

Dialer is a maker interface dialing to rpc server and returning new Client

func JSONRPC() Dialer

type DialerFunc ¶

type DialerFunc func(network, address string) (RPCClient, error)

DialerFunc is an adapter to use ordinary functions as Dialer.

func (f DialerFunc) Dial(network, addr string) (RPCClient, error)

type RPCClient ¶

type RPCClient interface {
	Call(serviceMethod string, args interface{}, reply interface{}) error
	Close() error
}

RPCClient describes a pure standard library rpc client.

type Redialer ¶

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

Redialer redials the RPC server with the provided repeating strategy, in case if Call has been failed.

func NewRedialer(dialer Dialer, strtg strategy.Interface, network, addr string) (*Redialer, error)

func (r *Redialer) Call(ctx context.Context, serviceMethod string, args interface{}, reply interface{}) error

func (r *Redialer) Close() error