U Vc2,@s@ddlZddlmZGdddeZGdddeZddZdS) N)write_service_pb2c@seZdZdZddZdS)TensorBoardWriterServiceStub/Service for writing data to TensorBoard.dev. cCs|jdtjjtjjd|_|jdtjjtjjd|_ |jdtj jtj jd|_ |jdtj jtjjd|_|jdtjjtjjd|_|jdtjjtjjd|_|jdtjjtjjd|_|jd tjjtjjd|_|jd tjjtjjd|_|jd tj jtj!jd|_"d S) z;Constructor. Args: channel: A grpc.Channel. z>/tensorboard.service.TensorBoardWriterService/CreateExperiment)Zrequest_serializerZresponse_deserializerz>/tensorboard.service.TensorBoardWriterService/UpdateExperimentz>/tensorboard.service.TensorBoardWriterService/DeleteExperimentz7/tensorboard.service.TensorBoardWriterService/PurgeDataz9/tensorboard.service.TensorBoardWriterService/WriteScalarz9/tensorboard.service.TensorBoardWriterService/WriteTensorzE/tensorboard.service.TensorBoardWriterService/GetOrCreateBlobSequencez=/tensorboard.service.TensorBoardWriterService/GetBlobMetadataz7/tensorboard.service.TensorBoardWriterService/WriteBlobz;/tensorboard.service.TensorBoardWriterService/DeleteOwnUserN)#Z unary_unary:tensorboard_dot_uploader_dot_proto_dot_write__service__pb2CreateExperimentRequestSerializeToStringCreateExperimentResponse FromStringCreateExperimentUpdateExperimentRequestUpdateExperimentResponseUpdateExperimentDeleteExperimentRequestDeleteExperimentResponseDeleteExperimentPurgeDataRequestPurgeDataResponse PurgeDataWriteScalarRequestWriteScalarResponse WriteScalarWriteTensorRequestWriteTensorResponse WriteTensorGetOrCreateBlobSequenceRequestGetOrCreateBlobSequenceResponseGetOrCreateBlobSequenceGetBlobMetadataRequestGetBlobMetadataResponseGetBlobMetadataZ stream_streamWriteBlobRequestWriteBlobResponse WriteBlobDeleteOwnUserRequestDeleteOwnUserResponse DeleteOwnUser)selfZchannelr'U/tmp/pip-unpacked-wheel-g8kmtpbc/tensorboard/uploader/proto/write_service_pb2_grpc.py__init__ sdz%TensorBoardWriterServiceStub.__init__N)__name__ __module__ __qualname____doc__r)r'r'r'r(rsrc@s`eZdZdZddZddZddZdd Zd d Zd d Z ddZ ddZ ddZ ddZ dS) TensorBoardWriterServiceServicerrcCs$|tjj|dtddS)zERequest for a new location to write TensorBoard readable events. Method not implemented!NZset_codegrpcZ StatusCodeZ UNIMPLEMENTEDZ set_detailsNotImplementedErrorr&requestcontextr'r'r(r Is z1TensorBoardWriterServiceServicer.CreateExperimentcCs$|tjj|dtddS)z>Request to mutate metadata associated with an experiment. r/Nr0r3r'r'r(r Ps z1TensorBoardWriterServiceServicer.UpdateExperimentcCs$|tjj|dtddS)zRequest that an experiment be deleted, along with all tags and scalars that it contains. This call may only be made by the original owner of the experiment. r/Nr0r3r'r'r(rWs z1TensorBoardWriterServiceServicer.DeleteExperimentcCs$|tjj|dtddS)z`Request that unreachable data be purged. Used only for testing; disabled in production. r/Nr0r3r'r'r(r`s z*TensorBoardWriterServiceServicer.PurgeDatacCs$|tjj|dtddS)zARequest additional scalar data be stored in TensorBoard.dev. r/Nr0r3r'r'r(rhs z,TensorBoardWriterServiceServicer.WriteScalarcCs$|tjj|dtddS)zARequest additional tensor data be stored in TensorBoard.dev. r/Nr0r3r'r'r(ros z,TensorBoardWriterServiceServicer.WriteTensorcCs$|tjj|dtddS)zyRequest to obtain a specific BlobSequence entry, creating it if needed, to be subsequently populated with blobs. r/Nr0r3r'r'r(rvs z8TensorBoardWriterServiceServicer.GetOrCreateBlobSequencecCs$|tjj|dtddS)zoRequest the current status of blob data being stored in TensorBoard.dev, to support resumable uploads. r/Nr0r3r'r'r(r~s z0TensorBoardWriterServiceServicer.GetBlobMetadatacCs$|tjj|dtddS)z?Request additional blob data be stored in TensorBoard.dev. r/Nr0)r&Zrequest_iteratorr5r'r'r(r"s z*TensorBoardWriterServiceServicer.WriteBlobcCs$|tjj|dtddS)zlRequest that the calling user and all their data be permanently deleted. Used for testing purposes. r/Nr0r3r'r'r(r%s z.TensorBoardWriterServiceServicer.DeleteOwnUserN)r*r+r,r-r r rrrrrrr"r%r'r'r'r(r.Es r.cCstj|jtjjtjjdtj|jtj jtj jdtj|j tj jtj jdtj|jtjjtjjdtj|jtjjtjjdtj|jtjjtjjdtj|jtjjtjjdtj|jtjjtjjdtj|jtjjtj jdtj|j!tj"jtj#jdd }t$d|}|%|fdS)N)Zrequest_deserializerZresponse_serializer) r r rrrrrrr"r%z,tensorboard.service.TensorBoardWriterService)&r1Zunary_unary_rpc_method_handlerr rrr rrr r r rrrrrrrrrrrrrrrrrrZ stream_stream_rpc_method_handlerr"r r!r%r#r$Zmethod_handlers_generic_handlerZadd_generic_rpc_handlers)ZservicerserverZrpc_method_handlersZgeneric_handlerr'r'r(.add_TensorBoardWriterServiceServicer_to_serversp4r7)r1Ztensorboard.uploader.protorrobjectrr.r7r'r'r'r(s >Q