v1connect

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 2, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// CoreServicePingProcedure is the fully-qualified name of the CoreService's Ping RPC.
	CoreServicePingProcedure = "/core.v1.CoreService/Ping"
	// CoreServiceGetHealthProcedure is the fully-qualified name of the CoreService's GetHealth RPC.
	CoreServiceGetHealthProcedure = "/core.v1.CoreService/GetHealth"
	// CoreServiceGetStatusProcedure is the fully-qualified name of the CoreService's GetStatus RPC.
	CoreServiceGetStatusProcedure = "/core.v1.CoreService/GetStatus"
	// CoreServiceGetNodeInfoProcedure is the fully-qualified name of the CoreService's GetNodeInfo RPC.
	CoreServiceGetNodeInfoProcedure = "/core.v1.CoreService/GetNodeInfo"
	// CoreServiceGetBlockProcedure is the fully-qualified name of the CoreService's GetBlock RPC.
	CoreServiceGetBlockProcedure = "/core.v1.CoreService/GetBlock"
	// CoreServiceGetBlocksProcedure is the fully-qualified name of the CoreService's GetBlocks RPC.
	CoreServiceGetBlocksProcedure = "/core.v1.CoreService/GetBlocks"
	// CoreServiceGetTransactionProcedure is the fully-qualified name of the CoreService's
	// GetTransaction RPC.
	CoreServiceGetTransactionProcedure = "/core.v1.CoreService/GetTransaction"
	// CoreServiceSendTransactionProcedure is the fully-qualified name of the CoreService's
	// SendTransaction RPC.
	CoreServiceSendTransactionProcedure = "/core.v1.CoreService/SendTransaction"
	// CoreServiceForwardTransactionProcedure is the fully-qualified name of the CoreService's
	// ForwardTransaction RPC.
	CoreServiceForwardTransactionProcedure = "/core.v1.CoreService/ForwardTransaction"
	// CoreServiceGetRegistrationAttestationProcedure is the fully-qualified name of the CoreService's
	// GetRegistrationAttestation RPC.
	CoreServiceGetRegistrationAttestationProcedure = "/core.v1.CoreService/GetRegistrationAttestation"
	// CoreServiceGetDeregistrationAttestationProcedure is the fully-qualified name of the CoreService's
	// GetDeregistrationAttestation RPC.
	CoreServiceGetDeregistrationAttestationProcedure = "/core.v1.CoreService/GetDeregistrationAttestation"
	// CoreServiceGetStoredSnapshotsProcedure is the fully-qualified name of the CoreService's
	// GetStoredSnapshots RPC.
	CoreServiceGetStoredSnapshotsProcedure = "/core.v1.CoreService/GetStoredSnapshots"
	// CoreServiceGetSlashAttestationProcedure is the fully-qualified name of the CoreService's
	// GetSlashAttestation RPC.
	CoreServiceGetSlashAttestationProcedure = "/core.v1.CoreService/GetSlashAttestation"
	// CoreServiceGetSlashAttestationsProcedure is the fully-qualified name of the CoreService's
	// GetSlashAttestations RPC.
	CoreServiceGetSlashAttestationsProcedure = "/core.v1.CoreService/GetSlashAttestations"
	// CoreServiceGetERNProcedure is the fully-qualified name of the CoreService's GetERN RPC.
	CoreServiceGetERNProcedure = "/core.v1.CoreService/GetERN"
	// CoreServiceGetMEADProcedure is the fully-qualified name of the CoreService's GetMEAD RPC.
	CoreServiceGetMEADProcedure = "/core.v1.CoreService/GetMEAD"
	// CoreServiceGetPIEProcedure is the fully-qualified name of the CoreService's GetPIE RPC.
	CoreServiceGetPIEProcedure = "/core.v1.CoreService/GetPIE"
	// CoreServiceGetRewardProcedure is the fully-qualified name of the CoreService's GetReward RPC.
	CoreServiceGetRewardProcedure = "/core.v1.CoreService/GetReward"
	// CoreServiceGetRewardsProcedure is the fully-qualified name of the CoreService's GetRewards RPC.
	CoreServiceGetRewardsProcedure = "/core.v1.CoreService/GetRewards"
	// CoreServiceGetRewardAttestationProcedure is the fully-qualified name of the CoreService's
	// GetRewardAttestation RPC.
	CoreServiceGetRewardAttestationProcedure = "/core.v1.CoreService/GetRewardAttestation"
	// CoreServiceGetStreamURLsProcedure is the fully-qualified name of the CoreService's GetStreamURLs
	// RPC.
	CoreServiceGetStreamURLsProcedure = "/core.v1.CoreService/GetStreamURLs"
	// CoreServiceGetUploadByCIDProcedure is the fully-qualified name of the CoreService's
	// GetUploadByCID RPC.
	CoreServiceGetUploadByCIDProcedure = "/core.v1.CoreService/GetUploadByCID"
)

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.

