rpc

package
v0.0.0-...-5fea7ce Latest Latest
Warning

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

 Go to latest Published: Mar 31, 2022 License: MIT Imports: 9 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_youplus_service_proto protoreflect.FileDescriptor
View Source 
var YouPlusService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "youplus.YouPlusService",
	HandlerType: (*YouPlusServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CheckDataset",
			Handler:    _YouPlusService_CheckDataset_Handler,
		},
		{
			MethodName: "GetDatasetInfo",
			Handler:    _YouPlusService_GetDatasetInfo_Handler,
		},
		{
			MethodName: "CreateDataset",
			Handler:    _YouPlusService_CreateDataset_Handler,
		},
		{
			MethodName: "DeleteDataset",
			Handler:    _YouPlusService_DeleteDataset_Handler,
		},
		{
			MethodName: "CreateSnapshot",
			Handler:    _YouPlusService_CreateSnapshot_Handler,
		},
		{
			MethodName: "DeleteSnapshot",
			Handler:    _YouPlusService_DeleteSnapshot_Handler,
		},
		{
			MethodName: "RollbackDataset",
			Handler:    _YouPlusService_RollbackDataset_Handler,
		},
		{
			MethodName: "RegisterEntry",
			Handler:    _YouPlusService_RegisterEntry_Handler,
		},
		{
			MethodName: "UnregisterEntry",
			Handler:    _YouPlusService_UnregisterEntry_Handler,
		},
		{
			MethodName: "UpdateEntryExport",
			Handler:    _YouPlusService_UpdateEntryExport_Handler,
		},
		{
			MethodName: "EntryHeartbeat",
			Handler:    _YouPlusService_EntryHeartbeat_Handler,
		},
		{
			MethodName: "GenerateToken",
			Handler:    _YouPlusService_GenerateToken_Handler,
		},
		{
			MethodName: "CheckToken",
			Handler:    _YouPlusService_CheckToken_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "youplus_service.proto",
}

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

Functions

func RegisterYouPlusServiceServer 

func RegisterYouPlusServiceServer(s grpc.ServiceRegistrar, srv YouPlusServiceServer)

Types

type ActionReply 

type ActionReply struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Reason  *string `protobuf:"bytes,2,opt,name=reason" json:"reason,omitempty"`
	Code    *int64  `protobuf:"varint,3,opt,name=code" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionReply) Descriptor deprecated 

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

Deprecated: Use ActionReply.ProtoReflect.Descriptor instead.

func (*ActionReply) GetCode 

func (x *ActionReply) GetCode() int64

func (*ActionReply) GetReason 

func (x *ActionReply) GetReason() string

func (*ActionReply) GetSuccess 

func (x *ActionReply) GetSuccess() bool

func (*ActionReply) ProtoMessage 

func (*ActionReply) ProtoMessage()

func (*ActionReply) ProtoReflect 

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

func (*ActionReply) Reset 

func (x *ActionReply) Reset()

func (*ActionReply) String 

func (x *ActionReply) String() string

type CheckDatasetReply 

type CheckDatasetReply struct {
	IsDataset *bool `protobuf:"varint,1,req,name=isDataset" json:"isDataset,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckDatasetReply) Descriptor deprecated 

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

Deprecated: Use CheckDatasetReply.ProtoReflect.Descriptor instead.

func (*CheckDatasetReply) GetIsDataset 

func (x *CheckDatasetReply) GetIsDataset() bool

func (*CheckDatasetReply) ProtoMessage 

func (*CheckDatasetReply) ProtoMessage()

func (*CheckDatasetReply) ProtoReflect 

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

func (*CheckDatasetReply) Reset 

func (x *CheckDatasetReply) Reset()

func (*CheckDatasetReply) String 

func (x *CheckDatasetReply) String() string

type CheckDatasetRequest 

type CheckDatasetRequest struct {
	Path *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckDatasetRequest) Descriptor deprecated 

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

Deprecated: Use CheckDatasetRequest.ProtoReflect.Descriptor instead.

func (*CheckDatasetRequest) GetPath 

func (x *CheckDatasetRequest) GetPath() string

func (*CheckDatasetRequest) ProtoMessage 

func (*CheckDatasetRequest) ProtoMessage()

func (*CheckDatasetRequest) ProtoReflect 

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

func (*CheckDatasetRequest) Reset 

func (x *CheckDatasetRequest) Reset()

func (*CheckDatasetRequest) String 

