utils

Documentation

Index

• func CheckRuntime(ctx context.Context, runtime *sharedpb.SignedRuntimeInfoRequest, ...) (*sharedpb.RuntimeInfoReport, error)
• func NewGRPCConn(ctx context.Context, address string, opts ...grpc.DialOption) (*grpc.ClientConn, error)
• func RegisterHealthCheckService(s *grpc.Server)
• type GrpcHealthServer
  • func (s *GrpcHealthServer) Check(context.Context, *he.HealthCheckRequest) (*he.HealthCheckResponse, error)
  • func (s *GrpcHealthServer) Watch(*he.HealthCheckRequest, he.Health_WatchServer) error

Functions

func CheckRuntime

func CheckRuntime(ctx context.Context, runtime *sharedpb.SignedRuntimeInfoRequest, connection db.ConnectionUrls) (*sharedpb.RuntimeInfoReport, error)

func NewGRPCConn

func NewGRPCConn(ctx context.Context, address string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

func RegisterHealthCheckService

func RegisterHealthCheckService(s *grpc.Server)

Types

type GrpcHealthServer

type GrpcHealthServer struct{}

func (*GrpcHealthServer) Check

func (s *GrpcHealthServer) Check(context.Context, *he.HealthCheckRequest) (*he.HealthCheckResponse, error)

func (*GrpcHealthServer) Watch

func (s *GrpcHealthServer) Watch(*he.HealthCheckRequest, he.Health_WatchServer) error