rpc

Documentation

Index

• func NewServer(h *Handler, logger *zap.Logger) *grpc.Server
• type Handler
  • func NewHandler(vaaSrv *vaaservice.Service, hbSrv *heartbeats.Service, ...) *Handler
  • func (h *Handler) GetCurrentGuardianSet(ctx context.Context, request *publicrpcv1.GetCurrentGuardianSetRequest) (*publicrpcv1.GetCurrentGuardianSetResponse, error)
  • func (h *Handler) GetLastHeartbeats(ctx context.Context, request *publicrpcv1.GetLastHeartbeatsRequest) (*publicrpcv1.GetLastHeartbeatsResponse, error)
  • func (h *Handler) GetSignedBatchVAA(ctx context.Context, _ any) (any, error)
  • func (h *Handler) GetSignedVAA(ctx context.Context, request *publicrpcv1.GetSignedVAARequest) (*publicrpcv1.GetSignedVAAResponse, error)
  • func (h *Handler) GovernorGetAvailableNotionalByChain(ctx context.Context, _ *publicrpcv1.GovernorGetAvailableNotionalByChainRequest) (*publicrpcv1.GovernorGetAvailableNotionalByChainResponse, error)
  • func (h *Handler) GovernorGetEnqueuedVAAs(ctx context.Context, _ *publicrpcv1.GovernorGetEnqueuedVAAsRequest) (*publicrpcv1.GovernorGetEnqueuedVAAsResponse, error)
  • func (h *Handler) GovernorGetTokenList(ctx context.Context, _ *publicrpcv1.GovernorGetTokenListRequest) (*publicrpcv1.GovernorGetTokenListResponse, error)
  • func (h *Handler) GovernorIsVAAEnqueued(ctx context.Context, request *publicrpcv1.GovernorIsVAAEnqueuedRequest) (*publicrpcv1.GovernorIsVAAEnqueuedResponse, error)
• type Server

Functions

func NewServer

func NewServer(h *Handler, logger *zap.Logger) *grpc.Server

NewServer creates a GRPC server.

Types

type Handler

type Handler struct {
	publicrpcv1.UnimplementedPublicRPCServiceServer
	// contains filtered or unexported fields
}

Handler rpc handler.

func NewHandler

func NewHandler(vaaSrv *vaaservice.Service, hbSrv *heartbeats.Service, govSrv *governor.Service, guardianSrv *guardian.Service, logger *zap.Logger) *Handler

NewHandler create a new rpc Handler.

func (*Handler) GetCurrentGuardianSet

func (h *Handler) GetCurrentGuardianSet(ctx context.Context, request *publicrpcv1.GetCurrentGuardianSetRequest) (*publicrpcv1.GetCurrentGuardianSetResponse, error)

GetCurrentGuardianSet get current guardian set.

func (*Handler) GetLastHeartbeats

func (h *Handler) GetLastHeartbeats(ctx context.Context, request *publicrpcv1.GetLastHeartbeatsRequest) (*publicrpcv1.GetLastHeartbeatsResponse, error)

GetLastHeartbeats get last heartbeats.

func (*Handler) GetSignedBatchVAA

func (h *Handler) GetSignedBatchVAA(ctx context.Context, _ any) (any, error)

GetSignedBatchVAA get signed batch VAA.

func (*Handler) GetSignedVAA

func (h *Handler) GetSignedVAA(ctx context.Context, request *publicrpcv1.GetSignedVAARequest) (*publicrpcv1.GetSignedVAAResponse, error)

GetSignedVAA get signedVAA by chainID, address, sequence.

func (*Handler) GovernorGetAvailableNotionalByChain

func (h *Handler) GovernorGetAvailableNotionalByChain(ctx context.Context, _ *publicrpcv1.GovernorGetAvailableNotionalByChainRequest) (*publicrpcv1.GovernorGetAvailableNotionalByChainResponse, error)

GovernorGetAvailableNotionalByChain get availableNotional.

func (*Handler) GovernorGetEnqueuedVAAs

func (h *Handler) GovernorGetEnqueuedVAAs(ctx context.Context, _ *publicrpcv1.GovernorGetEnqueuedVAAsRequest) (*publicrpcv1.GovernorGetEnqueuedVAAsResponse, error)

GovernorGetEnqueuedVAAs get enqueuedVaa.

func (*Handler) GovernorGetTokenList

func (h *Handler) GovernorGetTokenList(ctx context.Context, _ *publicrpcv1.GovernorGetTokenListRequest) (*publicrpcv1.GovernorGetTokenListResponse, error)

GovernorGetTokenList get governor token list.

func (*Handler) GovernorIsVAAEnqueued

func (h *Handler) GovernorIsVAAEnqueued(ctx context.Context, request *publicrpcv1.GovernorIsVAAEnqueuedRequest) (*publicrpcv1.GovernorIsVAAEnqueuedResponse, error)

GovernorIsVAAEnqueued check if a vaa is enqueued.

type Server

type Server struct {
	Srv *grpc.Server
}