pkg

package
v0.0.0-...-0a1b35b Latest Latest
Warning

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

 Go to latest Published: Feb 2, 2021 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewFileServiceClientCommand 

func NewFileServiceClientCommand(options ...client.Option) *cobra.Command

Types

type BackupAllResult 

type BackupAllResult struct {
	Version     string                `json:"version"`
	BackupFiles []*SingleBackupResult `json:"backup_files"`
}

func BackupAllResultFromProto 

func BackupAllResultFromProto(in *dbrpc.BackupAllResult) *BackupAllResult

func (*BackupAllResult) ToProto 

func (bar *BackupAllResult) ToProto() *dbrpc.BackupAllResult

type BusService 

type BusService interface {
	Broadcast(context.Context, *EventRequest) (*EventResponse, error)
}

type BusServiceClient 

type BusServiceClient interface {
	Broadcast(ctx context.Context, in *EventRequest, opts ...grpc.CallOption) (*EventResponse, error)
}

type DbAdminService 

type DbAdminService interface {
	Backup(context.Context, *emptypb.Empty) (*BackupAllResult, error)
	ListBackup(context.Context, *ListBackupRequest) (*ListBackupResult, error)
	Restore(context.Context, *RestoreAllRequest) (*RestoreAllResult, error)
}

type DbAdminServiceClient 

type DbAdminServiceClient interface {
	Backup(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*BackupAllResult, error)
	ListBackup(ctx context.Context, in *dbrpc.ListBackupRequest, opts ...grpc.CallOption) (*ListBackupResult, error)
	Restore(ctx context.Context, in *RestoreAllRequest, opts ...grpc.CallOption) (*RestoreAllResult, error)
}

type EmailRequest 

type EmailRequest struct {
	Sender      string            `json:"sender,omitempty"`
	SenderName  string            `json:"sender_name,omitempty"`
	Subject     string            `json:"subject,omitempty"`
	Recipients  map[string]string `json:"recipients,omitempty"`
	Content     []byte            `json:"content,omitempty"`
	Cc          []string          `json:"cc,omitempty"`
	Bcc         []string          `json:"bcc,omitempty"`
	Attachments [][]byte          `json:"attachments,omitempty"`
}

func EmailRequestFromProto 

func EmailRequestFromProto(in *dbrpc.EmailRequest) *EmailRequest

func (*EmailRequest) ToProto 

func (e *EmailRequest) ToProto() *dbrpc.EmailRequest

type EmailResponse 

type EmailResponse struct {
	Success        bool   `json:"success,omitempty"`
	ErrMessage     string `json:"err_message,omitempty"`
	SuccessMessage string `json:"success_message,omitempty"`
}

func EmailResponseFromProto 

func EmailResponseFromProto(e *dbrpc.EmailResponse) *EmailResponse

func (*EmailResponse) ToProto 

func (e *EmailResponse) ToProto() *dbrpc.EmailResponse

type EmailService 

type EmailService interface {
	SendMail(context.Context, *EmailRequest) (*EmailResponse, error)
}

SERVICES

type EmailServiceClient 

type EmailServiceClient interface {
	SendMail(ctx context.Context, in *EmailRequest, opts ...grpc.CallOption) (*EmailResponse, error)
}

CLIENT SIDE (LIBRARY)

type EventRequest 

type EventRequest struct {
	EventName   string `json:"event_name,omitempty"`
	Initiator   string `json:"initiator,omitempty"`
	UserId      string `json:"user_id,omitempty"`
	JsonPayload []byte `json:"json_payload,omitempty"`
}

func EventRequestFromProto 

func EventRequestFromProto(in *dbrpc.EventRequest) *EventRequest

func (*EventRequest) ToProto 

func (e *EventRequest) ToProto() *dbrpc.EventRequest

type EventResponse 

type EventResponse struct {
	Reply []byte `json:"reply"`
}

func EventResponseFromProto 

func EventResponseFromProto(in *dbrpc.EventResponse) *EventResponse

func (*EventResponse) ToProto 

func (e *EventResponse) ToProto() *dbrpc.EventResponse

type FileClient 

type FileClient struct {
	// contains filtered or unexported fields
}

func NewFileServiceClient 

func NewFileServiceClient(cc grpc.ClientConnInterface) *FileClient

func (*FileClient) DownloadFile 

func (fc *FileClient) DownloadFile(id string) ([]byte, error)

client library

func (*FileClient) UploadFile 

func (fc *FileClient) UploadFile(filepath string, r io.ReadCloser, fileInfo *dbrpc.FileInfo) ([]byte, error)

