Documentation
¶
Overview ¶
Implements publish_service.proto (see proto for details)
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PublishService ¶
type PublishService struct {
// contains filtered or unexported fields
}
PublishService implementation of publish_service.proto
func NewPublishService ¶
func NewPublishService(ctx context.Context, gcpCredentials string, logger *log.Logger) (*PublishService, func(), error)
NewPublishService creates a new publish service with the GCP storage client.
func (*PublishService) RunCli ¶
func (s *PublishService) RunCli(ctx context.Context, localDir string, gsDir string, outputPath string) error
RunCli runs publish service as execution by CLI.
Steps: 1) Publish the data to GCS bucket. 2) Save output log data.
func (*PublishService) StartServer ¶
func (s *PublishService) StartServer(port int) error
StartServer starts publish server on requested port
func (*PublishService) UploadToGS ¶
func (s *PublishService) UploadToGS(ctx context.Context, req *api.UploadToGSRequest) (*longrunning.Operation, error)
UploadToGS uploads the designated folder to the provided Google Cloud Storage bucket/object
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package mock_storage is a generated GoMock package.
|
Package mock_storage is a generated GoMock package. |
Click to show internal directories.
Click to hide internal directories.