grpc

Documentation

Index

• Variables
• func CreateServer(logger *zap.Logger, grpcOption config.GRPC, ...) *grpc.Server
• type IClientConn
  • func CreateClient(domain string, option config.GRPC) (IClientConn, error)
• type IRegister
• type IService

Variables

var (
	// Dial variable
	Dial = grpc.Dial
)

Functions

func CreateServer

func CreateServer(logger *zap.Logger, grpcOption config.GRPC, authenticateService services.IAuthenticate) *grpc.Server

Types

type IClientConn

type IClientConn interface {
	WaitForStateChange(ctx context.Context, sourceState connectivity.State) bool
	GetState() connectivity.State
	Target() string
	GetMethodConfig(method string) grpc.MethodConfig
	ResetConnectBackoff()
	Close() error
	NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
	Invoke(ctx context.Context, method string, args, reply interface{}, opts ...grpc.CallOption) error
}

IClientConn interface

func CreateClient

func CreateClient(domain string, option config.GRPC) (IClientConn, error)

CreateClient method

type IRegister

type IRegister interface {
	Handler(*grpc.Server)
}

IRegister interface

type IService

type IService interface {
	GetSession() (IClientConn, error)
	Close() error
}

IService interface