manager

package

v0.1.1 Latest Latest Go to latest Published: Jun 19, 2018 License: Apache-2.0 Imports: 28 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/pengcong06/openpitrix

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
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 CheckParamsRequired(req Request, columns ...string) error
func NewClient(ctx context.Context, host string, port int) (*grpc.ClientConn, error)
func UnaryServerLogInterceptor(showErrorCause bool) grpc.UnaryServerInterceptor
type GrpcServer
- func NewGrpcServer(serviceName string, port int) *GrpcServer
- func (g *GrpcServer) Serve(callback RegisterCallback)
- func (g *GrpcServer) ShowErrorCause(b bool) *GrpcServer
type RegisterCallback
type Request
type RequestWithReverse
type RequestWithSortKey

Constants ¶

View Source

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

Variables ¶

This section is empty.

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 CheckParamsRequired ¶

func CheckParamsRequired(req Request, columns ...string) error

func NewClient ¶

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

func UnaryServerLogInterceptor ¶

func UnaryServerLogInterceptor(showErrorCause bool) grpc.UnaryServerInterceptor

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

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
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL