v2

package
v0.0.0-...-acf58c8 Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2021 License: Apache-2.0 Imports: 16 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TimeSegment_name = map[int32]string{
		0: "INVALID",
		1: "HOUR",
		2: "DAY",
	}
	TimeSegment_value = map[string]int32{
		"INVALID": 0,
		"HOUR":    1,
		"DAY":     2,
	}
)

Enum value maps for TimeSegment.

View Source 
var AnalyticsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v2.sys_core.services.AnalyticsService",
	HandlerType: (*AnalyticsServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SendAnalyticsEvent",
			Handler:    _AnalyticsService_SendAnalyticsEvent_Handler,
		},
		{
			MethodName: "DownloadAnalytics",
			Handler:    _AnalyticsService_DownloadAnalytics_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "sys_core_services.proto",
}

AnalyticsService_ServiceDesc is the grpc.ServiceDesc for AnalyticsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var BusService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v2.sys_core.services.BusService",
	HandlerType: (*BusServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Broadcast",
			Handler:    _BusService_Broadcast_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "sys_core_services.proto",
}

BusService_ServiceDesc is the grpc.ServiceDesc for BusService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DbAdminService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v2.sys_core.services.DbAdminService",
	HandlerType: (*DbAdminServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Backup",
			Handler:    _DbAdminService_Backup_Handler,
		},
		{
			MethodName: "ListBackup",
			Handler:    _DbAdminService_ListBackup_Handler,
		},
		{
			MethodName: "Restore",
			Handler:    _DbAdminService_Restore_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "sys_core_services.proto",
}

DbAdminService_ServiceDesc is the grpc.ServiceDesc for DbAdminService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var EmailService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v2.sys_core.services.EmailService",
	HandlerType: (*EmailServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SendMail",
			Handler:    _EmailService_SendMail_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "sys_core_services.proto",
}

EmailService_ServiceDesc is the grpc.ServiceDesc for EmailService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var FileService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v2.sys_core.services.FileService",
	HandlerType: (*FileServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Upload",
			Handler:       _FileService_Upload_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "Download",
			Handler:       _FileService_Download_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "sys_core_file_services.proto",
}

FileService_ServiceDesc is the grpc.ServiceDesc for FileService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_sys_core_models_proto protoreflect.FileDescriptor

Functions

func AnalyticsServiceClientCommand 

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

func BusServiceClientCommand 

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

func DbAdminServiceClientCommand 

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

func EmailServiceClientCommand 

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

func RegisterAnalyticsServiceServer 

func RegisterAnalyticsServiceServer(s grpc.ServiceRegistrar, srv AnalyticsServiceServer)

func RegisterBusServiceServer 

func RegisterBusServiceServer(s grpc.ServiceRegistrar, srv BusServiceServer)

func RegisterDbAdminServiceServer 

func RegisterDbAdminServiceServer(s grpc.ServiceRegistrar, srv DbAdminServiceServer)

func RegisterEmailServiceServer 

func RegisterEmailServiceServer(s grpc.ServiceRegistrar, srv EmailServiceServer)

func RegisterFileServiceServer 

func RegisterFileServiceServer(s grpc.ServiceRegistrar, srv FileServiceServer)

Types

type AggMeta 

type AggMeta struct {
	TimeSegment   TimeSegment            `` /* 133-byte string literal not displayed */
	DatetimeStart *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=datetime_start,json=datetimeStart,proto3" json:"datetime_start,omitempty"`
	DatetimeEnd   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=datetime_end,json=datetimeEnd,proto3" json:"datetime_end,omitempty"`
	// contains filtered or unexported fields
}

func (*AggMeta) Descriptor deprecated 

func (*AggMeta) Descriptor() ([]byte, []int)

Deprecated: Use AggMeta.ProtoReflect.Descriptor instead.

func (*AggMeta) GetDatetimeEnd 

func (x *AggMeta) GetDatetimeEnd() *timestamppb.Timestamp

func (*AggMeta) GetDatetimeStart 

func (x *AggMeta) GetDatetimeStart() *timestamppb.Timestamp

func (*AggMeta) GetTimeSegment 

func (x *AggMeta) GetTimeSegment() TimeSegment

func (*AggMeta) ProtoMessage 

func (*AggMeta) ProtoMessage()

func (*AggMeta) ProtoReflect 

func (x *AggMeta) ProtoReflect() protoreflect.Message

func (*AggMeta) Reset 

func (x *AggMeta) Reset()

func (*AggMeta) String 

func (x *AggMeta) String() string

type AggModEvent 