func (x *CheckDatasetRequest) String() string

type CheckTokenReply 

type CheckTokenReply struct {
	Success  *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Reason   *string `protobuf:"bytes,2,opt,name=reason" json:"reason,omitempty"`
	Code     *int64  `protobuf:"varint,3,opt,name=code" json:"code,omitempty"`
	Username *string `protobuf:"bytes,4,opt,name=username" json:"username,omitempty"`
	Uid      *string `protobuf:"bytes,5,opt,name=uid" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckTokenReply) Descriptor deprecated 

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

Deprecated: Use CheckTokenReply.ProtoReflect.Descriptor instead.

func (*CheckTokenReply) GetCode 

func (x *CheckTokenReply) GetCode() int64

func (*CheckTokenReply) GetReason 

func (x *CheckTokenReply) GetReason() string

func (*CheckTokenReply) GetSuccess 

func (x *CheckTokenReply) GetSuccess() bool

func (*CheckTokenReply) GetUid 

func (x *CheckTokenReply) GetUid() string

func (*CheckTokenReply) GetUsername 

func (x *CheckTokenReply) GetUsername() string

func (*CheckTokenReply) ProtoMessage 

func (*CheckTokenReply) ProtoMessage()

func (*CheckTokenReply) ProtoReflect 

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

func (*CheckTokenReply) Reset 

func (x *CheckTokenReply) Reset()

func (*CheckTokenReply) String 

func (x *CheckTokenReply) String() string

type CheckTokenRequest 

type CheckTokenRequest struct {
	Token *string `protobuf:"bytes,1,req,name=token" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckTokenRequest) Descriptor deprecated 

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

Deprecated: Use CheckTokenRequest.ProtoReflect.Descriptor instead.

func (*CheckTokenRequest) GetToken 

func (x *CheckTokenRequest) GetToken() string

func (*CheckTokenRequest) ProtoMessage 

func (*CheckTokenRequest) ProtoMessage()

func (*CheckTokenRequest) ProtoReflect 

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

func (*CheckTokenRequest) Reset 

func (x *CheckTokenRequest) Reset()

func (*CheckTokenRequest) String 

func (x *CheckTokenRequest) String() string

type CreateDatasetRequest 

type CreateDatasetRequest struct {
	Path *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDatasetRequest) Descriptor deprecated 

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

Deprecated: Use CreateDatasetRequest.ProtoReflect.Descriptor instead.

func (*CreateDatasetRequest) GetPath 

func (x *CreateDatasetRequest) GetPath() string

func (*CreateDatasetRequest) ProtoMessage 

func (*CreateDatasetRequest) ProtoMessage()

func (*CreateDatasetRequest) ProtoReflect 

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

func (*CreateDatasetRequest) Reset 

func (x *CreateDatasetRequest) Reset()

func (*CreateDatasetRequest) String 

func (x *CreateDatasetRequest) String() string

type CreateSnapshotRequest 

