v1

Documentation

Index

• Constants
• Variables
• func RegisterProxyServiceServer(s grpc.ServiceRegistrar, srv ProxyServiceServer)
• type ProxyServiceClient
  • func NewProxyServiceClient(cc grpc.ClientConnInterface) ProxyServiceClient
• type ProxyServiceServer
• type ProxyService_RegisterClient
• type ProxyService_RegisterServer
• type RegisterRequest
  • func (*RegisterRequest) Descriptor() ([]byte, []int)
  • func (*RegisterRequest) ProtoMessage()
  • func (x *RegisterRequest) ProtoReflect() protoreflect.Message
  • func (x *RegisterRequest) Reset()
  • func (x *RegisterRequest) String() string
• type RegisterResponse
  • func (*RegisterResponse) Descriptor() ([]byte, []int)
  • func (x *RegisterResponse) GetEndpoint() string
  • func (*RegisterResponse) ProtoMessage()
  • func (x *RegisterResponse) ProtoReflect() protoreflect.Message
  • func (x *RegisterResponse) Reset()
  • func (x *RegisterResponse) String() string
• type UnimplementedProxyServiceServer
  • func (UnimplementedProxyServiceServer) Register(*RegisterRequest, ProxyService_RegisterServer) error
• type UnsafeProxyServiceServer

Constants

const (
	QuicProto = "breakpoint-grpc"

	GitHubOIDCTokenHeader = "x-breakpoint-github-oidc-token"

	GitHubOIDCAudience = "namespacelabs.dev/breakpoint"
)

Variables

var File_api_public_v1_service_proto protoreflect.FileDescriptor

var ProxyService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "namespacelabs.breakpoint.ProxyService",
	HandlerType: (*ProxyServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Register",
			Handler:       _ProxyService_Register_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/public/v1/service.proto",
}

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

Functions

func RegisterProxyServiceServer

func RegisterProxyServiceServer(s grpc.ServiceRegistrar, srv ProxyServiceServer)

Types

type ProxyServiceClient

type ProxyServiceClient interface {
	// The reverse tunnel is active for as long as this stream over a quic connection is active.
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (ProxyService_RegisterClient, error)
}

ProxyServiceClient is the client API for ProxyService 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 NewProxyServiceClient

func NewProxyServiceClient(cc grpc.ClientConnInterface) ProxyServiceClient

type ProxyServiceServer

type ProxyServiceServer interface {
	// The reverse tunnel is active for as long as this stream over a quic connection is active.
	Register(*RegisterRequest, ProxyService_RegisterServer) error
	// contains filtered or unexported methods
}

ProxyServiceServer is the server API for ProxyService service. All implementations must embed UnimplementedProxyServiceServer for forward compatibility

type ProxyService_RegisterClient

type ProxyService_RegisterClient interface {
	Recv() (*RegisterResponse, error)
	grpc.ClientStream
}

type ProxyService_RegisterServer

type ProxyService_RegisterServer interface {
	Send(*RegisterResponse) error
	grpc.ServerStream
}

type RegisterRequest

type RegisterRequest struct {
	// contains filtered or unexported fields
}

func (*RegisterRequest) Descriptor

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) ProtoMessage

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect

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

func (*RegisterRequest) Reset

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String

func (x *RegisterRequest) String() string

type RegisterResponse

type RegisterResponse struct {
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // Connection endpoint, e.g. <address>:<port>
	// contains filtered or unexported fields
}

func (*RegisterResponse) Descriptor

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

Deprecated: Use RegisterResponse.ProtoReflect.Descriptor instead.

func (*RegisterResponse) GetEndpoint

func (x *RegisterResponse) GetEndpoint() string

func (*RegisterResponse) ProtoMessage

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) ProtoReflect

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

func (*RegisterResponse) Reset

func (x *RegisterResponse) Reset()

func (*RegisterResponse) String

func (x *RegisterResponse) String() string

type UnimplementedProxyServiceServer

type UnimplementedProxyServiceServer struct {
}

UnimplementedProxyServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProxyServiceServer) Register

func (UnimplementedProxyServiceServer) Register(*RegisterRequest, ProxyService_RegisterServer) error

type UnsafeProxyServiceServer

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

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