type AggModEvent struct {
	Id         string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	AggMeta    *AggMeta `protobuf:"bytes,2,opt,name=agg_meta,json=aggMeta,proto3" json:"agg_meta,omitempty"`
	EventMetas []*Meta  `protobuf:"bytes,3,rep,name=event_metas,json=eventMetas,proto3" json:"event_metas,omitempty"` // aggregation of metadata from the events it collects
	EventType  string   `protobuf:"bytes,4,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	Payload    []byte   `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"` // merged json or string
	Count      int64    `protobuf:"varint,6,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*AggModEvent) Descriptor deprecated 

func (*AggModEvent) Descriptor() ([]byte, []int)

Deprecated: Use AggModEvent.ProtoReflect.Descriptor instead.

func (*AggModEvent) GetAggMeta 

func (x *AggModEvent) GetAggMeta() *AggMeta

func (*AggModEvent) GetCount 

func (x *AggModEvent) GetCount() int64

func (*AggModEvent) GetEventMetas 

func (x *AggModEvent) GetEventMetas() []*Meta

func (*AggModEvent) GetEventType 

func (x *AggModEvent) GetEventType() string

func (*AggModEvent) GetId 

func (x *AggModEvent) GetId() string

func (*AggModEvent) GetPayload 

func (x *AggModEvent) GetPayload() []byte

func (*AggModEvent) ProtoMessage 

func (*AggModEvent) ProtoMessage()

func (*AggModEvent) ProtoReflect 

func (x *AggModEvent) ProtoReflect() protoreflect.Message

func (*AggModEvent) Reset 

func (x *AggModEvent) Reset()

func (*AggModEvent) String 

func (x *AggModEvent) String() string

type AnalyticsServiceClient 

type AnalyticsServiceClient interface {
	SendAnalyticsEvent(ctx context.Context, in *ModEvent, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DownloadAnalytics(ctx context.Context, in *DownloadAnalyticsRequest, opts ...grpc.CallOption) (*DownloadAnalyticsResponse, error)
}

AnalyticsServiceClient is the client API for AnalyticsService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAnalyticsServiceClient 

func NewAnalyticsServiceClient(cc grpc.ClientConnInterface) AnalyticsServiceClient

type AnalyticsServiceServer 

type AnalyticsServiceServer interface {
	SendAnalyticsEvent(context.Context, *ModEvent) (*emptypb.Empty, error)
	DownloadAnalytics(context.Context, *DownloadAnalyticsRequest) (*DownloadAnalyticsResponse, error)
	// contains filtered or unexported methods
}

AnalyticsServiceServer is the server API for AnalyticsService service. All implementations must embed UnimplementedAnalyticsServiceServer for forward compatibility

type BackupAllResult 

type BackupAllResult struct {
	Version     string                `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	BackupFiles []*SingleBackupResult `protobuf:"bytes,2,rep,name=backup_files,json=backupFiles,proto3" json:"backup_files,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupAllResult) Descriptor deprecated 

func (*BackupAllResult) Descriptor() ([]byte, []int)

Deprecated: Use BackupAllResult.ProtoReflect.Descriptor instead.

func (*BackupAllResult) GetBackupFiles 

func (x *BackupAllResult) GetBackupFiles() []*SingleBackupResult

func (*BackupAllResult) GetVersion 

func (x *BackupAllResult) GetVersion() string

func (*BackupAllResult) ProtoMessage 

func (*BackupAllResult) ProtoMessage()

func (*BackupAllResult) ProtoReflect 

func (x *BackupAllResult) ProtoReflect() protoreflect.Message

func (*BackupAllResult) Reset 

func (x *BackupAllResult) Reset()

func (*BackupAllResult) String 

func (x *BackupAllResult) String() string

type BusServiceClient 

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

BusServiceClient is the client API for BusService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewBusServiceClient 

func NewBusServiceClient(cc grpc.ClientConnInterface) BusServiceClient

type BusServiceServer 

type BusServiceServer interface {
	Broadcast(context.Context, *EventRequest) (*EventResponse, error)
	// contains filtered or unexported methods
}

BusServiceServer is the server API for BusService service. All implementations must embed UnimplementedBusServiceServer for forward compatibility

type DbAdminServiceClient 

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

DbAdminServiceClient is the client API for DbAdminService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDbAdminServiceClient 

func NewDbAdminServiceClient(cc grpc.ClientConnInterface) DbAdminServiceClient

type DbAdminServiceServer 

type DbAdminServiceServer interface {
	Backup(context.Context, *emptypb.Empty) (*BackupAllResult, error)
	ListBackup(context.Context, *ListBackupRequest) (*ListBackupResult, error)
	Restore(context.Context, *RestoreAllRequest) (*RestoreAllResult, error)
	// contains filtered or unexported methods
}

DbAdminServiceServer is the server API for DbAdminService service. All implementations must embed UnimplementedDbAdminServiceServer for forward compatibility

type DownloadAnalyticsRequest 

type DownloadAnalyticsRequest struct {
	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Filter        []byte                 `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	DatetimeStart *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=datetime_start,json=datetimeStart,proto3" json:"datetime_start,omitempty"`
	DatetimeEnd   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=datetime_end,json=datetimeEnd,proto3" json:"datetime_end,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadAnalyticsRequest) Descriptor deprecated 

func (*DownloadAnalyticsRequest) Descriptor() ([]byte, []int)

Deprecated: Use DownloadAnalyticsRequest.ProtoReflect.Descriptor instead.

func (*DownloadAnalyticsRequest) GetDatetimeEnd 

func (x *DownloadAnalyticsRequest) GetDatetimeEnd() *timestamppb.Timestamp

func (*DownloadAnalyticsRequest) GetDatetimeStart 

func (x *DownloadAnalyticsRequest) GetDatetimeStart() *timestamppb.Timestamp

func (*DownloadAnalyticsRequest) GetFilter 