type CreateSnapshotRequest struct {
	Dataset  *string `protobuf:"bytes,1,req,name=dataset" json:"dataset,omitempty"`
	Snapshot *string `protobuf:"bytes,2,req,name=snapshot" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSnapshotRequest) Descriptor deprecated 

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

Deprecated: Use CreateSnapshotRequest.ProtoReflect.Descriptor instead.

func (*CreateSnapshotRequest) GetDataset 

func (x *CreateSnapshotRequest) GetDataset() string

func (*CreateSnapshotRequest) GetSnapshot 

func (x *CreateSnapshotRequest) GetSnapshot() string

func (*CreateSnapshotRequest) ProtoMessage 

func (*CreateSnapshotRequest) ProtoMessage()

func (*CreateSnapshotRequest) ProtoReflect 

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

func (*CreateSnapshotRequest) Reset 

func (x *CreateSnapshotRequest) Reset()

func (*CreateSnapshotRequest) String 

func (x *CreateSnapshotRequest) String() string

type DeleteDatasetRequest 

type DeleteDatasetRequest struct {
	Path *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDatasetRequest) Descriptor deprecated 

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

Deprecated: Use DeleteDatasetRequest.ProtoReflect.Descriptor instead.

func (*DeleteDatasetRequest) GetPath 

func (x *DeleteDatasetRequest) GetPath() string

func (*DeleteDatasetRequest) ProtoMessage 

func (*DeleteDatasetRequest) ProtoMessage()

func (*DeleteDatasetRequest) ProtoReflect 

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

func (*DeleteDatasetRequest) Reset 

func (x *DeleteDatasetRequest) Reset()

func (*DeleteDatasetRequest) String 

func (x *DeleteDatasetRequest) String() string

type DeleteSnapshotRequest 

type DeleteSnapshotRequest struct {
	Dataset  *string `protobuf:"bytes,1,req,name=dataset" json:"dataset,omitempty"`
	Snapshot *string `protobuf:"bytes,2,req,name=snapshot" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSnapshotRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSnapshotRequest.ProtoReflect.Descriptor instead.

func (*DeleteSnapshotRequest) GetDataset 

func (x *DeleteSnapshotRequest) GetDataset() string

func (*DeleteSnapshotRequest) GetSnapshot 

func (x *DeleteSnapshotRequest) GetSnapshot() string

func (*DeleteSnapshotRequest) ProtoMessage 

func (*DeleteSnapshotRequest) ProtoMessage()

func (*DeleteSnapshotRequest) ProtoReflect 

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

func (*DeleteSnapshotRequest) Reset 

func (x *DeleteSnapshotRequest) Reset()

func (*DeleteSnapshotRequest) String 

func (x *DeleteSnapshotRequest) String() string

type GenerateTokenReply 

type GenerateTokenReply struct {
	Success *bool   `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	Reason  *string `protobuf:"bytes,2,opt,name=reason" json:"reason,omitempty"`
	Code    *int64  `protobuf:"varint,3,opt,name=code" json:"code,omitempty"`
	Token   *string `protobuf:"bytes,4,opt,name=token" json:"token,omitempty"`
	Uid     *string `protobuf:"bytes,5,opt,name=uid" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateTokenReply) Descriptor deprecated 

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

Deprecated: Use GenerateTokenReply.ProtoReflect.Descriptor instead.

func (*GenerateTokenReply) GetCode 

func (x *GenerateTokenReply) GetCode() int64

func (*GenerateTokenReply) GetReason 

func (x *GenerateTokenReply) GetReason() string

func (*GenerateTokenReply) GetSuccess 

func (x *GenerateTokenReply) GetSuccess() bool

func (*GenerateTokenReply) GetToken 

func (x *GenerateTokenReply) GetToken() string

func (*GenerateTokenReply) GetUid 

func (x *GenerateTokenReply) GetUid() string

func (*GenerateTokenReply) ProtoMessage 

func (*GenerateTokenReply) ProtoMessage()

func (*GenerateTokenReply) ProtoReflect 

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

func (*GenerateTokenReply) Reset 

func (x *GenerateTokenReply) Reset()

func (*GenerateTokenReply) String 

func (x *GenerateTokenReply) String() string

type GenerateTokenRequest 

type GenerateTokenRequest struct {
	Username *string `protobuf:"bytes,1,req,name=username" json:"username,omitempty"`
	Password *string `protobuf:"bytes,2,req,name=password" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateTokenRequest) Descriptor deprecated 

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

Deprecated: Use GenerateTokenRequest.ProtoReflect.Descriptor instead.

func (*GenerateTokenRequest) GetPassword 

func (x *GenerateTokenRequest) GetPassword() string

func (*GenerateTokenRequest) GetUsername 

func (x *GenerateTokenRequest) GetUsername() string

func (*GenerateTokenRequest) ProtoMessage 

func (*GenerateTokenRequest) ProtoMessage()

func (*GenerateTokenRequest) ProtoReflect 

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

func (*GenerateTokenRequest) Reset 

func (x *GenerateTokenRequest) Reset()

func (*GenerateTokenRequest) String 

func (x *GenerateTokenRequest) String() string

type GetDatasetInfoReply 

type GetDatasetInfoReply struct {
	Path      *string     `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	Snapshots []*Snapshot `protobuf:"bytes,2,rep,name=snapshots" json:"snapshots,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDatasetInfoReply) Descriptor deprecated 

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

Deprecated: Use GetDatasetInfoReply.ProtoReflect.Descriptor instead.

func (*GetDatasetInfoReply) GetPath 

func (x *GetDatasetInfoReply) GetPath() string

func (*GetDatasetInfoReply) GetSnapshots 

func (x *GetDatasetInfoReply) GetSnapshots() []*Snapshot

func (*GetDatasetInfoReply) ProtoMessage 

func (*GetDatasetInfoReply) ProtoMessage()

func (*GetDatasetInfoReply) ProtoReflect 

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

func (*GetDatasetInfoReply) Reset 

func (x *GetDatasetInfoReply) Reset()

func (*GetDatasetInfoReply) String 

func (x *GetDatasetInfoReply) String() string

type GetDatasetInfoRequest 

type GetDatasetInfoRequest struct {
	Dataset *string `protobuf:"bytes,1,req,name=dataset" json:"dataset,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDatasetInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetDatasetInfoRequest.ProtoReflect.Descriptor instead.

func (*GetDatasetInfoRequest) GetDataset 

func (x *GetDatasetInfoRequest) GetDataset() string

func (*GetDatasetInfoRequest) ProtoMessage 

func (*GetDatasetInfoRequest) ProtoMessage()

func (*GetDatasetInfoRequest) ProtoReflect 

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

func (*GetDatasetInfoRequest) Reset 

func (x *GetDatasetInfoRequest) Reset()

func (*GetDatasetInfoRequest) String 

func (x *GetDatasetInfoRequest) String() string

type HeartbeatRequest 

type HeartbeatRequest struct {
	Name     *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Instance *string `protobuf:"bytes,2,req,name=instance" json:"instance,omitempty"`
	State    *string `protobuf:"bytes,3,req,name=state" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatRequest) Descriptor deprecated 

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

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetInstance 

func (x *HeartbeatRequest) GetInstance() string

func (*HeartbeatRequest) GetName 

func (x *HeartbeatRequest) GetName() string

func (*HeartbeatRequest) GetState 

func (x *HeartbeatRequest) GetState() string

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoReflect 

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

func (*HeartbeatRequest) Reset 

func (x *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (x *HeartbeatRequest) String() string

type RegisterEntryRequest 

type RegisterEntryRequest struct {
	Name     *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Instance *string `protobuf:"bytes,2,req,name=instance" json:"instance,omitempty"`
	Version  *int64  `protobuf:"varint,3,req,name=version" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterEntryRequest) Descriptor deprecated 

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

Deprecated: Use RegisterEntryRequest.ProtoReflect.Descriptor instead.

func (*RegisterEntryRequest) GetInstance 

func (x *RegisterEntryRequest) GetInstance() string

func (*RegisterEntryRequest) GetName 

func (x *RegisterEntryRequest) GetName() string

func (*RegisterEntryRequest) GetVersion 

func (x *RegisterEntryRequest) GetVersion() int64

func (*RegisterEntryRequest) ProtoMessage 

func (*RegisterEntryRequest) ProtoMessage()

func (*RegisterEntryRequest) ProtoReflect 

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

func (*RegisterEntryRequest) Reset 

func (x *RegisterEntryRequest) Reset()

func (*RegisterEntryRequest) String 

func (x *RegisterEntryRequest) String() string

type RollbackDatasetRequest 

type RollbackDatasetRequest struct {
	Dataset  *string `protobuf:"bytes,1,req,name=dataset" json:"dataset,omitempty"`
	Snapshot *string `protobuf:"bytes,2,req,name=snapshot" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

func (*RollbackDatasetRequest) Descriptor deprecated 

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

Deprecated: Use RollbackDatasetRequest.ProtoReflect.Descriptor instead.

func (*RollbackDatasetRequest) GetDataset 

func (x *RollbackDatasetRequest) GetDataset() string

func (*RollbackDatasetRequest) GetSnapshot 

func (x *RollbackDatasetRequest) GetSnapshot() string

func (*RollbackDatasetRequest) ProtoMessage 

func (*RollbackDatasetRequest) ProtoMessage()

func (*RollbackDatasetRequest) ProtoReflect 

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

func (*RollbackDatasetRequest) Reset 

func (x *RollbackDatasetRequest) Reset()

func (*RollbackDatasetRequest) String 

func (x *RollbackDatasetRequest) String() string

type Snapshot 

type Snapshot struct {
	Name *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*Snapshot) Descriptor deprecated 

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

Deprecated: Use Snapshot.ProtoReflect.Descriptor instead.

func (*Snapshot) GetName 

func (x *Snapshot) GetName() string

func (*Snapshot) ProtoMessage 

func (*Snapshot) ProtoMessage()

func (*Snapshot) ProtoReflect 

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

func (*Snapshot) Reset 

func (x *Snapshot) Reset()

func (*Snapshot) String 

func (x *Snapshot) String() string

type UnimplementedYouPlusServiceServer 

type UnimplementedYouPlusServiceServer struct {
}

UnimplementedYouPlusServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedYouPlusServiceServer) CheckDataset 

func (UnimplementedYouPlusServiceServer) CheckDataset(context.Context, *CheckDatasetRequest) (*CheckDatasetReply, error)

func (UnimplementedYouPlusServiceServer) CheckToken 

func (UnimplementedYouPlusServiceServer) CheckToken(context.Context, *CheckTokenRequest) (*CheckTokenReply, error)

func (UnimplementedYouPlusServiceServer) CreateDataset 

func (UnimplementedYouPlusServiceServer) CreateDataset(context.Context, *CreateDatasetRequest) (*ActionReply, error)

func (UnimplementedYouPlusServiceServer) CreateSnapshot 

func (UnimplementedYouPlusServiceServer) CreateSnapshot(context.Context, *CreateSnapshotRequest) (*ActionReply, error)

func (UnimplementedYouPlusServiceServer) DeleteDataset 

func (UnimplementedYouPlusServiceServer) DeleteDataset(context.Context, *DeleteDatasetRequest) (*ActionReply, error)

func (UnimplementedYouPlusServiceServer) DeleteSnapshot 

func (UnimplementedYouPlusServiceServer) DeleteSnapshot(context.Context, *DeleteSnapshotRequest) (*ActionReply, error)

func (UnimplementedYouPlusServiceServer) EntryHeartbeat 

func (UnimplementedYouPlusServiceServer) EntryHeartbeat(context.Context, *HeartbeatRequest) (*ActionReply, error)

func (UnimplementedYouPlusServiceServer) GenerateToken 

func (UnimplementedYouPlusServiceServer) GenerateToken(context.Context, *GenerateTokenRequest) (*GenerateTokenReply, error)

func (UnimplementedYouPlusServiceServer) GetDatasetInfo 

func (UnimplementedYouPlusServiceServer) GetDatasetInfo(context.Context, *GetDatasetInfoRequest) (*GetDatasetInfoReply, error)

func (UnimplementedYouPlusServiceServer) RegisterEntry 

func (UnimplementedYouPlusServiceServer) RegisterEntry(context.Context, *RegisterEntryRequest) (*ActionReply, error)

func (UnimplementedYouPlusServiceServer) RollbackDataset 

func (UnimplementedYouPlusServiceServer) RollbackDataset(context.Context, *RollbackDatasetRequest) (*ActionReply, error)

func (UnimplementedYouPlusServiceServer) UnregisterEntry 

func (UnimplementedYouPlusServiceServer) UnregisterEntry(context.Context, *UnregisterEntryRequest) (*ActionReply, error)

func (UnimplementedYouPlusServiceServer) UpdateEntryExport 

func (UnimplementedYouPlusServiceServer) UpdateEntryExport(context.Context, *UpdateEntryExportRequest) (*ActionReply, error)

type UnregisterEntryRequest 

type UnregisterEntryRequest struct {
	Instance *string `protobuf:"bytes,1,req,name=instance" json:"instance,omitempty"`
	// contains filtered or unexported fields
}

func (*UnregisterEntryRequest) Descriptor deprecated 

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

Deprecated: Use UnregisterEntryRequest.ProtoReflect.Descriptor instead.

func (*UnregisterEntryRequest) GetInstance 

func (x *UnregisterEntryRequest) GetInstance() string

func (*UnregisterEntryRequest) ProtoMessage 

func (*UnregisterEntryRequest) ProtoMessage()

func (*UnregisterEntryRequest) ProtoReflect 

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

func (*UnregisterEntryRequest) Reset 

func (x *UnregisterEntryRequest) Reset()

func (*UnregisterEntryRequest) String 

func (x *UnregisterEntryRequest) String() string

type UnsafeYouPlusServiceServer 

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

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

type UpdateEntryExportRequest 

type UpdateEntryExportRequest struct {
	Data     *string `protobuf:"bytes,1,req,name=data" json:"data,omitempty"`
	Instance *string `protobuf:"bytes,2,req,name=instance" json:"instance,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateEntryExportRequest) Descriptor deprecated 

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

Deprecated: Use UpdateEntryExportRequest.ProtoReflect.Descriptor instead.

func (*UpdateEntryExportRequest) GetData 

func (x *UpdateEntryExportRequest) GetData() string

func (*UpdateEntryExportRequest) GetInstance 

func (x *UpdateEntryExportRequest) GetInstance() string

func (*UpdateEntryExportRequest) ProtoMessage 

func (*UpdateEntryExportRequest) ProtoMessage()

func (*UpdateEntryExportRequest) ProtoReflect 

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

func (*UpdateEntryExportRequest) Reset 

func (x *UpdateEntryExportRequest) Reset()

func (*UpdateEntryExportRequest) String 

func (x *UpdateEntryExportRequest) String() string

type YouPlusRPCClient 

type YouPlusRPCClient struct {
	Address string
	// contains filtered or unexported fields
}

func NewYouPlusRPCClient 

func NewYouPlusRPCClient(address string) *YouPlusRPCClient

func (*YouPlusRPCClient) GetClient 

func (c *YouPlusRPCClient) GetClient() (YouPlusServiceClient, error)

func (*YouPlusRPCClient) Init 

func (c *YouPlusRPCClient) Init() error

type YouPlusServiceClient 

type YouPlusServiceClient interface {
	CheckDataset(ctx context.Context, in *CheckDatasetRequest, opts ...grpc.CallOption) (*CheckDatasetReply, error)
	GetDatasetInfo(ctx context.Context, in *GetDatasetInfoRequest, opts ...grpc.CallOption) (*GetDatasetInfoReply, error)
	CreateDataset(ctx context.Context, in *CreateDatasetRequest, opts ...grpc.CallOption) (*ActionReply, error)
	DeleteDataset(ctx context.Context, in *DeleteDatasetRequest, opts ...grpc.CallOption) (*ActionReply, error)
	CreateSnapshot(ctx context.Context, in *CreateSnapshotRequest, opts ...grpc.CallOption) (*ActionReply, error)
	DeleteSnapshot(ctx context.Context, in *DeleteSnapshotRequest, opts ...grpc.CallOption) (*ActionReply, error)
	RollbackDataset(ctx context.Context, in *RollbackDatasetRequest, opts ...grpc.CallOption) (*ActionReply, error)
	RegisterEntry(ctx context.Context, in *RegisterEntryRequest, opts ...grpc.CallOption) (*ActionReply, error)
	UnregisterEntry(ctx context.Context, in *UnregisterEntryRequest, opts ...grpc.CallOption) (*ActionReply, error)
	UpdateEntryExport(ctx context.Context, in *UpdateEntryExportRequest, opts ...grpc.CallOption) (*ActionReply, error)
	EntryHeartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*ActionReply, error)
	GenerateToken(ctx context.Context, in *GenerateTokenRequest, opts ...grpc.CallOption) (*GenerateTokenReply, error)
	CheckToken(ctx context.Context, in *CheckTokenRequest, opts ...grpc.CallOption) (*CheckTokenReply, error)
}

YouPlusServiceClient is the client API for YouPlusService 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 NewYouPlusServiceClient 

func NewYouPlusServiceClient(cc grpc.ClientConnInterface) YouPlusServiceClient

type YouPlusServiceServer 

type YouPlusServiceServer interface {
	CheckDataset(context.Context, *CheckDatasetRequest) (*CheckDatasetReply, error)
	GetDatasetInfo(context.Context, *GetDatasetInfoRequest) (*GetDatasetInfoReply, error)
	CreateDataset(context.Context, *CreateDatasetRequest) (*ActionReply, error)
	DeleteDataset(context.Context, *DeleteDatasetRequest) (*ActionReply, error)
	CreateSnapshot(context.Context, *CreateSnapshotRequest) (*ActionReply, error)
	DeleteSnapshot(context.Context, *DeleteSnapshotRequest) (*ActionReply, error)
	RollbackDataset(context.Context, *RollbackDatasetRequest) (*ActionReply, error)
	RegisterEntry(context.Context, *RegisterEntryRequest) (*ActionReply, error)
	UnregisterEntry(context.Context, *UnregisterEntryRequest) (*ActionReply, error)
	UpdateEntryExport(context.Context, *UpdateEntryExportRequest) (*ActionReply, error)
	EntryHeartbeat(context.Context, *HeartbeatRequest) (*ActionReply, error)
	GenerateToken(context.Context, *GenerateTokenRequest) (*GenerateTokenReply, error)
	CheckToken(context.Context, *CheckTokenRequest) (*CheckTokenReply, error)
	// contains filtered or unexported methods
}

YouPlusServiceServer is the server API for YouPlusService service. All implementations must embed UnimplementedYouPlusServiceServer for forward compatibility

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.