View Source 
const (
	// CoreServiceName is the fully-qualified name of the CoreService service.
	CoreServiceName = "core.v1.CoreService"
)

Variables

This section is empty.

Functions

func NewCoreServiceHandler 

func NewCoreServiceHandler(svc CoreServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewCoreServiceHandler 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.

Types

type CoreServiceClient 

type CoreServiceClient interface {
	Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
	GetHealth(context.Context, *connect.Request[v1.GetHealthRequest]) (*connect.Response[v1.GetHealthResponse], error)
	GetStatus(context.Context, *connect.Request[v1.GetStatusRequest]) (*connect.Response[v1.GetStatusResponse], error)
	GetNodeInfo(context.Context, *connect.Request[v1.GetNodeInfoRequest]) (*connect.Response[v1.GetNodeInfoResponse], error)
	GetBlock(context.Context, *connect.Request[v1.GetBlockRequest]) (*connect.Response[v1.GetBlockResponse], error)
	GetBlocks(context.Context, *connect.Request[v1.GetBlocksRequest]) (*connect.Response[v1.GetBlocksResponse], error)
	GetTransaction(context.Context, *connect.Request[v1.GetTransactionRequest]) (*connect.Response[v1.GetTransactionResponse], error)
	SendTransaction(context.Context, *connect.Request[v1.SendTransactionRequest]) (*connect.Response[v1.SendTransactionResponse], error)
	ForwardTransaction(context.Context, *connect.Request[v1.ForwardTransactionRequest]) (*connect.Response[v1.ForwardTransactionResponse], error)
	GetRegistrationAttestation(context.Context, *connect.Request[v1.GetRegistrationAttestationRequest]) (*connect.Response[v1.GetRegistrationAttestationResponse], error)
	GetDeregistrationAttestation(context.Context, *connect.Request[v1.GetDeregistrationAttestationRequest]) (*connect.Response[v1.GetDeregistrationAttestationResponse], error)
	GetStoredSnapshots(context.Context, *connect.Request[v1.GetStoredSnapshotsRequest]) (*connect.Response[v1.GetStoredSnapshotsResponse], error)
	GetSlashAttestation(context.Context, *connect.Request[v1.GetSlashAttestationRequest]) (*connect.Response[v1.GetSlashAttestationResponse], error)
	GetSlashAttestations(context.Context, *connect.Request[v1.GetSlashAttestationsRequest]) (*connect.Response[v1.GetSlashAttestationsResponse], error)
	GetERN(context.Context, *connect.Request[v1.GetERNRequest]) (*connect.Response[v1.GetERNResponse], error)
	GetMEAD(context.Context, *connect.Request[v1.GetMEADRequest]) (*connect.Response[v1.GetMEADResponse], error)
	GetPIE(context.Context, *connect.Request[v1.GetPIERequest]) (*connect.Response[v1.GetPIEResponse], error)
	GetReward(context.Context, *connect.Request[v1.GetRewardRequest]) (*connect.Response[v1.GetRewardResponse], error)
	GetRewards(context.Context, *connect.Request[v1.GetRewardsRequest]) (*connect.Response[v1.GetRewardsResponse], error)
	GetRewardAttestation(context.Context, *connect.Request[v1.GetRewardAttestationRequest]) (*connect.Response[v1.GetRewardAttestationResponse], error)
	GetStreamURLs(context.Context, *connect.Request[v1.GetStreamURLsRequest]) (*connect.Response[v1.GetStreamURLsResponse], error)
	GetUploadByCID(context.Context, *connect.Request[v1.GetUploadByCIDRequest]) (*connect.Response[v1.GetUploadByCIDResponse], error)
}

CoreServiceClient is a client for the core.v1.CoreService service.

func NewCoreServiceClient 

func NewCoreServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) CoreServiceClient

NewCoreServiceClient constructs a client for the core.v1.CoreService 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 CoreServiceHandler 