UploadFile client library

type FileDownloadRequest 

type FileDownloadRequest struct {
	Id string `json:"id"`
}

func FileDownloadRequestFromProto 

func FileDownloadRequestFromProto(in *dbrpc.FileDownloadRequest) *FileDownloadRequest

func (*FileDownloadRequest) ToProto 

func (f *FileDownloadRequest) ToProto() *dbrpc.FileDownloadRequest

type FileDownloadResponse 

type FileDownloadResponse struct {
	Chunk    []byte `json:"chunk,omitempty"`
	Success  bool   `json:"success,omitempty"`
	ErrorMsg string `json:"errorMsg,omitempty"`
}

func (*FileDownloadResponse) ToProto 

func (f *FileDownloadResponse) ToProto() *dbrpc.FileDownloadResponse

type FileInfo 

type FileInfo struct {
	MimeType   string `json:"mime_type,omitempty"`
	IsDir      bool   `json:"is_dir,omitempty"`
	ResourceId string `json:"resource_id,omitempty"`
}

func FileInfoFromProto 

func FileInfoFromProto(in *dbrpc.FileInfo) *FileInfo

func (*FileInfo) ToProto 

func (f *FileInfo) ToProto() *dbrpc.FileInfo

type FileUploadRequest 

type FileUploadRequest struct {
	FileInfo FileInfo `json:"file_info,omitempty"`
	Chunk    []byte   `json:"chunk"`
}

func FileUploadRequestFromProto 

func FileUploadRequestFromProto(in *dbrpc.FileUploadRequest) *FileUploadRequest

func (*FileUploadRequest) ToProto 

func (f *FileUploadRequest) ToProto() *dbrpc.FileUploadRequest

type FileUploadResponse 

type FileUploadResponse struct {
	Success  bool   `json:"success,omitempty"`
	Id       string `json:"id,omitempty"`
	ErrorMsg string `json:"error_msg,omitempty"`
}

func FileUploadResponseFromProto 

func FileUploadResponseFromProto(in *dbrpc.FileUploadResponse) *FileUploadResponse

func (*FileUploadResponse) ToProto 

func (f *FileUploadResponse) ToProto() *dbrpc.FileUploadResponse

type ListBackupRequest 

type ListBackupRequest struct {
	BackupVersion string `json:"backup_version"`
}

func ListBackupRequestFromProto 

func ListBackupRequestFromProto(in *dbrpc.ListBackupRequest) *ListBackupRequest

func (*ListBackupRequest) ToProto 

func (l *ListBackupRequest) ToProto() *dbrpc.ListBackupRequest

type ListBackupResult 

type ListBackupResult struct {
	BackupVersions []*BackupAllResult `json:"backup_versions"`
}

func ListBackupFromProto 

func ListBackupFromProto(in *dbrpc.ListBackupResult) *ListBackupResult

func (*ListBackupResult) ToProto 

func (l *ListBackupResult) ToProto() *dbrpc.ListBackupResult

type RestoreAllRequest 

type RestoreAllRequest struct {
	RestoreVersion string            `json:"restore_version"`
	BackupFiles    map[string]string `json:"backup_files"`
}

func RestoreAllRequestFromProto 

func RestoreAllRequestFromProto(in *dbrpc.RestoreAllRequest) *RestoreAllRequest

func (*RestoreAllRequest) ToProto 

func (r *RestoreAllRequest) ToProto() *dbrpc.RestoreAllRequest

type RestoreAllResult 

type RestoreAllResult struct {
	RestoreResults []*SingleRestoreResult `json:"restore_results"`
}

func RestoreAllResultFromProto 

func RestoreAllResultFromProto(in *dbrpc.RestoreAllResult) *RestoreAllResult

func (*RestoreAllResult) ToProto 

func (r *RestoreAllResult) ToProto() *dbrpc.RestoreAllResult

type SingleBackupResult 

type SingleBackupResult struct {
	BackupFile string `json:"backup_file"`
}

func SingleBackupResultFromProto 

func SingleBackupResultFromProto(in *dbrpc.SingleBackupResult) *SingleBackupResult

func (*SingleBackupResult) ToProto 

func (br *SingleBackupResult) ToProto() *dbrpc.SingleBackupResult

type SingleRestoreRequest 

type SingleRestoreRequest struct {
	BackupFile string `json:"backup_file"`
}

func SingleRestoreRequestFromProto 

func SingleRestoreRequestFromProto(in *dbrpc.SingleRestoreRequest) *SingleRestoreRequest

