Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

server

package

Go to main page

Versions in this module

v1

v1.0.7

Aug 2, 2022

v1.0.6

Jul 31, 2022

v1.0.5

Jul 20, 2022

v1.0.4

Jul 6, 2022

v1.0.3

Jul 5, 2022

v1.0.2

Mar 8, 2022

v1.0.1

Mar 7, 2022

Changes in this version

+ func GetServer(path string, opts ...Option) (svr interfaces.GrpcServer, err error)

+ func HandleError(err error) (res *grpc.Response, err2 error)

+ func HandleSuccess() (res *grpc.Response, err error)

+ func HandleSuccessWithData(data interface{}) (res *grpc.Response, err error)

+ func HandleSuccessWithListData(data interface{}, total int) (res *grpc.Response, err error)

+ func NewServer(opts ...Option) (svr2 interfaces.GrpcServer, err error)

+ func ProvideGetServer(path string, opts ...Option) func() (svr interfaces.GrpcServer, err error)

+ func ProvideMessageServer(server interfaces.GrpcServer, opts ...MessageServerOption) func() (res *MessageServer, err error)

+ func ProvideNodeServer(server interfaces.GrpcServer, opts ...NodeServerOption) func() (res *NodeServer, err error)

+ func ProvidePluginServer(server interfaces.GrpcServer, opts ...PluginServerOption) func() (res *PluginServer, err error)

+ func ProvideServer(path string, opts ...Option) func() (res interfaces.GrpcServer, err error)

+ func ProvideTaskServer(server interfaces.GrpcServer, opts ...TaskServerOption) func() (res *TaskServer, err error)

+ type MessageServer struct

+ func NewMessageServer(opts ...MessageServerOption) (res *MessageServer, err error)

+ func (svr MessageServer) Connect(stream grpc.MessageService_ConnectServer) (err error)

+ type MessageServerOption func(svr *MessageServer)

+ func WithServerMessageServerService(server interfaces.GrpcServer) MessageServerOption

+ type ModelBaseServiceBinder struct

+ func NewModelBaseServiceBinder(req *grpc.Request) (b *ModelBaseServiceBinder)

+ func (b *ModelBaseServiceBinder) Bind() (res *entity.GrpcBaseServiceParams, err error)

+ func (b *ModelBaseServiceBinder) BindWithBaseServiceMessage() (params *entity.GrpcBaseServiceParams, ...)

+ func (b *ModelBaseServiceBinder) MustBind() (res interface{})

+ type ModelBaseServiceServer struct

+ func NewModelBaseServiceServer() (svr2 *ModelBaseServiceServer, err error)

+ func (svr ModelBaseServiceServer) Count(ctx context.Context, req *grpc.Request) (res *grpc.Response, err error)

+ func (svr ModelBaseServiceServer) Delete(ctx context.Context, req *grpc.Request) (res *grpc.Response, err error)

+ func (svr ModelBaseServiceServer) DeleteById(ctx context.Context, req *grpc.Request) (res *grpc.Response, err error)

+ func (svr ModelBaseServiceServer) DeleteList(ctx context.Context, req *grpc.Request) (res *grpc.Response, err error)

+ func (svr ModelBaseServiceServer) ForceDeleteList(ctx context.Context, req *grpc.Request) (res *grpc.Response, err error)

+ func (svr ModelBaseServiceServer) Get(ctx context.Context, req *grpc.Request) (res *grpc.Response, err error)

+ func (svr ModelBaseServiceServer) GetById(ctx context.Context, req *grpc.Request) (res *grpc.Response, err error)

+ func (svr ModelBaseServiceServer) GetList(ctx context.Context, req *grpc.Request) (res *grpc.Response, err error)

+ func (svr ModelBaseServiceServer) Insert(ctx context.Context, req *grpc.Request) (res *grpc.Response, err error)

+ func (svr ModelBaseServiceServer) Update(ctx context.Context, req *grpc.Request) (res *grpc.Response, err error)