func (x *DownloadAnalyticsRequest) GetFilter() []byte

func (*DownloadAnalyticsRequest) GetId 

func (x *DownloadAnalyticsRequest) GetId() string

func (*DownloadAnalyticsRequest) ProtoMessage 

func (*DownloadAnalyticsRequest) ProtoMessage()

func (*DownloadAnalyticsRequest) ProtoReflect 

func (x *DownloadAnalyticsRequest) ProtoReflect() protoreflect.Message

func (*DownloadAnalyticsRequest) Reset 

func (x *DownloadAnalyticsRequest) Reset()

func (*DownloadAnalyticsRequest) String 

func (x *DownloadAnalyticsRequest) String() string

type DownloadAnalyticsResponse 

type DownloadAnalyticsResponse struct {
	AnalyticsBytes []byte `protobuf:"bytes,1,opt,name=analytics_bytes,json=analyticsBytes,proto3" json:"analytics_bytes,omitempty"` // when you want the raw data (json / msgpack / proto)
	AnalyticsUrl   string `protobuf:"bytes,2,opt,name=analytics_url,json=analyticsUrl,proto3" json:"analytics_url,omitempty"`       // when you want the url uploaded to sheets as json / csv
	AnalyticsFile  string `protobuf:"bytes,3,opt,name=analytics_file,json=analyticsFile,proto3" json:"analytics_file,omitempty"`    // when you want the file in json / csv format for example
	// contains filtered or unexported fields
}

func (*DownloadAnalyticsResponse) Descriptor deprecated 

func (*DownloadAnalyticsResponse) Descriptor() ([]byte, []int)

Deprecated: Use DownloadAnalyticsResponse.ProtoReflect.Descriptor instead.

func (*DownloadAnalyticsResponse) GetAnalyticsBytes 

func (x *DownloadAnalyticsResponse) GetAnalyticsBytes() []byte

func (*DownloadAnalyticsResponse) GetAnalyticsFile 

func (x *DownloadAnalyticsResponse) GetAnalyticsFile() string

func (*DownloadAnalyticsResponse) GetAnalyticsUrl 

func (x *DownloadAnalyticsResponse) GetAnalyticsUrl() string

func (*DownloadAnalyticsResponse) ProtoMessage 

func (*DownloadAnalyticsResponse) ProtoMessage()

func (*DownloadAnalyticsResponse) ProtoReflect 

func (x *DownloadAnalyticsResponse) ProtoReflect() protoreflect.Message

func (*DownloadAnalyticsResponse) Reset 

func (x *DownloadAnalyticsResponse) Reset()

func (*DownloadAnalyticsResponse) String 

func (x *DownloadAnalyticsResponse) String() string

type EmailRequest 

