plugin

type Conductor ¶

type Conductor struct {
	Address   string
	RPCDialer RPCDialer
	// contains filtered or unexported fields
}

Conductor accepts registrations from rpc plugins, keeps list of active/current plugins and provides middleware calling all of them.

func (c *Conductor) Middleware(next http.Handler) http.Handler

func (c *Conductor) Run(ctx context.Context) error

type Handler ¶

type Handler struct {
	Address string
	Method  string // full method name for rpc call, i.e. Plugin.Thing
	Alive   bool
	// contains filtered or unexported fields
}

Handler contains information about a plugin's handler

type RPCClient ¶

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

RPCClient defines interface for remote calls

type RPCClientMock ¶

type RPCClientMock struct {
	// CallFunc mocks the Call method.
	CallFunc func(serviceMethod string, args any, reply any) error
	// contains filtered or unexported fields
}

RPCClientMock is a mock implementation of RPCClient.

func TestSomethingThatUsesRPCClient(t *testing.T) {

	// make and configure a mocked RPCClient
	mockedRPCClient := &RPCClientMock{
		CallFunc: func(serviceMethod string, args any, reply any) error {
			panic("mock out the Call method")
		},
	}

	// use mockedRPCClient in code that requires RPCClient
	// and then make assertions.

}

func (mock *RPCClientMock) Call(serviceMethod string, args any, reply any) error

func (mock *RPCClientMock) CallCalls() []struct {
	ServiceMethod string
	Args          any
	Reply         any
}

len(mockedRPCClient.CallCalls())

type RPCDialer ¶

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

RPCDialer is a maker interface dialing to rpc server and returning new RPCClient

type RPCDialerFunc ¶

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

RPCDialerFunc is an adapter to allow the use of an ordinary functions as the RPCDialer.

func (f RPCDialerFunc) Dial(network, address string) (RPCClient, error)

type RPCDialerMock ¶

type RPCDialerMock struct {
	// DialFunc mocks the Dial method.
	DialFunc func(network string, address string) (RPCClient, error)
	// contains filtered or unexported fields
}

RPCDialerMock is a mock implementation of RPCDialer.

func TestSomethingThatUsesRPCDialer(t *testing.T) {

	// make and configure a mocked RPCDialer
	mockedRPCDialer := &RPCDialerMock{
		DialFunc: func(network string, address string) (RPCClient, error) {
			panic("mock out the Dial method")
		},
	}

	// use mockedRPCDialer in code that requires RPCDialer
	// and then make assertions.

}

func (mock *RPCDialerMock) Dial(network string, address string) (RPCClient, error)

func (mock *RPCDialerMock) DialCalls() []struct {
	Network string
	Address string
}

len(mockedRPCDialer.DialCalls())