Documentation ¶
Overview ¶
Copyright 2019 The OpenPitrix Authors. All rights reserved. Use of this source code is governed by a Apache license that can be found in the LICENSE file.
Index ¶
- func Serve()
- func ServeApiGateway()
- func ValidateCreateAddressParams(ctx context.Context, req *pb.CreateAddressRequest) error
- func ValidateCreateNotificationParams(ctx context.Context, req *pb.CreateNotificationRequest) error
- func ValidateModifyAddressParams(ctx context.Context, req *pb.ModifyAddressRequest) error
- func ValidateSetServiceConfigParams(ctx context.Context, req *pb.ServiceConfig) error
- func VerifyAvailableTimeStr(ctx context.Context, timeStr string) error
- func VerifyEmailFmt(ctx context.Context, emailStr string) error
- func VerifyPortFmt(ctx context.Context, port int32) error
- type Controller
- type Server
- func (s *Server) Checker(ctx context.Context, req interface{}) error
- func (s *Server) CreateAddress(ctx context.Context, req *pb.CreateAddressRequest) (*pb.CreateAddressResponse, error)
- func (s *Server) CreateAddressList(ctx context.Context, req *pb.CreateAddressListRequest) (*pb.CreateAddressListResponse, error)
- func (s *Server) CreateNotification(ctx context.Context, req *pb.CreateNotificationRequest) (*pb.CreateNotificationResponse, error)
- func (s *Server) CreateNotificationChannel(req *pb.StreamReqData, res pb.Notification_CreateNotificationChannelServer) error
- func (s *Server) DeleteAddressList(ctx context.Context, req *pb.DeleteAddressListRequest) (*pb.DeleteAddressListResponse, error)
- func (s *Server) DeleteAddresses(ctx context.Context, req *pb.DeleteAddressesRequest) (*pb.DeleteAddressesResponse, error)
- func (s *Server) DescribeAddressList(ctx context.Context, req *pb.DescribeAddressListRequest) (*pb.DescribeAddressListResponse, error)
- func (s *Server) DescribeAddresses(ctx context.Context, req *pb.DescribeAddressesRequest) (*pb.DescribeAddressesResponse, error)
- func (s *Server) DescribeNotifications(ctx context.Context, req *pb.DescribeNotificationsRequest) (*pb.DescribeNotificationsResponse, error)
- func (s *Server) DescribeTasks(ctx context.Context, req *pb.DescribeTasksRequest) (*pb.DescribeTasksResponse, error)
- func (s *Server) GetServiceConfig(ctx context.Context, req *pb.GetServiceConfigRequest) (*pb.ServiceConfig, error)
- func (s *Server) ModifyAddress(ctx context.Context, req *pb.ModifyAddressRequest) (*pb.ModifyAddressResponse, error)
- func (s *Server) ModifyAddressList(ctx context.Context, req *pb.ModifyAddressListRequest) (*pb.ModifyAddressListResponse, error)
- func (s *Server) RetryNotifications(ctx context.Context, req *pb.RetryNotificationsRequest) (*pb.RetryNotificationsResponse, error)
- func (s *Server) RetryTasks(ctx context.Context, req *pb.RetryTasksRequest) (*pb.RetryTasksResponse, error)
- func (s *Server) SetServiceConfig(ctx context.Context, req *pb.ServiceConfig) (*pb.SetServiceConfigResponse, error)
- func (s *Server) ValidateEmailService(ctx context.Context, req *pb.ServiceConfig) (*pb.ValidateEmailServiceResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ServeApiGateway ¶
func ServeApiGateway()
func ValidateCreateAddressParams ¶
func ValidateCreateAddressParams(ctx context.Context, req *pb.CreateAddressRequest) error
func ValidateCreateNotificationParams ¶
func ValidateCreateNotificationParams(ctx context.Context, req *pb.CreateNotificationRequest) error
func ValidateModifyAddressParams ¶
func ValidateModifyAddressParams(ctx context.Context, req *pb.ModifyAddressRequest) error
func ValidateSetServiceConfigParams ¶
func ValidateSetServiceConfigParams(ctx context.Context, req *pb.ServiceConfig) error
func VerifyAvailableTimeStr ¶
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func NewController ¶
func NewController() (*Controller, error)
func (*Controller) ExtractNotifications ¶
func (c *Controller) ExtractNotifications() error
func (*Controller) ExtractTasks ¶
func (c *Controller) ExtractTasks() error
func (*Controller) HandleNotification ¶
func (c *Controller) HandleNotification(handlerNum string)
func (*Controller) HandleTask ¶
func (c *Controller) HandleTask(handlerNum string)
func (*Controller) Serve ¶
func (c *Controller) Serve()
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func (*Server) CreateAddress ¶
func (s *Server) CreateAddress(ctx context.Context, req *pb.CreateAddressRequest) (*pb.CreateAddressResponse, error)
func (*Server) CreateAddressList ¶
func (s *Server) CreateAddressList(ctx context.Context, req *pb.CreateAddressListRequest) (*pb.CreateAddressListResponse, error)
func (*Server) CreateNotification ¶
func (s *Server) CreateNotification(ctx context.Context, req *pb.CreateNotificationRequest) (*pb.CreateNotificationResponse, error)
func (*Server) CreateNotificationChannel ¶
func (s *Server) CreateNotificationChannel(req *pb.StreamReqData, res pb.Notification_CreateNotificationChannelServer) error
func (*Server) DeleteAddressList ¶
func (s *Server) DeleteAddressList(ctx context.Context, req *pb.DeleteAddressListRequest) (*pb.DeleteAddressListResponse, error)
func (*Server) DeleteAddresses ¶
func (s *Server) DeleteAddresses(ctx context.Context, req *pb.DeleteAddressesRequest) (*pb.DeleteAddressesResponse, error)
func (*Server) DescribeAddressList ¶
func (s *Server) DescribeAddressList(ctx context.Context, req *pb.DescribeAddressListRequest) (*pb.DescribeAddressListResponse, error)
func (*Server) DescribeAddresses ¶
func (s *Server) DescribeAddresses(ctx context.Context, req *pb.DescribeAddressesRequest) (*pb.DescribeAddressesResponse, error)
func (*Server) DescribeNotifications ¶
func (s *Server) DescribeNotifications(ctx context.Context, req *pb.DescribeNotificationsRequest) (*pb.DescribeNotificationsResponse, error)
func (*Server) DescribeTasks ¶
func (s *Server) DescribeTasks(ctx context.Context, req *pb.DescribeTasksRequest) (*pb.DescribeTasksResponse, error)
func (*Server) GetServiceConfig ¶
func (s *Server) GetServiceConfig(ctx context.Context, req *pb.GetServiceConfigRequest) (*pb.ServiceConfig, error)
func (*Server) ModifyAddress ¶
func (s *Server) ModifyAddress(ctx context.Context, req *pb.ModifyAddressRequest) (*pb.ModifyAddressResponse, error)
func (*Server) ModifyAddressList ¶
func (s *Server) ModifyAddressList(ctx context.Context, req *pb.ModifyAddressListRequest) (*pb.ModifyAddressListResponse, error)
func (*Server) RetryNotifications ¶
func (s *Server) RetryNotifications(ctx context.Context, req *pb.RetryNotificationsRequest) (*pb.RetryNotificationsResponse, error)
func (*Server) RetryTasks ¶
func (s *Server) RetryTasks(ctx context.Context, req *pb.RetryTasksRequest) (*pb.RetryTasksResponse, error)
func (*Server) SetServiceConfig ¶
func (s *Server) SetServiceConfig(ctx context.Context, req *pb.ServiceConfig) (*pb.SetServiceConfigResponse, error)
func (*Server) ValidateEmailService ¶
func (s *Server) ValidateEmailService(ctx context.Context, req *pb.ServiceConfig) (*pb.ValidateEmailServiceResponse, error)
Source Files ¶
Click to show internal directories.
Click to hide internal directories.