protoconnect

Documentation

Index

• Constants
• func ExtractPubKey(message []byte, signature []byte) (*ecdsa.PublicKey, error)
• func GetNamespace(req connect.AnyRequest) string
• func NewAuthInterceptor(c client.Client) connect.Interceptor
• func NewProvisionPodServiceHandler(svc ProvisionPodServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
• func VerifyPayload(publisher common.Address, message []byte, signature []byte) (bool, error)
• type AuthInterceptorClient
  • func NewAuthInterceptorClient(deployment *pb.Deployment, expirationOffset int64, sign SignFunc) *AuthInterceptorClient
  • func (a *AuthInterceptorClient) WrapStreamingClient(handler connect.StreamingClientFunc) connect.StreamingClientFunc
  • func (a *AuthInterceptorClient) WrapStreamingHandler(handler connect.StreamingHandlerFunc) connect.StreamingHandlerFunc
  • func (a *AuthInterceptorClient) WrapUnary(handler connect.UnaryFunc) connect.UnaryFunc
• type HasPaymentChannel
• type ProvisionPodServiceClient
  • func NewProvisionPodServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ProvisionPodServiceClient
• type ProvisionPodServiceHandler
• type SignFunc
• type Token
• type UnimplementedProvisionPodServiceHandler
  • func (UnimplementedProvisionPodServiceHandler) DeletePod(context.Context, *connect.Request[proto.DeletePodRequest]) (*connect.Response[proto.DeletePodResponse], error)
  • func (UnimplementedProvisionPodServiceHandler) GetPodLogs(context.Context, *connect.Request[proto.PodLogRequest], ...) error
  • func (UnimplementedProvisionPodServiceHandler) ProvisionPod(context.Context, *connect.Request[proto.ProvisionPodRequest]) (*connect.Response[proto.ProvisionPodResponse], error)
  • func (UnimplementedProvisionPodServiceHandler) UpdatePod(context.Context, *connect.Request[proto.UpdatePodRequest]) (*connect.Response[proto.ProvisionPodResponse], error)

Constants

const (
	// ProvisionPodServiceProvisionPodProcedure is the fully-qualified name of the ProvisionPodService's
	// ProvisionPod RPC.
	ProvisionPodServiceProvisionPodProcedure = "/apocryph.proto.v0.provisionPod.ProvisionPodService/ProvisionPod"
	// ProvisionPodServiceUpdatePodProcedure is the fully-qualified name of the ProvisionPodService's
	// UpdatePod RPC.
	ProvisionPodServiceUpdatePodProcedure = "/apocryph.proto.v0.provisionPod.ProvisionPodService/UpdatePod"
	// ProvisionPodServiceDeletePodProcedure is the fully-qualified name of the ProvisionPodService's
	// DeletePod RPC.
	ProvisionPodServiceDeletePodProcedure = "/apocryph.proto.v0.provisionPod.ProvisionPodService/DeletePod"
	// ProvisionPodServiceGetPodLogsProcedure is the fully-qualified name of the ProvisionPodService's
	// GetPodLogs RPC.
	ProvisionPodServiceGetPodLogsProcedure = "/apocryph.proto.v0.provisionPod.ProvisionPodService/GetPodLogs"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

const (
	NamespaceHeader = "X-Namespace"
)

const (
	// ProvisionPodServiceName is the fully-qualified name of the ProvisionPodService service.
	ProvisionPodServiceName = "apocryph.proto.v0.provisionPod.ProvisionPodService"
)

Functions

func ExtractPubKey

func ExtractPubKey(message []byte, signature []byte) (*ecdsa.PublicKey, error)

func GetNamespace

func GetNamespace(req connect.AnyRequest) string

func NewAuthInterceptor

func NewAuthInterceptor(c client.Client) connect.Interceptor

func NewProvisionPodServiceHandler

func NewProvisionPodServiceHandler(svc ProvisionPodServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewProvisionPodServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func VerifyPayload

func VerifyPayload(publisher common.Address, message []byte, signature []byte) (bool, error)

Types

type AuthInterceptorClient

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

func NewAuthInterceptorClient

func NewAuthInterceptorClient(deployment *pb.Deployment, expirationOffset int64, sign SignFunc) *AuthInterceptorClient

func (*AuthInterceptorClient) WrapStreamingClient

func (a *AuthInterceptorClient) WrapStreamingClient(handler connect.StreamingClientFunc) connect.StreamingClientFunc

func (*AuthInterceptorClient) WrapStreamingHandler

func (a *AuthInterceptorClient) WrapStreamingHandler(handler connect.StreamingHandlerFunc) connect.StreamingHandlerFunc

func (*AuthInterceptorClient) WrapUnary

func (a *AuthInterceptorClient) WrapUnary(handler connect.UnaryFunc) connect.UnaryFunc

type HasPaymentChannel

type HasPaymentChannel interface{ GetPayment() *pb.PaymentChannel }

type ProvisionPodServiceClient

type ProvisionPodServiceClient interface {
	ProvisionPod(context.Context, *connect.Request[proto.ProvisionPodRequest]) (*connect.Response[proto.ProvisionPodResponse], error)
	UpdatePod(context.Context, *connect.Request[proto.UpdatePodRequest]) (*connect.Response[proto.ProvisionPodResponse], error)
	DeletePod(context.Context, *connect.Request[proto.DeletePodRequest]) (*connect.Response[proto.DeletePodResponse], error)
	GetPodLogs(context.Context, *connect.Request[proto.PodLogRequest]) (*connect.ServerStreamForClient[proto.PodLogResponse], error)
}

ProvisionPodServiceClient is a client for the apocryph.proto.v0.provisionPod.ProvisionPodService service.

func NewProvisionPodServiceClient

func NewProvisionPodServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ProvisionPodServiceClient

NewProvisionPodServiceClient constructs a client for the apocryph.proto.v0.provisionPod.ProvisionPodService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type ProvisionPodServiceHandler

type ProvisionPodServiceHandler interface {
	ProvisionPod(context.Context, *connect.Request[proto.ProvisionPodRequest]) (*connect.Response[proto.ProvisionPodResponse], error)
	UpdatePod(context.Context, *connect.Request[proto.UpdatePodRequest]) (*connect.Response[proto.ProvisionPodResponse], error)
	DeletePod(context.Context, *connect.Request[proto.DeletePodRequest]) (*connect.Response[proto.DeletePodResponse], error)
	GetPodLogs(context.Context, *connect.Request[proto.PodLogRequest], *connect.ServerStream[proto.PodLogResponse]) error
}

ProvisionPodServiceHandler is an implementation of the apocryph.proto.v0.provisionPod.ProvisionPodService service.

type SignFunc

type SignFunc func(data []byte) ([]byte, error)

type Token

type Token struct {
	PodId          common.Hash
	Operation      string
	ExpirationTime time.Time
	Publisher      common.Address
}

type UnimplementedProvisionPodServiceHandler

type UnimplementedProvisionPodServiceHandler struct{}

UnimplementedProvisionPodServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedProvisionPodServiceHandler) DeletePod

func (UnimplementedProvisionPodServiceHandler) DeletePod(context.Context, *connect.Request[proto.DeletePodRequest]) (*connect.Response[proto.DeletePodResponse], error)

func (UnimplementedProvisionPodServiceHandler) GetPodLogs

func (UnimplementedProvisionPodServiceHandler) GetPodLogs(context.Context, *connect.Request[proto.PodLogRequest], *connect.ServerStream[proto.PodLogResponse]) error

func (UnimplementedProvisionPodServiceHandler) ProvisionPod

func (UnimplementedProvisionPodServiceHandler) ProvisionPod(context.Context, *connect.Request[proto.ProvisionPodRequest]) (*connect.Response[proto.ProvisionPodResponse], error)

func (UnimplementedProvisionPodServiceHandler) UpdatePod

func (UnimplementedProvisionPodServiceHandler) UpdatePod(context.Context, *connect.Request[proto.UpdatePodRequest]) (*connect.Response[proto.ProvisionPodResponse], error)