type CoreServiceHandler interface {
	Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)
	GetHealth(context.Context, *connect.Request[v1.GetHealthRequest]) (*connect.Response[v1.GetHealthResponse], error)
	GetStatus(context.Context, *connect.Request[v1.GetStatusRequest]) (*connect.Response[v1.GetStatusResponse], error)
	GetNodeInfo(context.Context, *connect.Request[v1.GetNodeInfoRequest]) (*connect.Response[v1.GetNodeInfoResponse], error)
	GetBlock(context.Context, *connect.Request[v1.GetBlockRequest]) (*connect.Response[v1.GetBlockResponse], error)
	GetBlocks(context.Context, *connect.Request[v1.GetBlocksRequest]) (*connect.Response[v1.GetBlocksResponse], error)
	GetTransaction(context.Context, *connect.Request[v1.GetTransactionRequest]) (*connect.Response[v1.GetTransactionResponse], error)
	SendTransaction(context.Context, *connect.Request[v1.SendTransactionRequest]) (*connect.Response[v1.SendTransactionResponse], error)
	ForwardTransaction(context.Context, *connect.Request[v1.ForwardTransactionRequest]) (*connect.Response[v1.ForwardTransactionResponse], error)
	GetRegistrationAttestation(context.Context, *connect.Request[v1.GetRegistrationAttestationRequest]) (*connect.Response[v1.GetRegistrationAttestationResponse], error)
	GetDeregistrationAttestation(context.Context, *connect.Request[v1.GetDeregistrationAttestationRequest]) (*connect.Response[v1.GetDeregistrationAttestationResponse], error)
	GetStoredSnapshots(context.Context, *connect.Request[v1.GetStoredSnapshotsRequest]) (*connect.Response[v1.GetStoredSnapshotsResponse], error)
	GetSlashAttestation(context.Context, *connect.Request[v1.GetSlashAttestationRequest]) (*connect.Response[v1.GetSlashAttestationResponse], error)
	GetSlashAttestations(context.Context, *connect.Request[v1.GetSlashAttestationsRequest]) (*connect.Response[v1.GetSlashAttestationsResponse], error)
	GetERN(context.Context, *connect.Request[v1.GetERNRequest]) (*connect.Response[v1.GetERNResponse], error)
	GetMEAD(context.Context, *connect.Request[v1.GetMEADRequest]) (*connect.Response[v1.GetMEADResponse], error)
	GetPIE(context.Context, *connect.Request[v1.GetPIERequest]) (*connect.Response[v1.GetPIEResponse], error)
	GetReward(context.Context, *connect.Request[v1.GetRewardRequest]) (*connect.Response[v1.GetRewardResponse], error)
	GetRewards(context.Context, *connect.Request[v1.GetRewardsRequest]) (*connect.Response[v1.GetRewardsResponse], error)
	GetRewardAttestation(context.Context, *connect.Request[v1.GetRewardAttestationRequest]) (*connect.Response[v1.GetRewardAttestationResponse], error)
	GetStreamURLs(context.Context, *connect.Request[v1.GetStreamURLsRequest]) (*connect.Response[v1.GetStreamURLsResponse], error)
	GetUploadByCID(context.Context, *connect.Request[v1.GetUploadByCIDRequest]) (*connect.Response[v1.GetUploadByCIDResponse], error)
}

CoreServiceHandler is an implementation of the core.v1.CoreService service.

type UnimplementedCoreServiceHandler 

type UnimplementedCoreServiceHandler struct{}

UnimplementedCoreServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedCoreServiceHandler) ForwardTransaction 

func (UnimplementedCoreServiceHandler) ForwardTransaction(context.Context, *connect.Request[v1.ForwardTransactionRequest]) (*connect.Response[v1.ForwardTransactionResponse], error)

func (UnimplementedCoreServiceHandler) GetBlock 

func (UnimplementedCoreServiceHandler) GetBlock(context.Context, *connect.Request[v1.GetBlockRequest]) (*connect.Response[v1.GetBlockResponse], error)

func (UnimplementedCoreServiceHandler) GetBlocks 

func (UnimplementedCoreServiceHandler) GetBlocks(context.Context, *connect.Request[v1.GetBlocksRequest]) (*connect.Response[v1.GetBlocksResponse], error)

func (UnimplementedCoreServiceHandler) GetDeregistrationAttestation 

func (UnimplementedCoreServiceHandler) GetDeregistrationAttestation(context.Context, *connect.Request[v1.GetDeregistrationAttestationRequest]) (*connect.Response[v1.GetDeregistrationAttestationResponse], error)

func (UnimplementedCoreServiceHandler) GetERN 

func (UnimplementedCoreServiceHandler) GetERN(context.Context, *connect.Request[v1.GetERNRequest]) (*connect.Response[v1.GetERNResponse], error)

