proto

package
v0.1.2 Latest Latest
Warning

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

Go to latest
Published: Sep 13, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_notifier_proto_notifier_proto protoreflect.FileDescriptor

Functions

func RegisterNotifierServer

func RegisterNotifierServer(s *grpc.Server, srv NotifierServer)

Types

type FsEvent

type FsEvent struct {
	Timestamp         int64  `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Action            string `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
	Username          string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	FsPath            string `protobuf:"bytes,4,opt,name=fs_path,json=fsPath,proto3" json:"fs_path,omitempty"`
	FsTargetPath      string `protobuf:"bytes,5,opt,name=fs_target_path,json=fsTargetPath,proto3" json:"fs_target_path,omitempty"`
	SshCmd            string `protobuf:"bytes,6,opt,name=ssh_cmd,json=sshCmd,proto3" json:"ssh_cmd,omitempty"`
	FileSize          int64  `protobuf:"varint,7,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
	Protocol          string `protobuf:"bytes,8,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Status            int32  `protobuf:"varint,9,opt,name=status,proto3" json:"status,omitempty"`
	Ip                string `protobuf:"bytes,10,opt,name=ip,proto3" json:"ip,omitempty"`
	VirtualPath       string `protobuf:"bytes,11,opt,name=virtual_path,json=virtualPath,proto3" json:"virtual_path,omitempty"`
	VirtualTargetPath string `protobuf:"bytes,12,opt,name=virtual_target_path,json=virtualTargetPath,proto3" json:"virtual_target_path,omitempty"`
	SessionId         string `protobuf:"bytes,13,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	FsProvider        int32  `protobuf:"varint,14,opt,name=fs_provider,json=fsProvider,proto3" json:"fs_provider,omitempty"`
	Bucket            string `protobuf:"bytes,15,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Endpoint          string `protobuf:"bytes,16,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	OpenFlags         int32  `protobuf:"varint,17,opt,name=open_flags,json=openFlags,proto3" json:"open_flags,omitempty"`
	// contains filtered or unexported fields
}

func (*FsEvent) Descriptor deprecated

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

Deprecated: Use FsEvent.ProtoReflect.Descriptor instead.

func (*FsEvent) GetAction

func (x *FsEvent) GetAction() string

func (*FsEvent) GetBucket

func (x *FsEvent) GetBucket() string

func (*FsEvent) GetEndpoint

func (x *FsEvent) GetEndpoint() string

func (*FsEvent) GetFileSize

func (x *FsEvent) GetFileSize() int64

func (*FsEvent) GetFsPath

func (x *FsEvent) GetFsPath() string

func (*FsEvent) GetFsProvider

func (x *FsEvent) GetFsProvider() int32

func (*FsEvent) GetFsTargetPath

func (x *FsEvent) GetFsTargetPath() string

func (*FsEvent) GetIp

func (x *FsEvent) GetIp() string

func (*FsEvent) GetOpenFlags

func (x *FsEvent) GetOpenFlags() int32

func (*FsEvent) GetProtocol

func (x *FsEvent) GetProtocol() string

func (*FsEvent) GetSessionId

func (x *FsEvent) GetSessionId() string

func (*FsEvent) GetSshCmd

func (x *FsEvent) GetSshCmd() string

func (*FsEvent) GetStatus

func (x *FsEvent) GetStatus() int32

func (*FsEvent) GetTimestamp

func (x *FsEvent) GetTimestamp() int64

func (*FsEvent) GetUsername

func (x *FsEvent) GetUsername() string

func (*FsEvent) GetVirtualPath

func (x *FsEvent) GetVirtualPath() string

func (*FsEvent) GetVirtualTargetPath

func (x *FsEvent) GetVirtualTargetPath() string

func (*FsEvent) ProtoMessage

func (*FsEvent) ProtoMessage()

func (*FsEvent) ProtoReflect

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

func (*FsEvent) Reset

func (x *FsEvent) Reset()

func (*FsEvent) String

func (x *FsEvent) String() string

type NotifierClient

type NotifierClient interface {
	SendFsEvent(ctx context.Context, in *FsEvent, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SendProviderEvent(ctx context.Context, in *ProviderEvent, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

NotifierClient is the client API for Notifier service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewNotifierClient

func NewNotifierClient(cc grpc.ClientConnInterface) NotifierClient

type NotifierServer

type NotifierServer interface {
	SendFsEvent(context.Context, *FsEvent) (*emptypb.Empty, error)
	SendProviderEvent(context.Context, *ProviderEvent) (*emptypb.Empty, error)
}

NotifierServer is the server API for Notifier service.

type ProviderEvent

type ProviderEvent struct {
	Timestamp  int64  `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Action     string `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
	ObjectType string `protobuf:"bytes,3,opt,name=object_type,json=objectType,proto3" json:"object_type,omitempty"`
	Username   string `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty"`
	Ip         string `protobuf:"bytes,5,opt,name=ip,proto3" json:"ip,omitempty"`
	ObjectName string `protobuf:"bytes,6,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
	ObjectData []byte `protobuf:"bytes,7,opt,name=object_data,json=objectData,proto3" json:"object_data,omitempty"` // object JSON serialized
	// contains filtered or unexported fields
}

func (*ProviderEvent) Descriptor deprecated

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

Deprecated: Use ProviderEvent.ProtoReflect.Descriptor instead.

func (*ProviderEvent) GetAction

func (x *ProviderEvent) GetAction() string

func (*ProviderEvent) GetIp

func (x *ProviderEvent) GetIp() string

func (*ProviderEvent) GetObjectData

func (x *ProviderEvent) GetObjectData() []byte

func (*ProviderEvent) GetObjectName

func (x *ProviderEvent) GetObjectName() string

func (*ProviderEvent) GetObjectType

func (x *ProviderEvent) GetObjectType() string

func (*ProviderEvent) GetTimestamp

func (x *ProviderEvent) GetTimestamp() int64

func (*ProviderEvent) GetUsername

func (x *ProviderEvent) GetUsername() string

func (*ProviderEvent) ProtoMessage

func (*ProviderEvent) ProtoMessage()

func (*ProviderEvent) ProtoReflect

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

func (*ProviderEvent) Reset

func (x *ProviderEvent) Reset()

func (*ProviderEvent) String

func (x *ProviderEvent) String() string

type UnimplementedNotifierServer

type UnimplementedNotifierServer struct {
}

UnimplementedNotifierServer can be embedded to have forward compatible implementations.

func (*UnimplementedNotifierServer) SendFsEvent

func (*UnimplementedNotifierServer) SendProviderEvent

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL