utils

Documentation

Index

• Constants
• func BytesToString(data []byte, encoding int) (string, error)
• func RegisterHealthCheckService(s *grpc.Server)
• func StringToBytes(str string, encoding int) ([]byte, error)
• type DbConnection
  • func CheckDBConnection(ctx context.Context, runtime *sharedpb.SignedRuntimeInfoRequest, ...) (*sharedpb.RuntimeInfoReport, []DbConnection, error)
• type GrpcHealthServer
  • func (s *GrpcHealthServer) Check(context.Context, *he.HealthCheckRequest) (*he.HealthCheckResponse, error)
  • func (s *GrpcHealthServer) Watch(*he.HealthCheckRequest, he.Health_WatchServer) error
• type PostgresObj
• type RedisObj

Constants

const (
	Text = iota + 1
	Base64
)

const DBURLDNE = "DB URL does not exist !!"

DBURLDNE database does not exist or unreachable

const RDURLDNE = "RD URL does not exist !!"

RDURLDNE redis does not exist or unreachable

Functions

func BytesToString

func BytesToString(data []byte, encoding int) (string, error)

func RegisterHealthCheckService

func RegisterHealthCheckService(s *grpc.Server)

func StringToBytes

func StringToBytes(str string, encoding int) ([]byte, error)

Types

type DbConnection

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

func CheckDBConnection

func CheckDBConnection(ctx context.Context, runtime *sharedpb.SignedRuntimeInfoRequest,
	connection db.ConnectionUrls) (*sharedpb.RuntimeInfoReport, []DbConnection, error)

CheckDBConnection checks database connections.

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

type PostgresObj

type PostgresObj struct {
	DBs map[string]*postgres.TGPGDB
	// contains filtered or unexported fields
}

type RedisObj

type RedisObj struct {
	DB *redis.TGRDDB
	// contains filtered or unexported fields
}