Documentation
¶
Overview ¶
Package artfs provides protocol buffer message for artfs.
Index ¶
Constants ¶
const (
Artfs_AddCasFiles_FullMethodName = "/artfs.Artfs/AddCasFiles"
)
Variables ¶
var Artfs_ServiceDesc = grpc.ServiceDesc{ ServiceName: "artfs.Artfs", HandlerType: (*ArtfsServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "AddCasFiles", Handler: _Artfs_AddCasFiles_Handler, ClientStreams: true, }, }, Metadata: "artfs.proto", }
Artfs_ServiceDesc is the grpc.ServiceDesc for Artfs service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_artfs_proto protoreflect.FileDescriptor
Functions ¶
func RegisterArtfsServer ¶
func RegisterArtfsServer(s grpc.ServiceRegistrar, srv ArtfsServer)
Types ¶
type AddCasFilesReply ¶
type AddCasFilesReply struct {
// Total number of files added. Should be equal to the number of files
// sent via the stream of FileManifests.
Total int64 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
// contains filtered or unexported fields
}
func (*AddCasFilesReply) Descriptor
deprecated
func (*AddCasFilesReply) Descriptor() ([]byte, []int)
Deprecated: Use AddCasFilesReply.ProtoReflect.Descriptor instead.
func (*AddCasFilesReply) GetTotal ¶
func (x *AddCasFilesReply) GetTotal() int64
func (*AddCasFilesReply) ProtoMessage ¶
func (*AddCasFilesReply) ProtoMessage()
func (*AddCasFilesReply) ProtoReflect ¶
func (x *AddCasFilesReply) ProtoReflect() protoreflect.Message
func (*AddCasFilesReply) Reset ¶
func (x *AddCasFilesReply) Reset()
func (*AddCasFilesReply) String ¶
func (x *AddCasFilesReply) String() string
type ArtfsClient ¶
type ArtfsClient interface {
// Stream a bunch of files that are backed by CAS to Artfs.
AddCasFiles(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[manifest.FileManifest, AddCasFilesReply], error)
}
ArtfsClient is the client API for Artfs 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 NewArtfsClient ¶
func NewArtfsClient(cc grpc.ClientConnInterface) ArtfsClient
type ArtfsServer ¶
type ArtfsServer interface {
// Stream a bunch of files that are backed by CAS to Artfs.
AddCasFiles(grpc.ClientStreamingServer[manifest.FileManifest, AddCasFilesReply]) error
// contains filtered or unexported methods
}
ArtfsServer is the server API for Artfs service. All implementations must embed UnimplementedArtfsServer for forward compatibility.
type Artfs_AddCasFilesClient ¶
type Artfs_AddCasFilesClient = grpc.ClientStreamingClient[manifest.FileManifest, AddCasFilesReply]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Artfs_AddCasFilesServer ¶
type Artfs_AddCasFilesServer = grpc.ClientStreamingServer[manifest.FileManifest, AddCasFilesReply]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type UnimplementedArtfsServer ¶
type UnimplementedArtfsServer struct{}
UnimplementedArtfsServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedArtfsServer) AddCasFiles ¶
func (UnimplementedArtfsServer) AddCasFiles(grpc.ClientStreamingServer[manifest.FileManifest, AddCasFilesReply]) error
type UnsafeArtfsServer ¶
type UnsafeArtfsServer interface {
// contains filtered or unexported methods
}
UnsafeArtfsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ArtfsServer will result in compilation errors.
Source Files