cloud

Documentation

Index

• Variables
• func RegisterTestKubeCloudAPIServer(s grpc.ServiceRegistrar, srv TestKubeCloudAPIServer)
• type ExecuteRequest
  • func (*ExecuteRequest) Descriptor() ([]byte, []int)
  • func (x *ExecuteRequest) GetBody() []byte
  • func (x *ExecuteRequest) GetHeaders() map[string]*HeaderValue
  • func (x *ExecuteRequest) GetMethod() string
  • func (x *ExecuteRequest) GetUrl() string
  • func (*ExecuteRequest) ProtoMessage()
  • func (x *ExecuteRequest) ProtoReflect() protoreflect.Message
  • func (x *ExecuteRequest) Reset()
  • func (x *ExecuteRequest) String() string
• type ExecuteResponse
  • func (*ExecuteResponse) Descriptor() ([]byte, []int)
  • func (x *ExecuteResponse) GetBody() []byte
  • func (x *ExecuteResponse) GetHeaders() map[string]*HeaderValue
  • func (x *ExecuteResponse) GetStatus() int64
  • func (*ExecuteResponse) ProtoMessage()
  • func (x *ExecuteResponse) ProtoReflect() protoreflect.Message
  • func (x *ExecuteResponse) Reset()
  • func (x *ExecuteResponse) String() string
• type HeaderValue
  • func (*HeaderValue) Descriptor() ([]byte, []int)
  • func (x *HeaderValue) GetHeader() []string
  • func (*HeaderValue) ProtoMessage()
  • func (x *HeaderValue) ProtoReflect() protoreflect.Message
  • func (x *HeaderValue) Reset()
  • func (x *HeaderValue) String() string
• type TestKubeCloudAPIClient
  • func NewTestKubeCloudAPIClient(cc grpc.ClientConnInterface) TestKubeCloudAPIClient
• type TestKubeCloudAPIServer
• type TestKubeCloudAPI_ExecuteClient
• type TestKubeCloudAPI_ExecuteServer
• type UnimplementedTestKubeCloudAPIServer
  • func (UnimplementedTestKubeCloudAPIServer) Execute(TestKubeCloudAPI_ExecuteServer) error
• type UnsafeTestKubeCloudAPIServer

Variables

var File_proto_service_proto protoreflect.FileDescriptor

var TestKubeCloudAPI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cloud.TestKubeCloudAPI",
	HandlerType: (*TestKubeCloudAPIServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Execute",
			Handler:       _TestKubeCloudAPI_Execute_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "proto/service.proto",
}

TestKubeCloudAPI_ServiceDesc is the grpc.ServiceDesc for TestKubeCloudAPI service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTestKubeCloudAPIServer

func RegisterTestKubeCloudAPIServer(s grpc.ServiceRegistrar, srv TestKubeCloudAPIServer)

Types

type ExecuteRequest

type ExecuteRequest struct {
	Method  string                  `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Url     string                  `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Headers map[string]*HeaderValue `` /* 155-byte string literal not displayed */
	Body    []byte                  `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteRequest) Descriptor

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

Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRequest) GetBody

func (x *ExecuteRequest) GetBody() []byte

func (*ExecuteRequest) GetHeaders

func (x *ExecuteRequest) GetHeaders() map[string]*HeaderValue

func (*ExecuteRequest) GetMethod

func (x *ExecuteRequest) GetMethod() string

func (*ExecuteRequest) GetUrl

func (x *ExecuteRequest) GetUrl() string

func (*ExecuteRequest) ProtoMessage

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) ProtoReflect

func (x *ExecuteRequest) ProtoReflect() protoreflect.Message

func (*ExecuteRequest) Reset

func (x *ExecuteRequest) Reset()

func (*ExecuteRequest) String

func (x *ExecuteRequest) String() string

type ExecuteResponse

type ExecuteResponse struct {
	Status  int64                   `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Headers map[string]*HeaderValue `` /* 155-byte string literal not displayed */
	Body    []byte                  `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteResponse) Descriptor

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

Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.

func (*ExecuteResponse) GetBody

func (x *ExecuteResponse) GetBody() []byte

func (*ExecuteResponse) GetHeaders

func (x *ExecuteResponse) GetHeaders() map[string]*HeaderValue

func (*ExecuteResponse) GetStatus

func (x *ExecuteResponse) GetStatus() int64

func (*ExecuteResponse) ProtoMessage

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) ProtoReflect

func (x *ExecuteResponse) ProtoReflect() protoreflect.Message

func (*ExecuteResponse) Reset

func (x *ExecuteResponse) Reset()

func (*ExecuteResponse) String

func (x *ExecuteResponse) String() string

type HeaderValue

type HeaderValue struct {
	Header []string `protobuf:"bytes,1,rep,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

func (*HeaderValue) Descriptor

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

Deprecated: Use HeaderValue.ProtoReflect.Descriptor instead.

func (*HeaderValue) GetHeader

func (x *HeaderValue) GetHeader() []string

func (*HeaderValue) ProtoMessage

func (*HeaderValue) ProtoMessage()

func (*HeaderValue) ProtoReflect

func (x *HeaderValue) ProtoReflect() protoreflect.Message

func (*HeaderValue) Reset

func (x *HeaderValue) Reset()

func (*HeaderValue) String

func (x *HeaderValue) String() string

type TestKubeCloudAPIClient

type TestKubeCloudAPIClient interface {
	Execute(ctx context.Context, opts ...grpc.CallOption) (TestKubeCloudAPI_ExecuteClient, error)
}

TestKubeCloudAPIClient is the client API for TestKubeCloudAPI service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTestKubeCloudAPIClient

func NewTestKubeCloudAPIClient(cc grpc.ClientConnInterface) TestKubeCloudAPIClient

type TestKubeCloudAPIServer

type TestKubeCloudAPIServer interface {
	Execute(TestKubeCloudAPI_ExecuteServer) error
	// contains filtered or unexported methods
}

TestKubeCloudAPIServer is the server API for TestKubeCloudAPI service. All implementations must embed UnimplementedTestKubeCloudAPIServer for forward compatibility

type TestKubeCloudAPI_ExecuteClient

type TestKubeCloudAPI_ExecuteClient interface {
	Send(*ExecuteResponse) error
	Recv() (*ExecuteRequest, error)
	grpc.ClientStream
}

type TestKubeCloudAPI_ExecuteServer

type TestKubeCloudAPI_ExecuteServer interface {
	Send(*ExecuteRequest) error
	Recv() (*ExecuteResponse, error)
	grpc.ServerStream
}

type UnimplementedTestKubeCloudAPIServer

type UnimplementedTestKubeCloudAPIServer struct {
}

UnimplementedTestKubeCloudAPIServer must be embedded to have forward compatible implementations.

func (UnimplementedTestKubeCloudAPIServer) Execute

func (UnimplementedTestKubeCloudAPIServer) Execute(TestKubeCloudAPI_ExecuteServer) error

type UnsafeTestKubeCloudAPIServer

type UnsafeTestKubeCloudAPIServer interface {
	// contains filtered or unexported methods
}

UnsafeTestKubeCloudAPIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TestKubeCloudAPIServer will result in compilation errors.