type EmailRequest struct {
	Sender      string            `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	Subject     string            `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"`
	Recipients  map[string]string `` /* 161-byte string literal not displayed */
	Content     []byte            `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	Cc          []string          `protobuf:"bytes,5,rep,name=cc,proto3" json:"cc,omitempty"`
	Bcc         []string          `protobuf:"bytes,6,rep,name=bcc,proto3" json:"bcc,omitempty"`
	Attachments [][]byte          `protobuf:"bytes,7,rep,name=attachments,proto3" json:"attachments,omitempty"`
	SenderName  string            `protobuf:"bytes,8,opt,name=sender_name,json=senderName,proto3" json:"sender_name,omitempty"`
	// contains filtered or unexported fields
}

func (*EmailRequest) Descriptor deprecated 

func (*EmailRequest) Descriptor() ([]byte, []int)

Deprecated: Use EmailRequest.ProtoReflect.Descriptor instead.

func (*EmailRequest) GetAttachments 

func (x *EmailRequest) GetAttachments() [][]byte

func (*EmailRequest) GetBcc 

func (x *EmailRequest) GetBcc() []string

func (*EmailRequest) GetCc 

func (x *EmailRequest) GetCc() []string

func (*EmailRequest) GetContent 

func (x *EmailRequest) GetContent() []byte

func (*EmailRequest) GetRecipients 

func (x *EmailRequest) GetRecipients() map[string]string

func (*EmailRequest) GetSender 

func (x *EmailRequest) GetSender() string

func (*EmailRequest) GetSenderName 

func (x *EmailRequest) GetSenderName() string

func (*EmailRequest) GetSubject 

func (x *EmailRequest) GetSubject() string

func (*EmailRequest) ProtoMessage 

func (*EmailRequest) ProtoMessage()

func (*EmailRequest) ProtoReflect 

func (x *EmailRequest) ProtoReflect() protoreflect.Message

func (*EmailRequest) Reset 

func (x *EmailRequest) Reset()

func (*EmailRequest) String 

func (x *EmailRequest) String() string

type EmailResponse 

type EmailResponse struct {
	Success        bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrMessage     string `protobuf:"bytes,2,opt,name=err_message,json=errMessage,proto3" json:"err_message,omitempty"`
	SuccessMessage string `protobuf:"bytes,3,opt,name=success_message,json=successMessage,proto3" json:"success_message,omitempty"`
	// contains filtered or unexported fields
}

func (*EmailResponse) Descriptor deprecated 

func (*EmailResponse) Descriptor() ([]byte, []int)

Deprecated: Use EmailResponse.ProtoReflect.Descriptor instead.

func (*EmailResponse) GetErrMessage 

func (x *EmailResponse) GetErrMessage() string

func (*EmailResponse) GetSuccess 

func (x *EmailResponse) GetSuccess() bool

func (*EmailResponse) GetSuccessMessage 

func (x *EmailResponse) GetSuccessMessage() string

func (*EmailResponse) ProtoMessage 

func (*EmailResponse) ProtoMessage()

func (*EmailResponse) ProtoReflect 

func (x *EmailResponse) ProtoReflect() protoreflect.Message

func (*EmailResponse) Reset 

func (x *EmailResponse) Reset()

func (*EmailResponse) String 

func (x *EmailResponse) String() string

type EmailServiceClient 

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

EmailServiceClient is the client API for EmailService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewEmailServiceClient 

func NewEmailServiceClient(cc grpc.ClientConnInterface) EmailServiceClient

type EmailServiceServer 

type EmailServiceServer interface {
	SendMail(context.Context, *EmailRequest) (*EmailResponse, error)
	// contains filtered or unexported methods
}

EmailServiceServer is the server API for EmailService service. All implementations must embed UnimplementedEmailServiceServer for forward compatibility

type EventRequest 

type EventRequest struct {
	EventName   string `protobuf:"bytes,1,opt,name=eventName,proto3" json:"eventName,omitempty"`
	Initiator   string `protobuf:"bytes,2,opt,name=initiator,proto3" json:"initiator,omitempty"`
	UserId      string `protobuf:"bytes,3,opt,name=userId,proto3" json:"userId,omitempty"`
	JsonPayload []byte `protobuf:"bytes,4,opt,name=jsonPayload,proto3" json:"jsonPayload,omitempty"`
	// contains filtered or unexported fields
}

This will be replaced by NATS in the future

func (*EventRequest) Descriptor deprecated 

func (*EventRequest) Descriptor() ([]byte, []int)

Deprecated: Use EventRequest.ProtoReflect.Descriptor instead.

func (*EventRequest) GetEventName 

func (x *EventRequest) GetEventName() string

func (*EventRequest) GetInitiator 

func (x *EventRequest) GetInitiator() string

func (*EventRequest) GetJsonPayload 

func (x *EventRequest) GetJsonPayload() []byte

func (*EventRequest) GetUserId 

func (x *EventRequest) GetUserId() string

func (*EventRequest) ProtoMessage 

func (*EventRequest) ProtoMessage()

func (*EventRequest) ProtoReflect 

func (x *EventRequest) ProtoReflect() protoreflect.Message

func (*EventRequest) Reset 

func (x *EventRequest) Reset()

func (*EventRequest) String 

func (x *EventRequest) String() string

type EventResponse 

type EventResponse struct {

	// will return a json / msgpack encoded as string
	Reply []byte `protobuf:"bytes,1,opt,name=reply,proto3" json:"reply,omitempty"`
	// contains filtered or unexported fields
}

func (*EventResponse) Descriptor deprecated 

func (*EventResponse) Descriptor() ([]byte, []int)

Deprecated: Use EventResponse.ProtoReflect.Descriptor instead.

func (*EventResponse) GetReply 

func (x *EventResponse) GetReply() []byte

func (*EventResponse) ProtoMessage 

func (*EventResponse) ProtoMessage()

func (*EventResponse) ProtoReflect 

func (x *EventResponse) ProtoReflect() protoreflect.Message

func (*EventResponse) Reset 

func (x *EventResponse) Reset()

func (*EventResponse) String 

func (x *EventResponse) String() string

type FileDownloadRequest 

type FileDownloadRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*FileDownloadRequest) Descriptor deprecated 

func (*FileDownloadRequest) Descriptor() ([]byte, []int)

Deprecated: Use FileDownloadRequest.ProtoReflect.Descriptor instead.

func (*FileDownloadRequest) GetId 

func (x *FileDownloadRequest) GetId() string

func (*FileDownloadRequest) ProtoMessage 

func (*FileDownloadRequest) ProtoMessage()

func (*FileDownloadRequest) ProtoReflect 

func (x *FileDownloadRequest) ProtoReflect() protoreflect.Message

func (*FileDownloadRequest) Reset 

func (x *FileDownloadRequest) Reset()

func (*FileDownloadRequest) String 

func (x *FileDownloadRequest) String() string

type FileDownloadResponse 

type FileDownloadResponse struct {
	Chunk        []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
	Success      bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMsg     string `protobuf:"bytes,3,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	TotalSize    int64  `protobuf:"varint,4,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	IsCompressed bool   `protobuf:"varint,5,opt,name=is_compressed,json=isCompressed,proto3" json:"is_compressed,omitempty"`
	// contains filtered or unexported fields
}

func (*FileDownloadResponse) Descriptor deprecated 

func (*FileDownloadResponse) Descriptor() ([]byte, []int)

Deprecated: Use FileDownloadResponse.ProtoReflect.Descriptor instead.

func (*FileDownloadResponse) GetChunk 

func (x *FileDownloadResponse) GetChunk() []byte

