manager

Documentation

Index

• Constants
• Variables
• func AddQueryJoinWithMap(query *db.SelectQuery, ...) *db.SelectQuery
• func AddQueryOrderDir(query *db.SelectQuery, req Request, column string) *db.SelectQuery
• func BuildFilterConditions(req Request, tableName string, exclude ...string) dbr.Builder
• func BuildFilterConditionsWithPrefix(req Request, tableName string, exclude ...string) dbr.Builder
• func BuildUpdateAttributes(req Request, columns ...string) map[string]interface{}
• func NewChecker(ctx context.Context, req Request) *checker
• func NewClient(host string, port int) (*grpc.ClientConn, error)
• type GrpcServer
  • func NewGrpcServer(serviceName string, port int) *GrpcServer
  • func (g *GrpcServer) Serve(callback RegisterCallback)
  • func (g *GrpcServer) ShowErrorCause(b bool) *GrpcServer
  • func (g *GrpcServer) WithChecker(c checkerT) *GrpcServer
• type RegisterCallback
• type Request
• type RequestWithReverse
• type RequestWithSortKey

Constants

const (
	TagName              = "json"
	SearchWordColumnName = "search_word"
)

Variables

var ClientOptions = []grpc.DialOption{
	grpc.WithInsecure(),
	grpc.WithKeepaliveParams(keepalive.ClientParameters{
		Time:                30 * time.Second,
		Timeout:             10 * time.Second,
		PermitWithoutStream: true,
	}),
}

Functions

func AddQueryJoinWithMap

func AddQueryJoinWithMap(query *db.SelectQuery, table, joinTable, primaryKey, keyField, valueField string, filterMap map[string][]string) *db.SelectQuery

func AddQueryOrderDir

func AddQueryOrderDir(query *db.SelectQuery, req Request, column string) *db.SelectQuery

func BuildFilterConditions

func BuildFilterConditions(req Request, tableName string, exclude ...string) dbr.Builder

func BuildFilterConditionsWithPrefix

func BuildFilterConditionsWithPrefix(req Request, tableName string, exclude ...string) dbr.Builder

func BuildUpdateAttributes

func BuildUpdateAttributes(req Request, columns ...string) map[string]interface{}

func NewChecker

func NewChecker(ctx context.Context, req Request) *checker

func NewClient

func NewClient(host string, port int) (*grpc.ClientConn, error)

Types

type GrpcServer

type GrpcServer struct {
	ServiceName string
	Port        int
	// contains filtered or unexported fields
}

func NewGrpcServer

func NewGrpcServer(serviceName string, port int) *GrpcServer

func (*GrpcServer) Serve

func (g *GrpcServer) Serve(callback RegisterCallback)

func (*GrpcServer) ShowErrorCause

func (g *GrpcServer) ShowErrorCause(b bool) *GrpcServer

func (*GrpcServer) WithChecker

func (g *GrpcServer) WithChecker(c checkerT) *GrpcServer

type RegisterCallback

type RegisterCallback func(*grpc.Server)

type Request

type Request interface {
	Reset()
	String() string
	ProtoMessage()
	Descriptor() ([]byte, []int)
}

type RequestWithReverse

type RequestWithReverse interface {
	RequestWithSortKey
	GetReverse() *wrappers.BoolValue
}

type RequestWithSortKey

type RequestWithSortKey interface {
	Request
	GetSortKey() *wrappers.StringValue
}