go-plugin: github.com/hashicorp/go-plugin/test/grpc Index | Files

package grpctest

import "github.com/hashicorp/go-plugin/test/grpc"

Index

Package Files

gen.go test.pb.go

func RegisterPingPongServer Uses

func RegisterPingPongServer(s *grpc.Server, srv PingPongServer)

func RegisterTestServer Uses

func RegisterTestServer(s *grpc.Server, srv TestServer)

type BidirectionalRequest Uses

type BidirectionalRequest struct {
    Id                   uint32   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*BidirectionalRequest) Descriptor Uses

func (*BidirectionalRequest) Descriptor() ([]byte, []int)

func (*BidirectionalRequest) GetId Uses

func (m *BidirectionalRequest) GetId() uint32

func (*BidirectionalRequest) ProtoMessage Uses

func (*BidirectionalRequest) ProtoMessage()

func (*BidirectionalRequest) Reset Uses

func (m *BidirectionalRequest) Reset()

func (*BidirectionalRequest) String Uses

func (m *BidirectionalRequest) String() string

func (*BidirectionalRequest) XXX_DiscardUnknown Uses

func (m *BidirectionalRequest) XXX_DiscardUnknown()

func (*BidirectionalRequest) XXX_Marshal Uses

func (m *BidirectionalRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BidirectionalRequest) XXX_Merge Uses

func (dst *BidirectionalRequest) XXX_Merge(src proto.Message)

func (*BidirectionalRequest) XXX_Size Uses

func (m *BidirectionalRequest) XXX_Size() int

func (*BidirectionalRequest) XXX_Unmarshal Uses

func (m *BidirectionalRequest) XXX_Unmarshal(b []byte) error

type BidirectionalResponse Uses

type BidirectionalResponse struct {
    Id                   uint32   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*BidirectionalResponse) Descriptor Uses

func (*BidirectionalResponse) Descriptor() ([]byte, []int)

func (*BidirectionalResponse) GetId Uses

func (m *BidirectionalResponse) GetId() uint32

func (*BidirectionalResponse) ProtoMessage Uses

func (*BidirectionalResponse) ProtoMessage()

func (*BidirectionalResponse) Reset Uses

func (m *BidirectionalResponse) Reset()

func (*BidirectionalResponse) String Uses

func (m *BidirectionalResponse) String() string

func (*BidirectionalResponse) XXX_DiscardUnknown Uses

func (m *BidirectionalResponse) XXX_DiscardUnknown()

func (*BidirectionalResponse) XXX_Marshal Uses

func (m *BidirectionalResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BidirectionalResponse) XXX_Merge Uses

func (dst *BidirectionalResponse) XXX_Merge(src proto.Message)

func (*BidirectionalResponse) XXX_Size Uses

func (m *BidirectionalResponse) XXX_Size() int

func (*BidirectionalResponse) XXX_Unmarshal Uses

func (m *BidirectionalResponse) XXX_Unmarshal(b []byte) error

type PingPongClient Uses

type PingPongClient interface {
    Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PongResponse, error)
}

PingPongClient is the client API for PingPong service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPingPongClient Uses

func NewPingPongClient(cc *grpc.ClientConn) PingPongClient

type PingPongServer Uses

type PingPongServer interface {
    Ping(context.Context, *PingRequest) (*PongResponse, error)
}

PingPongServer is the server API for PingPong service.

type PingRequest Uses

type PingRequest struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*PingRequest) Descriptor Uses

func (*PingRequest) Descriptor() ([]byte, []int)

func (*PingRequest) ProtoMessage Uses

func (*PingRequest) ProtoMessage()

func (*PingRequest) Reset Uses

func (m *PingRequest) Reset()

func (*PingRequest) String Uses

func (m *PingRequest) String() string

func (*PingRequest) XXX_DiscardUnknown Uses

func (m *PingRequest) XXX_DiscardUnknown()

func (*PingRequest) XXX_Marshal Uses

func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PingRequest) XXX_Merge Uses

func (dst *PingRequest) XXX_Merge(src proto.Message)

func (*PingRequest) XXX_Size Uses

func (m *PingRequest) XXX_Size() int

func (*PingRequest) XXX_Unmarshal Uses

func (m *PingRequest) XXX_Unmarshal(b []byte) error

type PongResponse Uses

