Upgrade to 0.12

[github/fretlink/terraform-provider-statuscake.git] / vendor / github.com / hashicorp / go-plugin / grpc_broker.go

diff --git a/vendor/github.com/hashicorp/go-plugin/grpc_broker.go b/vendor/github.com/hashicorp/go-plugin/grpc_broker.go
index 49fd21c618c913ec1b0c968db0b86f107d6d95a1..daf142d1709e1cc9e99dbe0cfdd5e18319cda6af 100644 (file)
--- a/vendor/github.com/hashicorp/go-plugin/grpc_broker.go
+++ b/vendor/github.com/hashicorp/go-plugin/grpc_broker.go
@@ -11,6 +11,8 @@ import (
        "sync/atomic"
        "time"
 
+       "github.com/hashicorp/go-plugin/internal/plugin"
+
        "github.com/oklog/run"
        "google.golang.org/grpc"
        "google.golang.org/grpc/credentials"
@@ -19,14 +21,14 @@ import (
 // streamer interface is used in the broker to send/receive connection
 // information.
 type streamer interface {
-       Send(*ConnInfo) error
-       Recv() (*ConnInfo, error)
+       Send(*plugin.ConnInfo) error
+       Recv() (*plugin.ConnInfo, error)
        Close()
 }
 
 // sendErr is used to pass errors back during a send.
 type sendErr struct {
-       i  *ConnInfo
+       i  *plugin.ConnInfo
        ch chan error
 }
 
@@ -38,7 +40,7 @@ type gRPCBrokerServer struct {
        send chan *sendErr
 
        // recv is used to receive connection info from the gRPC stream.
-       recv chan *ConnInfo
+       recv chan *plugin.ConnInfo
 
        // quit closes down the stream.
        quit chan struct{}
@@ -50,7 +52,7 @@ type gRPCBrokerServer struct {
 func newGRPCBrokerServer() *gRPCBrokerServer {
        return &gRPCBrokerServer{
                send: make(chan *sendErr),
-               recv: make(chan *ConnInfo),
+               recv: make(chan *plugin.ConnInfo),
                quit: make(chan struct{}),
        }
 }
@@ -58,7 +60,7 @@ func newGRPCBrokerServer() *gRPCBrokerServer {
 // StartStream implements the GRPCBrokerServer interface and will block until
 // the quit channel is closed or the context reports Done. The stream will pass
 // connection information to/from the client.
-func (s *gRPCBrokerServer) StartStream(stream GRPCBroker_StartStreamServer) error {
+func (s *gRPCBrokerServer) StartStream(stream plugin.GRPCBroker_StartStreamServer) error {
        doneCh := stream.Context().Done()
        defer s.Close()
 
@@ -97,7 +99,7 @@ func (s *gRPCBrokerServer) StartStream(stream GRPCBroker_StartStreamServer) erro
 
 // Send is used by the GRPCBroker to pass connection information into the stream
 // to the client.
-func (s *gRPCBrokerServer) Send(i *ConnInfo) error {
+func (s *gRPCBrokerServer) Send(i *plugin.ConnInfo) error {
        ch := make(chan error)
        defer close(ch)
 
@@ -115,7 +117,7 @@ func (s *gRPCBrokerServer) Send(i *ConnInfo) error {
 
 // Recv is used by the GRPCBroker to pass connection information that has been
 // sent from the client from the stream to the broker.
-func (s *gRPCBrokerServer) Recv() (*ConnInfo, error) {
+func (s *gRPCBrokerServer) Recv() (*plugin.ConnInfo, error) {
        select {
        case <-s.quit:
                return nil, errors.New("broker closed")
@@ -136,13 +138,13 @@ func (s *gRPCBrokerServer) Close() {
 // streamer interfaces.
 type gRPCBrokerClientImpl struct {
        // client is the underlying GRPC client used to make calls to the server.
-       client GRPCBrokerClient
+       client plugin.GRPCBrokerClient
 
        // send is used to send connection info to the gRPC stream.
        send chan *sendErr
 
        // recv is used to receive connection info from the gRPC stream.
-       recv chan *ConnInfo
+       recv chan *plugin.ConnInfo
 
        // quit closes down the stream.
        quit chan struct{}
@@ -153,9 +155,9 @@ type gRPCBrokerClientImpl struct {
 
 func newGRPCBrokerClient(conn *grpc.ClientConn) *gRPCBrokerClientImpl {
        return &gRPCBrokerClientImpl{
-               client: NewGRPCBrokerClient(conn),
+               client: plugin.NewGRPCBrokerClient(conn),
                send:   make(chan *sendErr),
-               recv:   make(chan *ConnInfo),
+               recv:   make(chan *plugin.ConnInfo),
                quit:   make(chan struct{}),
        }
 }
@@ -207,7 +209,7 @@ func (s *gRPCBrokerClientImpl) StartStream() error {
 
 // Send is used by the GRPCBroker to pass connection information into the stream
 // to the plugin.
-func (s *gRPCBrokerClientImpl) Send(i *ConnInfo) error {
+func (s *gRPCBrokerClientImpl) Send(i *plugin.ConnInfo) error {
        ch := make(chan error)
        defer close(ch)
 
@@ -225,7 +227,7 @@ func (s *gRPCBrokerClientImpl) Send(i *ConnInfo) error {
 
 // Recv is used by the GRPCBroker to pass connection information that has been
 // sent from the plugin to the broker.
-func (s *gRPCBrokerClientImpl) Recv() (*ConnInfo, error) {
+func (s *gRPCBrokerClientImpl) Recv() (*plugin.ConnInfo, error) {
        select {
        case <-s.quit:
                return nil, errors.New("broker closed")
@@ -266,7 +268,7 @@ type GRPCBroker struct {
 }
 
 type gRPCBrokerPending struct {
-       ch     chan *ConnInfo
+       ch     chan *plugin.ConnInfo
        doneCh chan struct{}
 }
 
@@ -288,7 +290,7 @@ func (b *GRPCBroker) Accept(id uint32) (net.Listener, error) {
                return nil, err
        }
 
-       err = b.streamer.Send(&ConnInfo{
+       err = b.streamer.Send(&plugin.ConnInfo{
                ServiceId: id,
                Network:   listener.Addr().Network(),
                Address:   listener.Addr().String(),
@@ -363,7 +365,7 @@ func (b *GRPCBroker) Close() error {
 
 // Dial opens a connection by ID.
 func (b *GRPCBroker) Dial(id uint32) (conn *grpc.ClientConn, err error) {
-       var c *ConnInfo
+       var c *plugin.ConnInfo
 
        // Open the stream
        p := b.getStream(id)
@@ -433,7 +435,7 @@ func (m *GRPCBroker) getStream(id uint32) *gRPCBrokerPending {
        }
 
        m.streams[id] = &gRPCBrokerPending{
-               ch:     make(chan *ConnInfo, 1),
+               ch:     make(chan *plugin.ConnInfo, 1),
                doneCh: make(chan struct{}),
        }
        return m.streams[id]