func (*SingleRestoreRequest) ToProto 

func (r *SingleRestoreRequest) ToProto() *dbrpc.SingleRestoreRequest

type SingleRestoreResult 

type SingleRestoreResult struct {
	Result string `json:"result"`
}

func SingleRestoreResultFromProto 

func SingleRestoreResultFromProto(drr *dbrpc.SingleRestoreResult) *SingleRestoreResult

func (*SingleRestoreResult) ToProto 

func (rr *SingleRestoreResult) ToProto() *dbrpc.SingleRestoreResult

type SysBusProxyClient 

type SysBusProxyClient struct {
	SysBusClient *busClient
}

func NewSysBusProxyClient 

func NewSysBusProxyClient(options ...cliClient.Option) *SysBusProxyClient

func (*SysBusProxyClient) CobraCommand 

func (sb *SysBusProxyClient) CobraCommand() *cobra.Command

type SysBusProxyService 

type SysBusProxyService struct {
	SysBus *busProxyService
}

func NewSysBusProxyService 

func NewSysBusProxyService(bs BusService) *SysBusProxyService

func (*SysBusProxyService) RegisterSvc 

func (s *SysBusProxyService) RegisterSvc(server *grpc.Server)

type SysBusProxyServiceClient 

type SysBusProxyServiceClient struct {
	// contains filtered or unexported fields
}

func NewSysBusProxyServiceClient 

func NewSysBusProxyServiceClient(cc grpc.ClientConnInterface) *SysBusProxyServiceClient

func (SysBusProxyServiceClient) Broadcast 

func (b SysBusProxyServiceClient) Broadcast(ctx context.Context, in *EventRequest, opts ...grpc.CallOption) (*EventResponse, error)

type SysCoreProxyClient 

type SysCoreProxyClient struct {
	SysCoreClient *sysCoreClient
}

CLI

func NewSysCoreProxyClient 

func NewSysCoreProxyClient(options ...cliClient.Option) *SysCoreProxyClient

func (*SysCoreProxyClient) CobraCommand 

func (s *SysCoreProxyClient) CobraCommand() *cobra.Command

type SysCoreProxyService 

type SysCoreProxyService struct {
	SysCore *sysCoreService
}

func NewSysCoreProxyService 

func NewSysCoreProxyService(ds DbAdminService) *SysCoreProxyService

func (*SysCoreProxyService) RegisterSvc 

func (s *SysCoreProxyService) RegisterSvc(server *grpc.Server)

type SysCoreProxyServiceClient 

type SysCoreProxyServiceClient struct {
	// contains filtered or unexported fields
}

func NewSysCoreProxyServiceClient 

func NewSysCoreProxyServiceClient(cc grpc.ClientConnInterface) *SysCoreProxyServiceClient

func (SysCoreProxyServiceClient) Backup 

func (s SysCoreProxyServiceClient) Backup(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*BackupAllResult, error)

func (SysCoreProxyServiceClient) ListBackup 

func (s SysCoreProxyServiceClient) ListBackup(ctx context.Context, in *ListBackupRequest, opts ...grpc.CallOption) (*ListBackupResult, error)

func (SysCoreProxyServiceClient) Restore 

func (s SysCoreProxyServiceClient) Restore(ctx context.Context, in *RestoreAllRequest, opts ...grpc.CallOption) (*RestoreAllResult, error)

type SysEmailProxyService 

type SysEmailProxyService struct {
	SysMail *mailProxyService
}

Server side

func NewSysMailProxyService 

func NewSysMailProxyService(e EmailService) *SysEmailProxyService

func (*SysEmailProxyService) RegisterSvc 

func (s *SysEmailProxyService) RegisterSvc(server *grpc.Server)

type SysMailProxyClient 

type SysMailProxyClient struct {
	SysMailProxyClient *mailClient
}

func NewSysMailProxyClient 

func NewSysMailProxyClient(options ...cliClient.Option) *SysMailProxyClient

func (*SysMailProxyClient) CobraCommand 

func (sm *SysMailProxyClient) CobraCommand() *cobra.Command

type SysMailProxyServiceClient 

type SysMailProxyServiceClient struct {
	// contains filtered or unexported fields
}

Client side

func NewSysMailProxyServiceClient 

func NewSysMailProxyServiceClient(cc grpc.ClientConnInterface) *SysMailProxyServiceClient

func (SysMailProxyServiceClient) SendMail 

func (e SysMailProxyServiceClient) SendMail(ctx context.Context, in *EmailRequest, opts ...grpc.CallOption) (*EmailResponse, 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.