manager

Documentation

Index

• Constants
• Variables
• func AddQueryJoinWithMap(query *db.SelectQuery, ...) *db.SelectQuery
• func AddQueryOrderDir(query *db.SelectQuery, req Request, defaultColumn string) *db.SelectQuery
• func AddQueryOrderDirWithPrefix(query *db.SelectQuery, req Request, defaultColumn, tableName string) *db.SelectQuery
• func BuildFilterConditions(req Request, tableName string, exclude ...string) dbr.Builder
• func BuildFilterConditionsWithPrefix(req Request, tableName string, exclude ...string) dbr.Builder
• func BuildPermissionFilter(ctx context.Context) dbr.Builder
• func BuildPermissionFilterWithPrefix(ctx context.Context, prefix string) dbr.Builder
• func BuildUpdateAttributes(req Request, columns ...string) map[string]interface{}
• func GetDisplayColumns(displayColumns []string, wholeColumns []string) []string
• func NewChecker(ctx context.Context, req Request) *checker
• func NewClient(host string, port int) (*grpc.ClientConn, error)
• func NewTLSClient(host string, port int, tlsConfig *tls.Config) (*grpc.ClientConn, error)
• type GrpcServer
  • func NewGrpcServer(serviceName string, port int) *GrpcServer
  • func (g *GrpcServer) Serve(callback RegisterCallback, opt ...grpc.ServerOption)
  • func (g *GrpcServer) ShowErrorCause(b bool) *GrpcServer
  • func (g *GrpcServer) WithBuilder(b builderT) *GrpcServer
  • func (g *GrpcServer) WithChecker(c checkerT) *GrpcServer
  • func (g *GrpcServer) WithMysqlConfig(cfg config.MysqlConfig) *GrpcServer
• type RegisterCallback
• type Request
• type RequestWithOwner
• 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, defaultColumn string) *db.SelectQuery

func AddQueryOrderDirWithPrefix

func AddQueryOrderDirWithPrefix(query *db.SelectQuery, req Request, defaultColumn, tableName 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 BuildPermissionFilter

func BuildPermissionFilter(ctx context.Context) dbr.Builder

func BuildPermissionFilterWithPrefix

func BuildPermissionFilterWithPrefix(ctx context.Context, prefix string) dbr.Builder

func BuildUpdateAttributes

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

func GetDisplayColumns

func GetDisplayColumns(displayColumns []string, wholeColumns []string) []string

func NewChecker

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

func NewClient

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

func NewTLSClient

func NewTLSClient(host string, port int, tlsConfig *tls.Config) (*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, opt ...grpc.ServerOption)

func (*GrpcServer) ShowErrorCause

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

func (*GrpcServer) WithBuilder

func (g *GrpcServer) WithBuilder(b builderT) *GrpcServer

func (*GrpcServer) WithChecker

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

func (*GrpcServer) WithMysqlConfig

func (g *GrpcServer) WithMysqlConfig(cfg config.MysqlConfig) *GrpcServer

type RegisterCallback

type RegisterCallback func(*grpc.Server)

type Request

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

type RequestWithOwner

type RequestWithOwner interface {
	Request
	GetOwner() []string
}

type RequestWithReverse

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

type RequestWithSortKey

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