notification

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 17, 2026 License: Apache-2.0 Imports: 38 Imported by: 0

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

Constants

This section is empty.

Variables

This section is empty.

Functions

func Serve 

func Serve()

func ServeApiGateway 

func ServeApiGateway()

func ValidatModifyAddressList 

func ValidatModifyAddressList(ctx context.Context, req *pb.ModifyAddressListRequest) error

func ValidateCreateAddress 

func ValidateCreateAddress(ctx context.Context, req *pb.CreateAddressRequest) error

**************************************** Validate Address ****************************************

func ValidateCreateAddressList 

func ValidateCreateAddressList(ctx context.Context, req *pb.CreateAddressListRequest) error

**************************************** Validate AddressList ****************************************

func ValidateCreateNotification 

func ValidateCreateNotification(ctx context.Context, req *pb.CreateNotificationRequest) error

**************************************** Validate Notification ****************************************

func ValidateDeleteAddresses 

func ValidateDeleteAddresses(ctx context.Context, req *pb.DeleteAddressesRequest) error

func ValidateDeleteAddressesList 

func ValidateDeleteAddressesList(ctx context.Context, req *pb.DeleteAddressListRequest) error

func ValidateModifyAddress 

func ValidateModifyAddress(ctx context.Context, req *pb.ModifyAddressRequest) error

func ValidateSetServiceConfigParams 

func ValidateSetServiceConfigParams(ctx context.Context, emailServiceConfig *pb.EmailServiceConfig, testEmailRecipient string) error

**************************************** Validate ServiceConfig ****************************************

func VerifyAvailableTimeStr 

func VerifyAvailableTimeStr(ctx context.Context, timeStr string) error

VerifyAvailableTimeStr

func VerifyEmailFmt 

func VerifyEmailFmt(ctx context.Context, emailStr string) error

**************************************** VerifyEmailFmt

func VerifyPortFmt 

func VerifyPortFmt(ctx context.Context, port int32) error

VerifyPortFmt

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) Checker 

func (s *Server) Checker(ctx context.Context, req interface{}) error

func (*Server) CreateAddress 

func (s *Server) CreateAddress(ctx context.Context, req *pb.CreateAddressRequest) (*pb.CreateAddressResponse, error)

**************************************** Address ****************************************

func (*Server) CreateAddressList 

func (s *Server) CreateAddressList(ctx context.Context, req *pb.CreateAddressListRequest) (*pb.CreateAddressListResponse, error)

**************************************** AddressList ****************************************

func (*Server) CreateNotification 

func (s *Server) CreateNotification(ctx context.Context, req *pb.CreateNotificationRequest) (*pb.CreateNotificationResponse, error)

**************************************** Notification ****************************************

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)

**************************************** ServiceConfig ****************************************

func (*Server) ValidateEmailService 

func (s *Server) ValidateEmailService(ctx context.Context, req *pb.ServiceConfig) (*pb.ValidateEmailServiceResponse, error)

func (*Server) ValidateEmailServiceV2 

func (s *Server) ValidateEmailServiceV2(ctx context.Context, req *pb.ValidateEmailServiceV2Request) (*pb.ValidateEmailServiceResponse, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.