func (*FileDownloadResponse) GetErrorMsg 

func (x *FileDownloadResponse) GetErrorMsg() string

func (*FileDownloadResponse) GetIsCompressed 

func (x *FileDownloadResponse) GetIsCompressed() bool

func (*FileDownloadResponse) GetSuccess 

func (x *FileDownloadResponse) GetSuccess() bool

func (*FileDownloadResponse) GetTotalSize 

func (x *FileDownloadResponse) GetTotalSize() int64

func (*FileDownloadResponse) ProtoMessage 

func (*FileDownloadResponse) ProtoMessage()

func (*FileDownloadResponse) ProtoReflect 

func (x *FileDownloadResponse) ProtoReflect() protoreflect.Message

func (*FileDownloadResponse) Reset 

func (x *FileDownloadResponse) Reset()

func (*FileDownloadResponse) String 

func (x *FileDownloadResponse) String() string

type FileInfo 

type FileInfo struct {
	MimeType   string `protobuf:"bytes,1,opt,name=mime_type,json=mimeType,proto3" json:"mime_type,omitempty"`
	IsDir      bool   `protobuf:"varint,2,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"`
	ResourceId string `protobuf:"bytes,3,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// contains filtered or unexported fields
}

func (*FileInfo) Descriptor deprecated 

func (*FileInfo) Descriptor() ([]byte, []int)

Deprecated: Use FileInfo.ProtoReflect.Descriptor instead.

func (*FileInfo) GetIsDir 

func (x *FileInfo) GetIsDir() bool

func (*FileInfo) GetMimeType 

func (x *FileInfo) GetMimeType() string

func (*FileInfo) GetResourceId 

func (x *FileInfo) GetResourceId() string

func (*FileInfo) ProtoMessage 

func (*FileInfo) ProtoMessage()

func (*FileInfo) ProtoReflect 

func (x *FileInfo) ProtoReflect() protoreflect.Message

func (*FileInfo) Reset 

func (x *FileInfo) Reset()

func (*FileInfo) String 

func (x *FileInfo) String() string

type FileServiceClient 

type FileServiceClient interface {
	Upload(ctx context.Context, opts ...grpc.CallOption) (FileService_UploadClient, error)
	Download(ctx context.Context, in *FileDownloadRequest, opts ...grpc.CallOption) (FileService_DownloadClient, error)
}

FileServiceClient is the client API for FileService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewFileServiceClient 

func NewFileServiceClient(cc grpc.ClientConnInterface) FileServiceClient

type FileServiceServer 

type FileServiceServer interface {
	Upload(FileService_UploadServer) error
	Download(*FileDownloadRequest, FileService_DownloadServer) error
	// contains filtered or unexported methods
}

FileServiceServer is the server API for FileService service. All implementations must embed UnimplementedFileServiceServer for forward compatibility

type FileService_DownloadClient 

type FileService_DownloadClient interface {
	Recv() (*FileDownloadResponse, error)
	grpc.ClientStream
}

type FileService_DownloadServer 

type FileService_DownloadServer interface {
	Send(*FileDownloadResponse) error
	grpc.ServerStream
}

type FileService_UploadClient 

type FileService_UploadClient interface {
	Send(*FileUploadRequest) error
	CloseAndRecv() (*FileUploadResponse, error)
	grpc.ClientStream
}

type FileService_UploadServer 

type FileService_UploadServer interface {
	SendAndClose(*FileUploadResponse) error
	Recv() (*FileUploadRequest, error)
	grpc.ServerStream
}

type FileUploadRequest 

type FileUploadRequest struct {
	FileInfo *FileInfo `protobuf:"bytes,1,opt,name=file_info,json=fileInfo,proto3" json:"file_info,omitempty"`
	Chunk    []byte    `protobuf:"bytes,2,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

func (*FileUploadRequest) Descriptor deprecated 

func (*FileUploadRequest) Descriptor() ([]byte, []int)

Deprecated: Use FileUploadRequest.ProtoReflect.Descriptor instead.

func (*FileUploadRequest) GetChunk 

func (x *FileUploadRequest) GetChunk() []byte

func (*FileUploadRequest) GetFileInfo 

func (x *FileUploadRequest) GetFileInfo() *FileInfo

func (*FileUploadRequest) ProtoMessage 

func (*FileUploadRequest) ProtoMessage()

func (*FileUploadRequest) ProtoReflect 

func (x *FileUploadRequest) ProtoReflect() protoreflect.Message

func (*FileUploadRequest) Reset 

func (x *FileUploadRequest) Reset()

func (*FileUploadRequest) String 

func (x *FileUploadRequest) String() string

type FileUploadResponse 

type FileUploadResponse struct {
	Success    bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Id         string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	ErrorMsg   string `protobuf:"bytes,3,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	ResourceId string `protobuf:"bytes,4,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// contains filtered or unexported fields
}

func (*FileUploadResponse) Descriptor deprecated 

func (*FileUploadResponse) Descriptor() ([]byte, []int)

Deprecated: Use FileUploadResponse.ProtoReflect.Descriptor instead.

func (*FileUploadResponse) GetErrorMsg 

func (x *FileUploadResponse) GetErrorMsg() string

func (*FileUploadResponse) GetId 

func (x *FileUploadResponse) GetId() string

func (*FileUploadResponse) GetResourceId 

func (x *FileUploadResponse) GetResourceId() string

func (*FileUploadResponse) GetSuccess 

func (x *FileUploadResponse) GetSuccess() bool

func (*FileUploadResponse) ProtoMessage 

func (*FileUploadResponse) ProtoMessage()

func (*FileUploadResponse) ProtoReflect 

func (x *FileUploadResponse) ProtoReflect() protoreflect.Message

func (*FileUploadResponse) Reset 

func (x *FileUploadResponse) Reset()

func (*FileUploadResponse) String 

func (x *FileUploadResponse) String() string

type GeoLoc 

type GeoLoc struct {
	Longitude float32 `protobuf:"fixed32,1,opt,name=longitude,proto3" json:"longitude,omitempty"`
	Latitude  float32 `protobuf:"fixed32,2,opt,name=latitude,proto3" json:"latitude,omitempty"`
	// contains filtered or unexported fields
}

func (*GeoLoc) Descriptor deprecated 

func (*GeoLoc) Descriptor() ([]byte, []int)

Deprecated: Use GeoLoc.ProtoReflect.Descriptor instead.

func (*GeoLoc) GetLatitude 

func (x *GeoLoc) GetLatitude() float32

func (*GeoLoc) GetLongitude 

func (x *GeoLoc) GetLongitude() float32

func (*GeoLoc) ProtoMessage 

func (*GeoLoc) ProtoMessage()

func (*GeoLoc) ProtoReflect 

func (x *GeoLoc) ProtoReflect() protoreflect.Message

func (*GeoLoc) Reset 

func (x *GeoLoc) Reset()

func (*GeoLoc) String 

func (x *GeoLoc) String() string

type ListBackupRequest 

type ListBackupRequest struct {
	BackupVersion string `protobuf:"bytes,1,opt,name=backup_version,json=backupVersion,proto3" json:"backup_version,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBackupRequest) Descriptor deprecated 

func (*ListBackupRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListBackupRequest.ProtoReflect.Descriptor instead.

func (*ListBackupRequest) GetBackupVersion 

func (x *ListBackupRequest) GetBackupVersion() string

func (*ListBackupRequest) ProtoMessage 

func (*ListBackupRequest) ProtoMessage()

func (*ListBackupRequest) ProtoReflect 

func (x *ListBackupRequest) ProtoReflect() protoreflect.Message

func (*ListBackupRequest) Reset 

func (x *ListBackupRequest) Reset()

func (*ListBackupRequest) String 

func (x *ListBackupRequest) String() string

type ListBackupResult 

type ListBackupResult struct {
	BackupVersions []*BackupAllResult `protobuf:"bytes,1,rep,name=backup_versions,json=backupVersions,proto3" json:"backup_versions,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBackupResult) Descriptor deprecated 

func (*ListBackupResult) Descriptor() ([]byte, []int)

Deprecated: Use ListBackupResult.ProtoReflect.Descriptor instead.

func (*ListBackupResult) GetBackupVersions 

func (x *ListBackupResult) GetBackupVersions() []*BackupAllResult

func (*ListBackupResult) ProtoMessage 

func (*ListBackupResult) ProtoMessage()

func (*ListBackupResult) ProtoReflect 

func (x *ListBackupResult) ProtoReflect() protoreflect.Message

func (*ListBackupResult) Reset 

func (x *ListBackupResult) Reset()

func (*ListBackupResult) String 

func (x *ListBackupResult) String() string

type Meta 

type Meta struct {
	Actor       string                 `protobuf:"bytes,1,opt,name=actor,proto3" json:"actor,omitempty"`
	UserId      string                 `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // name or id
	UserName    string                 `protobuf:"bytes,3,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	Datetime    *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=datetime,proto3" json:"datetime,omitempty"`
	Geo         *GeoLoc                `protobuf:"bytes,5,opt,name=geo,proto3" json:"geo,omitempty"`
	OrgId       string                 `protobuf:"bytes,6,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	OrgName     string                 `protobuf:"bytes,7,opt,name=org_name,json=orgName,proto3" json:"org_name,omitempty"`
	ProjectId   string                 `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	ProjectName string                 `protobuf:"bytes,9,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	// contains filtered or unexported fields
}

func (*Meta) Descriptor deprecated 

func (*Meta) Descriptor() ([]byte, []int)

Deprecated: Use Meta.ProtoReflect.Descriptor instead.

func (*Meta) GetActor 

func (x *Meta) GetActor() string

func (*Meta) GetDatetime 

func (x *Meta) GetDatetime() *timestamppb.Timestamp

func (*Meta) GetGeo 

func (x *Meta) GetGeo() *GeoLoc

func (*Meta) GetOrgId 

func (x *Meta) GetOrgId() string

func (*Meta) GetOrgName 

func (x *Meta) GetOrgName() string

func (*Meta) GetProjectId 

func (x *Meta) GetProjectId() string

func (*Meta) GetProjectName 

func (x *Meta) GetProjectName() string

func (*Meta) GetUserId 

func (x *Meta) GetUserId() string

func (*Meta) GetUserName 

func (x *Meta) GetUserName() string

func (*Meta) ProtoMessage 

func (*Meta) ProtoMessage()

func (*Meta) ProtoReflect 

func (x *Meta) ProtoReflect() protoreflect.Message

func (*Meta) Reset 

func (x *Meta) Reset()

func (*Meta) String 

func (x *Meta) String() string

type ModEvent 

type ModEvent struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Meta      *Meta  `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	EventType string `protobuf:"bytes,3,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	Payload   []byte `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	// string / json / proto / msgpack / whichever
	PayloadEncoding string `protobuf:"bytes,5,opt,name=payload_encoding,json=payloadEncoding,proto3" json:"payload_encoding,omitempty"`
	// contains filtered or unexported fields
}

func (*ModEvent) Descriptor deprecated 

func (*ModEvent) Descriptor() ([]byte, []int)

Deprecated: Use ModEvent.ProtoReflect.Descriptor instead.

func (*ModEvent) GetEventType 

func (x *ModEvent) GetEventType() string

func (*ModEvent) GetId 

func (x *ModEvent) GetId() string

func (*ModEvent) GetMeta 

func (x *ModEvent) GetMeta() *Meta

func (*ModEvent) GetPayload 

func (x *ModEvent) GetPayload() []byte

func (*ModEvent) GetPayloadEncoding 

func (x *ModEvent) GetPayloadEncoding() string

func (*ModEvent) ProtoMessage 

func (*ModEvent) ProtoMessage()

func (*ModEvent) ProtoReflect 

func (x *ModEvent) ProtoReflect() protoreflect.Message

func (*ModEvent) Reset 

func (x *ModEvent) Reset()

func (*ModEvent) String 

func (x *ModEvent) String() string

type RestoreAllRequest 

type RestoreAllRequest struct {
	RestoreVersion string            `protobuf:"bytes,1,opt,name=restore_version,json=restoreVersion,proto3" json:"restore_version,omitempty"`
	BackupFiles    map[string]string `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RestoreAllRequest) Descriptor deprecated 

func (*RestoreAllRequest) Descriptor() ([]byte, []int)

Deprecated: Use RestoreAllRequest.ProtoReflect.Descriptor instead.

func (*RestoreAllRequest) GetBackupFiles 

func (x *RestoreAllRequest) GetBackupFiles() map[string]string

func (*RestoreAllRequest) GetRestoreVersion 

func (x *RestoreAllRequest) GetRestoreVersion() string

func (*RestoreAllRequest) ProtoMessage 

func (*RestoreAllRequest) ProtoMessage()

func (*RestoreAllRequest) ProtoReflect 

func (x *RestoreAllRequest) ProtoReflect() protoreflect.Message

func (*RestoreAllRequest) Reset 

func (x *RestoreAllRequest) Reset()

func (*RestoreAllRequest) String 

func (x *RestoreAllRequest) String() string

type RestoreAllResult 

type RestoreAllResult struct {
	RestoreResults []*SingleRestoreResult `protobuf:"bytes,1,rep,name=restore_results,json=restoreResults,proto3" json:"restore_results,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoreAllResult) Descriptor deprecated 

func (*RestoreAllResult) Descriptor() ([]byte, []int)

Deprecated: Use RestoreAllResult.ProtoReflect.Descriptor instead.

func (*RestoreAllResult) GetRestoreResults 

func (x *RestoreAllResult) GetRestoreResults() []*SingleRestoreResult

func (*RestoreAllResult) ProtoMessage 

func (*RestoreAllResult) ProtoMessage()

func (*RestoreAllResult) ProtoReflect 

func (x *RestoreAllResult) ProtoReflect() protoreflect.Message

func (*RestoreAllResult) Reset 

func (x *RestoreAllResult) Reset()

func (*RestoreAllResult) String 

func (x *RestoreAllResult) String() string

type SingleBackupResult 

type SingleBackupResult struct {
	BackupFile string `protobuf:"bytes,1,opt,name=backupFile,proto3" json:"backupFile,omitempty"`
	// contains filtered or unexported fields
}

func (*SingleBackupResult) Descriptor deprecated 

func (*SingleBackupResult) Descriptor() ([]byte, []int)

Deprecated: Use SingleBackupResult.ProtoReflect.Descriptor instead.

func (*SingleBackupResult) GetBackupFile 

func (x *SingleBackupResult) GetBackupFile() string

func (*SingleBackupResult) ProtoMessage 

func (*SingleBackupResult) ProtoMessage()

func (*SingleBackupResult) ProtoReflect 

func (x *SingleBackupResult) ProtoReflect() protoreflect.Message

func (*SingleBackupResult) Reset 

func (x *SingleBackupResult) Reset()

func (*SingleBackupResult) String 

func (x *SingleBackupResult) String() string

type SingleRestoreRequest 

type SingleRestoreRequest struct {
	BackupFile string `protobuf:"bytes,1,opt,name=backupFile,proto3" json:"backupFile,omitempty"`
	// contains filtered or unexported fields
}

func (*SingleRestoreRequest) Descriptor deprecated 

func (*SingleRestoreRequest) Descriptor() ([]byte, []int)

Deprecated: Use SingleRestoreRequest.ProtoReflect.Descriptor instead.

func (*SingleRestoreRequest) GetBackupFile 

func (x *SingleRestoreRequest) GetBackupFile() string

func (*SingleRestoreRequest) ProtoMessage 

func (*SingleRestoreRequest) ProtoMessage()

func (*SingleRestoreRequest) ProtoReflect 

func (x *SingleRestoreRequest) ProtoReflect() protoreflect.Message

func (*SingleRestoreRequest) Reset 

func (x *SingleRestoreRequest) Reset()

func (*SingleRestoreRequest) String 

func (x *SingleRestoreRequest) String() string

type SingleRestoreResult 

type SingleRestoreResult struct {
	Result string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*SingleRestoreResult) Descriptor deprecated 

func (*SingleRestoreResult) Descriptor() ([]byte, []int)

Deprecated: Use SingleRestoreResult.ProtoReflect.Descriptor instead.

func (*SingleRestoreResult) GetResult 

func (x *SingleRestoreResult) GetResult() string

func (*SingleRestoreResult) ProtoMessage 

func (*SingleRestoreResult) ProtoMessage()

func (*SingleRestoreResult) ProtoReflect 

func (x *SingleRestoreResult) ProtoReflect() protoreflect.Message

func (*SingleRestoreResult) Reset 

func (x *SingleRestoreResult) Reset()

func (*SingleRestoreResult) String 

func (x *SingleRestoreResult) String() string

type TimeSegment 

type TimeSegment int32
const (
	TimeSegment_INVALID TimeSegment = 0
	TimeSegment_HOUR    TimeSegment = 1
	TimeSegment_DAY     TimeSegment = 2
)

func (TimeSegment) Descriptor 

func (TimeSegment) Descriptor() protoreflect.EnumDescriptor

func (TimeSegment) Enum 

func (x TimeSegment) Enum() *TimeSegment

func (TimeSegment) EnumDescriptor deprecated 

func (TimeSegment) EnumDescriptor() ([]byte, []int)

Deprecated: Use TimeSegment.Descriptor instead.

func (TimeSegment) Number 

func (x TimeSegment) Number() protoreflect.EnumNumber

func (TimeSegment) String 

func (x TimeSegment) String() string

func (TimeSegment) Type 

func (TimeSegment) Type() protoreflect.EnumType

type UnimplementedAnalyticsServiceServer 

type UnimplementedAnalyticsServiceServer struct {
}

UnimplementedAnalyticsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAnalyticsServiceServer) DownloadAnalytics 

func (UnimplementedAnalyticsServiceServer) DownloadAnalytics(context.Context, *DownloadAnalyticsRequest) (*DownloadAnalyticsResponse, error)

func (UnimplementedAnalyticsServiceServer) SendAnalyticsEvent 

func (UnimplementedAnalyticsServiceServer) SendAnalyticsEvent(context.Context, *ModEvent) (*emptypb.Empty, error)

type UnimplementedBusServiceServer 

type UnimplementedBusServiceServer struct {
}

UnimplementedBusServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBusServiceServer) Broadcast 

