Expose TargetEndpoints for per-peer execution (#37)

Author: sam-at-luther

internal/rpc/shiroclient.go

@@ -528,6 +528,10 @@ func (c *rpcShiroClient) Call(ctx context.Context, method string, configs ...typ
 		req["params"].(map[string]interface{})["creator_msp_id"] = opt.Creator
 	}
 
+	if len(opt.TargetEndpoints) > 0 {
+		req["params"].(map[string]interface{})["target_endpoints"] = opt.TargetEndpoints
+	}
+
 	res, err := c.reqres(ctx, req, opt)
 	if err != nil {
 		return nil, err

internal/types/types.go

@@ -109,6 +109,7 @@ type RequestOptions struct {
 	Target              *interface{}
 	TimestampGenerator  func(context.Context) string
 	MspFilter           []string
+	TargetEndpoints     []string
 	MinEndorsers        int
 	Creator             string
 	DependentTxID       string

shiroclient/configs.go

@@ -123,6 +123,14 @@ func WithMSPFilter(mspFilter []string) Config {
 	})
 }
 
+// WithTargetEndpoints allows specifying which exact peers will be used
+// to process the transaction. Specifcy a name or URL of the peer.
+func WithTargetEndpoints(nameOrURL []string) Config {
+	return types.Opt(func(r *types.RequestOptions) {
+		r.TargetEndpoints = append([]string(nil), nameOrURL...)
+	})
+}
+
 // WithMinEndorsers allows specifying the minimum number of endorsing
 // peers. Has no effect in mock mode.
 func WithMinEndorsers(minEndorsers int) Config {