manage_to_manage_container

package module
v0.0.0-...-a47a548 Latest Latest
Warning

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

 Go to latest Published: Oct 12, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_manage_to_manage_proto protoreflect.FileDescriptor
View Source 
var ManageToManage_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "managetomanage.ManageToManage",
	HandlerType: (*ManageToManageServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DeleteShares",
			Handler:    _ManageToManage_DeleteShares_Handler,
		},
		{
			MethodName: "Sync",
			Handler:    _ManageToManage_Sync_Handler,
		},
		{
			MethodName: "CreateStatusFile",
			Handler:    _ManageToManage_CreateStatusFile_Handler,
		},
		{
			MethodName: "DeleteStatusFile",
			Handler:    _ManageToManage_DeleteStatusFile_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "manage_to_manage.proto",
}

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

Functions

func RegisterManageToManageServer 

func RegisterManageToManageServer(s grpc.ServiceRegistrar, srv ManageToManageServer)

Types

type CreateStatusFileRequest 

type CreateStatusFileRequest struct {
	JobUuid string `protobuf:"bytes,1,opt,name=job_uuid,json=jobUuid,proto3" json:"job_uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateStatusFileRequest) Descriptor deprecated 

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

Deprecated: Use CreateStatusFileRequest.ProtoReflect.Descriptor instead.

func (*CreateStatusFileRequest) GetJobUuid 

func (x *CreateStatusFileRequest) GetJobUuid() string

func (*CreateStatusFileRequest) ProtoMessage 

func (*CreateStatusFileRequest) ProtoMessage()

func (*CreateStatusFileRequest) ProtoReflect 

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

func (*CreateStatusFileRequest) Reset 

func (x *CreateStatusFileRequest) Reset()

func (*CreateStatusFileRequest) String 

func (x *CreateStatusFileRequest) String() string

type DeleteSharesRequest 

type DeleteSharesRequest struct {
	DataId string `protobuf:"bytes,1,opt,name=data_id,json=dataId,proto3" json:"data_id,omitempty"`
	// contains filtered or unexported fields
}

* the message of DeleteSharesRequest

func (*DeleteSharesRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSharesRequest.ProtoReflect.Descriptor instead.

func (*DeleteSharesRequest) GetDataId 

func (x *DeleteSharesRequest) GetDataId() string

func (*DeleteSharesRequest) ProtoMessage 

func (*DeleteSharesRequest) ProtoMessage()

func (*DeleteSharesRequest) ProtoReflect 

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

func (*DeleteSharesRequest) Reset 

func (x *DeleteSharesRequest) Reset()

func (*DeleteSharesRequest) String 

func (x *DeleteSharesRequest) String() string

type DeleteSharesResponse 

type DeleteSharesResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	IsOk    bool   `protobuf:"varint,2,opt,name=is_ok,json=isOk,proto3" json:"is_ok,omitempty"`
	// contains filtered or unexported fields
}

* the message of DeleteSharesResponse

func (*DeleteSharesResponse) Descriptor deprecated 

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

Deprecated: Use DeleteSharesResponse.ProtoReflect.Descriptor instead.

func (*DeleteSharesResponse) GetIsOk 

func (x *DeleteSharesResponse) GetIsOk() bool

func (*DeleteSharesResponse) GetMessage 

func (x *DeleteSharesResponse) GetMessage() string

func (*DeleteSharesResponse) ProtoMessage 

func (*DeleteSharesResponse) ProtoMessage()

func (*DeleteSharesResponse) ProtoReflect 

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

func (*DeleteSharesResponse) Reset 

func (x *DeleteSharesResponse) Reset()

func (*DeleteSharesResponse) String 

func (x *DeleteSharesResponse) String() string

type DeleteStatusFileRequest 

type DeleteStatusFileRequest struct {
	JobUuid string `protobuf:"bytes,1,opt,name=job_uuid,json=jobUuid,proto3" json:"job_uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteStatusFileRequest) Descriptor deprecated 

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

Deprecated: Use DeleteStatusFileRequest.ProtoReflect.Descriptor instead.

func (*DeleteStatusFileRequest) GetJobUuid 

func (x *DeleteStatusFileRequest) GetJobUuid() string

func (*DeleteStatusFileRequest) ProtoMessage 

func (*DeleteStatusFileRequest) ProtoMessage()

func (*DeleteStatusFileRequest) ProtoReflect 

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

func (*DeleteStatusFileRequest) Reset 

func (x *DeleteStatusFileRequest) Reset()

func (*DeleteStatusFileRequest) String 

func (x *DeleteStatusFileRequest) String() string

type ManageToManageClient 

type ManageToManageClient interface {
	DeleteShares(ctx context.Context, in *DeleteSharesRequest, opts ...grpc.CallOption) (*DeleteSharesResponse, error)
	Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncResponse, error)
	CreateStatusFile(ctx context.Context, in *CreateStatusFileRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteStatusFile(ctx context.Context, in *DeleteStatusFileRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ManageToManageClient is the client API for ManageToManage 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 NewManageToManageClient 

func NewManageToManageClient(cc grpc.ClientConnInterface) ManageToManageClient

type ManageToManageServer 

type ManageToManageServer interface {
	DeleteShares(context.Context, *DeleteSharesRequest) (*DeleteSharesResponse, error)
	Sync(context.Context, *SyncRequest) (*SyncResponse, error)
	CreateStatusFile(context.Context, *CreateStatusFileRequest) (*emptypb.Empty, error)
	DeleteStatusFile(context.Context, *DeleteStatusFileRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

ManageToManageServer is the server API for ManageToManage service. All implementations must embed UnimplementedManageToManageServer for forward compatibility

type SyncRequest 

type SyncRequest struct {
	SyncId string `protobuf:"bytes,1,opt,name=sync_id,json=syncId,proto3" json:"sync_id,omitempty"`
	// contains filtered or unexported fields
}

* the message of SyncRequest

func (*SyncRequest) Descriptor deprecated 

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

Deprecated: Use SyncRequest.ProtoReflect.Descriptor instead.

func (*SyncRequest) GetSyncId 

func (x *SyncRequest) GetSyncId() string

func (*SyncRequest) ProtoMessage 

func (*SyncRequest) ProtoMessage()

func (*SyncRequest) ProtoReflect 

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

func (*SyncRequest) Reset 

func (x *SyncRequest) Reset()

func (*SyncRequest) String 

func (x *SyncRequest) String() string

type SyncResponse 

type SyncResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	IsOk    bool   `protobuf:"varint,2,opt,name=is_ok,json=isOk,proto3" json:"is_ok,omitempty"`
	// contains filtered or unexported fields
}

* the message of SyncResponse

func (*SyncResponse) Descriptor deprecated 

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

Deprecated: Use SyncResponse.ProtoReflect.Descriptor instead.

func (*SyncResponse) GetIsOk 

func (x *SyncResponse) GetIsOk() bool

func (*SyncResponse) GetMessage 

func (x *SyncResponse) GetMessage() string

func (*SyncResponse) ProtoMessage 

func (*SyncResponse) ProtoMessage()

func (*SyncResponse) ProtoReflect 

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

func (*SyncResponse) Reset 

func (x *SyncResponse) Reset()

func (*SyncResponse) String 

func (x *SyncResponse) String() string

type UnimplementedManageToManageServer 

type UnimplementedManageToManageServer struct {
}

UnimplementedManageToManageServer must be embedded to have forward compatible implementations.

func (UnimplementedManageToManageServer) CreateStatusFile 

func (UnimplementedManageToManageServer) CreateStatusFile(context.Context, *CreateStatusFileRequest) (*emptypb.Empty, error)

func (UnimplementedManageToManageServer) DeleteShares 

func (UnimplementedManageToManageServer) DeleteShares(context.Context, *DeleteSharesRequest) (*DeleteSharesResponse, error)

func (UnimplementedManageToManageServer) DeleteStatusFile 

func (UnimplementedManageToManageServer) DeleteStatusFile(context.Context, *DeleteStatusFileRequest) (*emptypb.Empty, error)

func (UnimplementedManageToManageServer) Sync 

func (UnimplementedManageToManageServer) Sync(context.Context, *SyncRequest) (*SyncResponse, error)

type UnsafeManageToManageServer 

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

UnsafeManageToManageServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ManageToManageServer 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.