type PongResponse struct {
    Msg                  string   `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*PongResponse) Descriptor Uses

func (*PongResponse) Descriptor() ([]byte, []int)

func (*PongResponse) GetMsg Uses

func (m *PongResponse) GetMsg() string

func (*PongResponse) ProtoMessage Uses

func (*PongResponse) ProtoMessage()

func (*PongResponse) Reset Uses

func (m *PongResponse) Reset()

func (*PongResponse) String Uses

func (m *PongResponse) String() string

func (*PongResponse) XXX_DiscardUnknown Uses

func (m *PongResponse) XXX_DiscardUnknown()

func (*PongResponse) XXX_Marshal Uses

func (m *PongResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PongResponse) XXX_Merge Uses

func (dst *PongResponse) XXX_Merge(src proto.Message)

func (*PongResponse) XXX_Size Uses

func (m *PongResponse) XXX_Size() int

func (*PongResponse) XXX_Unmarshal Uses

func (m *PongResponse) XXX_Unmarshal(b []byte) error

type PrintKVRequest Uses

type PrintKVRequest struct {
    Key string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
    // Types that are valid to be assigned to Value:
    //	*PrintKVRequest_ValueString
    //	*PrintKVRequest_ValueInt
    Value                isPrintKVRequest_Value `protobuf_oneof:"Value"`
    XXX_NoUnkeyedLiteral struct{}               `json:"-"`
    XXX_unrecognized     []byte                 `json:"-"`
    XXX_sizecache        int32                  `json:"-"`
}

func (*PrintKVRequest) Descriptor Uses

func (*PrintKVRequest) Descriptor() ([]byte, []int)

func (*PrintKVRequest) GetKey Uses

func (m *PrintKVRequest) GetKey() string

func (*PrintKVRequest) GetValue Uses

func (m *PrintKVRequest) GetValue() isPrintKVRequest_Value

func (*PrintKVRequest) GetValueInt Uses

func (m *PrintKVRequest) GetValueInt() int32

func (*PrintKVRequest) GetValueString Uses

func (m *PrintKVRequest) GetValueString() string

func (*PrintKVRequest) ProtoMessage Uses

func (*PrintKVRequest) ProtoMessage()

func (*PrintKVRequest) Reset Uses

func (m *PrintKVRequest) Reset()

func (*PrintKVRequest) String Uses

func (m *PrintKVRequest) String() string

func (*PrintKVRequest) XXX_DiscardUnknown Uses

func (m *PrintKVRequest) XXX_DiscardUnknown()

func (*PrintKVRequest) XXX_Marshal Uses

func (m *PrintKVRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrintKVRequest) XXX_Merge Uses

func (dst *PrintKVRequest) XXX_Merge(src proto.Message)

func (*PrintKVRequest) XXX_OneofFuncs Uses

func (*PrintKVRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*PrintKVRequest) XXX_Size Uses

func (m *PrintKVRequest) XXX_Size() int

func (*PrintKVRequest) XXX_Unmarshal Uses

func (m *PrintKVRequest) XXX_Unmarshal(b []byte) error

type PrintKVRequest_ValueInt Uses

type PrintKVRequest_ValueInt struct {
    ValueInt int32 `protobuf:"varint,3,opt,name=ValueInt,proto3,oneof"`
}

type PrintKVRequest_ValueString Uses

type PrintKVRequest_ValueString struct {
    ValueString string `protobuf:"bytes,2,opt,name=ValueString,proto3,oneof"`
}

type PrintKVResponse Uses

type PrintKVResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*PrintKVResponse) Descriptor Uses

func (*PrintKVResponse) Descriptor() ([]byte, []int)

func (*PrintKVResponse) ProtoMessage Uses

func (*PrintKVResponse) ProtoMessage()

func (*PrintKVResponse) Reset Uses

func (m *PrintKVResponse) Reset()

func (*PrintKVResponse) String Uses

func (m *PrintKVResponse) String() string

func (*PrintKVResponse) XXX_DiscardUnknown Uses

func (m *PrintKVResponse) XXX_DiscardUnknown()

func (*PrintKVResponse) XXX_Marshal Uses

func (m *PrintKVResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrintKVResponse) XXX_Merge Uses

func (dst *PrintKVResponse) XXX_Merge(src proto.Message)

func (*PrintKVResponse) XXX_Size Uses

func (m *PrintKVResponse) XXX_Size() int

func (*PrintKVResponse) XXX_Unmarshal Uses

func (m *PrintKVResponse) XXX_Unmarshal(b []byte) error

type PrintStdioRequest Uses

type PrintStdioRequest struct {
    Stdout               []byte   `protobuf:"bytes,1,opt,name=stdout,proto3" json:"stdout,omitempty"`
    Stderr               []byte   `protobuf:"bytes,2,opt,name=stderr,proto3" json:"stderr,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*PrintStdioRequest) Descriptor Uses

func (*PrintStdioRequest) Descriptor() ([]byte, []int)

func (*PrintStdioRequest) GetStderr Uses

func (m *PrintStdioRequest) GetStderr() []byte

func (*PrintStdioRequest) GetStdout Uses

func (m *PrintStdioRequest) GetStdout() []byte

func (*PrintStdioRequest) ProtoMessage Uses

func (*PrintStdioRequest) ProtoMessage()

func (*PrintStdioRequest) Reset Uses

func (m *PrintStdioRequest) Reset()

func (*PrintStdioRequest) String Uses

func (m *PrintStdioRequest) String() string

func (*PrintStdioRequest) XXX_DiscardUnknown Uses

func (m *PrintStdioRequest) XXX_DiscardUnknown()

func (*PrintStdioRequest) XXX_Marshal Uses

func (m *PrintStdioRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrintStdioRequest) XXX_Merge Uses

func (dst *PrintStdioRequest) XXX_Merge(src proto.Message)

func (*PrintStdioRequest) XXX_Size Uses

func (m *PrintStdioRequest) XXX_Size() int

func (*PrintStdioRequest) XXX_Unmarshal Uses

func (m *PrintStdioRequest) XXX_Unmarshal(b []byte) error

type TestClient Uses

type TestClient interface {
    Double(ctx context.Context, in *TestRequest, opts ...grpc.CallOption) (*TestResponse, error)
    PrintKV(ctx context.Context, in *PrintKVRequest, opts ...grpc.CallOption) (*PrintKVResponse, error)
    Bidirectional(ctx context.Context, in *BidirectionalRequest, opts ...grpc.CallOption) (*BidirectionalResponse, error)
    Stream(ctx context.Context, opts ...grpc.CallOption) (Test_StreamClient, error)
    PrintStdio(ctx context.Context, in *PrintStdioRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

TestClient is the client API for Test service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTestClient Uses

func NewTestClient(cc *grpc.ClientConn) TestClient

type TestRequest Uses

type TestRequest struct {
    Input                int32    `protobuf:"varint,1,opt,name=Input,proto3" json:"Input,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*TestRequest) Descriptor Uses

func (*TestRequest) Descriptor() ([]byte, []int)

func (*TestRequest) GetInput Uses

func (m *TestRequest) GetInput() int32

func (*TestRequest) ProtoMessage Uses

func (*TestRequest) ProtoMessage()

func (*TestRequest) Reset Uses

func (m *TestRequest) Reset()

func (*TestRequest) String Uses

func (m *TestRequest) String() string

func (*TestRequest) XXX_DiscardUnknown Uses

func (m *TestRequest) XXX_DiscardUnknown()

func (*TestRequest) XXX_Marshal Uses

func (m *TestRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TestRequest) XXX_Merge Uses

func (dst *TestRequest) XXX_Merge(src proto.Message)

func (*TestRequest) XXX_Size Uses

func (m *TestRequest) XXX_Size() int

func (*TestRequest) XXX_Unmarshal Uses

func (m *TestRequest) XXX_Unmarshal(b []byte) error

type TestResponse Uses

type TestResponse struct {
    Output               int32    `protobuf:"varint,2,opt,name=Output,proto3" json:"Output,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*TestResponse) Descriptor Uses

func (*TestResponse) Descriptor() ([]byte, []int)

func (*TestResponse) GetOutput Uses

func (m *TestResponse) GetOutput() int32

func (*TestResponse) ProtoMessage Uses

func (*TestResponse) ProtoMessage()

func (*TestResponse) Reset Uses

func (m *TestResponse) Reset()

func (*TestResponse) String Uses

func (m *TestResponse) String() string

func (*TestResponse) XXX_DiscardUnknown Uses

func (m *TestResponse) XXX_DiscardUnknown()

func (*TestResponse) XXX_Marshal Uses

func (m *TestResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TestResponse) XXX_Merge Uses

func (dst *TestResponse) XXX_Merge(src proto.Message)

func (*TestResponse) XXX_Size Uses

func (m *TestResponse) XXX_Size() int

func (*TestResponse) XXX_Unmarshal Uses

func (m *TestResponse) XXX_Unmarshal(b []byte) error

type TestServer Uses

type TestServer interface {
    Double(context.Context, *TestRequest) (*TestResponse, error)
    PrintKV(context.Context, *PrintKVRequest) (*PrintKVResponse, error)
    Bidirectional(context.Context, *BidirectionalRequest) (*BidirectionalResponse, error)
    Stream(Test_StreamServer) error
    PrintStdio(context.Context, *PrintStdioRequest) (*empty.Empty, error)
}

TestServer is the server API for Test service.

type Test_StreamClient Uses

type Test_StreamClient interface {
    Send(*TestRequest) error
    Recv() (*TestResponse, error)
    grpc.ClientStream
}

type Test_StreamServer Uses

type Test_StreamServer interface {
    Send(*TestResponse) error
    Recv() (*TestRequest, error)
    grpc.ServerStream
}

Package grpctest imports 6 packages (graph). Updated 2020-03-29. Refresh now. Tools for package owners.