+ func (svr ModelBaseServiceServer) UpdateById(ctx context.Context, req *grpc.Request) (res *grpc.Response, err error)

+ func (svr ModelBaseServiceServer) UpdateDoc(ctx context.Context, req *grpc.Request) (res *grpc.Response, err error)

+ type ModelDelegateBinder struct

+ func NewModelDelegateBinder(req *grpc.Request) (b *ModelDelegateBinder)

+ func (b *ModelDelegateBinder) Bind() (res interface{}, err error)

+ func (b *ModelDelegateBinder) BindWithDelegateMessage() (res interface{}, msg interfaces.GrpcModelDelegateMessage, err error)

+ func (b *ModelDelegateBinder) MustBind() (res interface{})

+ type ModelDelegateServer struct

+ func NewModelDelegateServer() (svr *ModelDelegateServer)

+ func (svr ModelDelegateServer) Do(ctx context.Context, req *grpc.Request) (res *grpc.Response, err error)

+ type NodeServer struct

+ func NewNodeServer(opts ...NodeServerOption) (res *NodeServer, err error)

+ func (svr NodeServer) Ping(ctx context.Context, req *grpc.Request) (res *grpc.Response, err error)

+ func (svr NodeServer) Register(ctx context.Context, req *grpc.Request) (res *grpc.Response, err error)

+ func (svr NodeServer) SendHeartbeat(ctx context.Context, req *grpc.Request) (res *grpc.Response, err error)

+ func (svr NodeServer) Subscribe(request *grpc.Request, stream grpc.NodeService_SubscribeServer) (err error)

+ func (svr NodeServer) Unsubscribe(ctx context.Context, req *grpc.Request) (res *grpc.Response, err error)

+ type NodeServerOption func(svr *NodeServer)

+ func WithServerNodeServerService(server interfaces.GrpcServer) NodeServerOption

+ type Option func(svr interfaces.GrpcServer)

+ func WithAddress(address interfaces.Address) Option

+ func WithConfigPath(path string) Option

+ type PluginServer struct

+ func NewPluginServer(opts ...PluginServerOption) (res *PluginServer, err error)

+ func (svr PluginServer) Poll(stream grpc.PluginService_PollServer) (err error)

+ func (svr PluginServer) Register(ctx context.Context, req *grpc.PluginRequest) (res *grpc.Response, err error)

+ func (svr PluginServer) Subscribe(req *grpc.PluginRequest, stream grpc.PluginService_SubscribeServer) (err error)

+ type PluginServerOption func(svr *PluginServer)

+ func WithServerPluginServerService(server interfaces.GrpcServer) PluginServerOption

+ type Server struct

+ func (svr *Server) DeleteSubscribe(key string)

+ func (svr *Server) GetConfigPath() (path string)

+ func (svr *Server) GetSubscribe(key string) (sub interfaces.GrpcSubscribe, err error)

+ func (svr *Server) Init() (err error)

+ func (svr *Server) IsStopped() (res bool)

+ func (svr *Server) Register() (err error)

+ func (svr *Server) SendStreamMessage(key string, code grpc2.StreamMessageCode) (err error)

+ func (svr *Server) SendStreamMessageWithData(key string, code grpc2.StreamMessageCode, d interface{}) (err error)

+ func (svr *Server) SetAddress(address interfaces.Address)

+ func (svr *Server) SetConfigPath(path string)

+ func (svr *Server) SetSubscribe(key string, sub interfaces.GrpcSubscribe)

+ func (svr *Server) Start() (err error)

+ func (svr *Server) Stop() (err error)

+ type TaskServer struct

+ func NewTaskServer(opts ...TaskServerOption) (res *TaskServer, err error)

+ func (svr TaskServer) Subscribe(stream grpc.TaskService_SubscribeServer) (err error)

+ type TaskServerOption func(svr *TaskServer)

+ func WithServerTaskServerService(server interfaces.GrpcServer) TaskServerOption