func (UnimplementedCoreServiceHandler) GetHealth 

func (UnimplementedCoreServiceHandler) GetHealth(context.Context, *connect.Request[v1.GetHealthRequest]) (*connect.Response[v1.GetHealthResponse], error)

func (UnimplementedCoreServiceHandler) GetMEAD 

func (UnimplementedCoreServiceHandler) GetMEAD(context.Context, *connect.Request[v1.GetMEADRequest]) (*connect.Response[v1.GetMEADResponse], error)

func (UnimplementedCoreServiceHandler) GetNodeInfo 

func (UnimplementedCoreServiceHandler) GetNodeInfo(context.Context, *connect.Request[v1.GetNodeInfoRequest]) (*connect.Response[v1.GetNodeInfoResponse], error)

func (UnimplementedCoreServiceHandler) GetPIE 

func (UnimplementedCoreServiceHandler) GetPIE(context.Context, *connect.Request[v1.GetPIERequest]) (*connect.Response[v1.GetPIEResponse], error)

func (UnimplementedCoreServiceHandler) GetRegistrationAttestation 

func (UnimplementedCoreServiceHandler) GetRegistrationAttestation(context.Context, *connect.Request[v1.GetRegistrationAttestationRequest]) (*connect.Response[v1.GetRegistrationAttestationResponse], error)

func (UnimplementedCoreServiceHandler) GetReward 

func (UnimplementedCoreServiceHandler) GetReward(context.Context, *connect.Request[v1.GetRewardRequest]) (*connect.Response[v1.GetRewardResponse], error)

func (UnimplementedCoreServiceHandler) GetRewardAttestation 

func (UnimplementedCoreServiceHandler) GetRewardAttestation(context.Context, *connect.Request[v1.GetRewardAttestationRequest]) (*connect.Response[v1.GetRewardAttestationResponse], error)

func (UnimplementedCoreServiceHandler) GetRewards 

func (UnimplementedCoreServiceHandler) GetRewards(context.Context, *connect.Request[v1.GetRewardsRequest]) (*connect.Response[v1.GetRewardsResponse], error)

func (UnimplementedCoreServiceHandler) GetSlashAttestation 

func (UnimplementedCoreServiceHandler) GetSlashAttestation(context.Context, *connect.Request[v1.GetSlashAttestationRequest]) (*connect.Response[v1.GetSlashAttestationResponse], error)

func (UnimplementedCoreServiceHandler) GetSlashAttestations 

func (UnimplementedCoreServiceHandler) GetSlashAttestations(context.Context, *connect.Request[v1.GetSlashAttestationsRequest]) (*connect.Response[v1.GetSlashAttestationsResponse], error)

func (UnimplementedCoreServiceHandler) GetStatus 

func (UnimplementedCoreServiceHandler) GetStatus(context.Context, *connect.Request[v1.GetStatusRequest]) (*connect.Response[v1.GetStatusResponse], error)

func (UnimplementedCoreServiceHandler) GetStoredSnapshots 

func (UnimplementedCoreServiceHandler) GetStoredSnapshots(context.Context, *connect.Request[v1.GetStoredSnapshotsRequest]) (*connect.Response[v1.GetStoredSnapshotsResponse], error)

func (UnimplementedCoreServiceHandler) GetStreamURLs 

func (UnimplementedCoreServiceHandler) GetStreamURLs(context.Context, *connect.Request[v1.GetStreamURLsRequest]) (*connect.Response[v1.GetStreamURLsResponse], error)

func (UnimplementedCoreServiceHandler) GetTransaction 

func (UnimplementedCoreServiceHandler) GetTransaction(context.Context, *connect.Request[v1.GetTransactionRequest]) (*connect.Response[v1.GetTransactionResponse], error)

func (UnimplementedCoreServiceHandler) GetUploadByCID 

func (UnimplementedCoreServiceHandler) GetUploadByCID(context.Context, *connect.Request[v1.GetUploadByCIDRequest]) (*connect.Response[v1.GetUploadByCIDResponse], error)

func (UnimplementedCoreServiceHandler) Ping 

func (UnimplementedCoreServiceHandler) Ping(context.Context, *connect.Request[v1.PingRequest]) (*connect.Response[v1.PingResponse], error)

func (UnimplementedCoreServiceHandler) SendTransaction 

func (UnimplementedCoreServiceHandler) SendTransaction(context.Context, *connect.Request[v1.SendTransactionRequest]) (*connect.Response[v1.SendTransactionResponse], error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.