wrapper

README

Wrapper

Application wrapper library

Wrapper is a golang library to wrap objects into one bigger structure and handle dynamic openning on usage.

• Usage
• Firebase App
• Grpc Server
• Postgresql Connection

Usage

Create a raw wrapper object

package main

import "gitlab.com/redpanda-utils/wrapper"

func main() {
	w := wrapper.NewWrapper()
}

This object does not have any subojects. You can customize your wrapper by issuing the proper methods.

Firebase App

Add firebase app:

package main

import "gitlab.com/redpanda-utils/wrapper"

func main() {
	w := wrapper.NewWrapper()

	/* Add firebase app */
	w.OpenFirebaseApp()

	/* Use the method FirebaseApp() to obtain the firebase app */
}

Grpc Server

Add grpc server:

package main

import "gitlab.com/redpanda-utils/wrapper"

func main() {
	w := wrapper.NewWrapper()

	/* Add grpc server */
	w.OpenGrpcServer("0.0.0.0", "5012")
	
	/* For a TLS grpc server use this function */
	/* w.OpenGrpcTLSServer("0.0.0.0", "5012", "cert.pem", "key.pem") */

	/* Use the method GrpcServer() to obtain the grpc server and set the proper
		endpoints */

	/* Serve */
	w.ServeGrpcServer()
}

Postgresql Connection

Add postgresql connection:

package main

import "gitlab.com/redpanda-utils/wrapper"

func main() {
	w := wrapper.NewWrapper()

	/* Add psql connection */
	w.OpenPsqlConn(host, port, database_name, schema, user, password)

	/* Use the method PsqlConn() to obtain postgresql connection */

	/* Close */
	w.ClosePsqlConn()
}

Documentation

Index

• type Wrapper
  • func NewWrapper() *Wrapper
  • func (wrapper *Wrapper) CloseKafkaConn()
  • func (wrapper *Wrapper) ClosePsqlConn()
  • func (wrapper *Wrapper) FirebaseApp() (*firebase.App, error)
  • func (wrapper *Wrapper) GrpcServer() (*grpc.Server, error)
  • func (wrapper *Wrapper) KafkaConnConsumer() (*kafka.Consumer, error)
  • func (wrapper *Wrapper) KafkaConnProducer() (*kafka.Producer, error)
  • func (wrapper *Wrapper) OpenFirebaseApp() error
  • func (wrapper *Wrapper) OpenGrpcServer(ifc, port string) error
  • func (wrapper *Wrapper) OpenGrpcTLSServer(ifc, port, cert, key string) error
  • func (wrapper *Wrapper) OpenKafkaConn() error
  • func (wrapper *Wrapper) OpenKafkaConnConsumer(server, groupId, autoOffsetReset string) error
  • func (wrapper *Wrapper) OpenKafkaConnProducer() error
  • func (wrapper *Wrapper) OpenPsqlConn(host, port, name, schema, user, password string) error
  • func (wrapper *Wrapper) PsqlConn() (*gorm.DB, error)
  • func (wrapper *Wrapper) ServeGrpcServer() error

Types

type Wrapper

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

Wrapper type

func NewWrapper

func NewWrapper() *Wrapper

Creates a new wrapper

func (*Wrapper) CloseKafkaConn

func (wrapper *Wrapper) CloseKafkaConn()

Closes kafka connection

func (*Wrapper) ClosePsqlConn

func (wrapper *Wrapper) ClosePsqlConn()

Closes psql server

func (*Wrapper) FirebaseApp

func (wrapper *Wrapper) FirebaseApp() (*firebase.App, error)

Returns firebase app

func (*Wrapper) GrpcServer

func (wrapper *Wrapper) GrpcServer() (*grpc.Server, error)

Returns grpc server

func (*Wrapper) KafkaConnConsumer

func (wrapper *Wrapper) KafkaConnConsumer() (*kafka.Consumer, error)

Returns kafka connection consumer

func (*Wrapper) KafkaConnProducer

func (wrapper *Wrapper) KafkaConnProducer() (*kafka.Producer, error)

Returns kafka connection producer

func (*Wrapper) OpenFirebaseApp

func (wrapper *Wrapper) OpenFirebaseApp() error

Opens firebase app

func (*Wrapper) OpenGrpcServer

func (wrapper *Wrapper) OpenGrpcServer(ifc, port string) error

Opens grpc server

func (*Wrapper) OpenGrpcTLSServer

func (wrapper *Wrapper) OpenGrpcTLSServer(ifc, port, cert, key string) error

Opens grpc TLS server

func (*Wrapper) OpenKafkaConn

func (wrapper *Wrapper) OpenKafkaConn() error

Opens kafka connection both consumer and producer

func (*Wrapper) OpenKafkaConnConsumer

func (wrapper *Wrapper) OpenKafkaConnConsumer(server, groupId,
	autoOffsetReset string) error

Opens kafka connection consumer

func (*Wrapper) OpenKafkaConnProducer

func (wrapper *Wrapper) OpenKafkaConnProducer() error

Opens kafka connection producer

func (*Wrapper) OpenPsqlConn

func (wrapper *Wrapper) OpenPsqlConn(host, port, name, schema, user,
	password string) error

Opens psql server

func (*Wrapper) PsqlConn

func (wrapper *Wrapper) PsqlConn() (*gorm.DB, error)

Returns psql connection

func (*Wrapper) ServeGrpcServer

func (wrapper *Wrapper) ServeGrpcServer() error

Serves grpc server