func (UnimplementedBusServiceServer) Broadcast(context.Context, *EventRequest) (*EventResponse, error)

type UnimplementedDbAdminServiceServer 

type UnimplementedDbAdminServiceServer struct {
}

UnimplementedDbAdminServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDbAdminServiceServer) Backup 

func (UnimplementedDbAdminServiceServer) Backup(context.Context, *emptypb.Empty) (*BackupAllResult, error)

func (UnimplementedDbAdminServiceServer) ListBackup 

func (UnimplementedDbAdminServiceServer) ListBackup(context.Context, *ListBackupRequest) (*ListBackupResult, error)

func (UnimplementedDbAdminServiceServer) Restore 

func (UnimplementedDbAdminServiceServer) Restore(context.Context, *RestoreAllRequest) (*RestoreAllResult, error)

type UnimplementedEmailServiceServer 

type UnimplementedEmailServiceServer struct {
}

UnimplementedEmailServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEmailServiceServer) SendMail 

func (UnimplementedEmailServiceServer) SendMail(context.Context, *EmailRequest) (*EmailResponse, error)

type UnimplementedFileServiceServer 

type UnimplementedFileServiceServer struct {
}

UnimplementedFileServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFileServiceServer) Download 

func (UnimplementedFileServiceServer) Download(*FileDownloadRequest, FileService_DownloadServer) error

func (UnimplementedFileServiceServer) Upload 

func (UnimplementedFileServiceServer) Upload(FileService_UploadServer) error

type UnsafeAnalyticsServiceServer 

type UnsafeAnalyticsServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeAnalyticsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AnalyticsServiceServer will result in compilation errors.

type UnsafeBusServiceServer 

type UnsafeBusServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeBusServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BusServiceServer will result in compilation errors.

type UnsafeDbAdminServiceServer 

type UnsafeDbAdminServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDbAdminServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DbAdminServiceServer will result in compilation errors.

type UnsafeEmailServiceServer 

type UnsafeEmailServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeEmailServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EmailServiceServer will result in compilation errors.

type UnsafeFileServiceServer 

type UnsafeFileServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeFileServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FileServiceServer will result in compilation errors.

Source Files

View all Source files

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.