proto

package
v1.6.0-rc.1 Latest Latest
Warning

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

Go to latest
Published: Feb 20, 2023 License: AGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_proto_warehouse_warehouse_proto protoreflect.FileDescriptor
View Source
var Warehouse_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Warehouse",
	HandlerType: (*WarehouseServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetHealth",
			Handler:    _Warehouse_GetHealth_Handler,
		},
		{
			MethodName: "GetWHUploads",
			Handler:    _Warehouse_GetWHUploads_Handler,
		},
		{
			MethodName: "GetWHUpload",
			Handler:    _Warehouse_GetWHUpload_Handler,
		},
		{
			MethodName: "TriggerWHUpload",
			Handler:    _Warehouse_TriggerWHUpload_Handler,
		},
		{
			MethodName: "TriggerWHUploads",
			Handler:    _Warehouse_TriggerWHUploads_Handler,
		},
		{
			MethodName: "Validate",
			Handler:    _Warehouse_Validate_Handler,
		},
		{
			MethodName: "RetryWHUploads",
			Handler:    _Warehouse_RetryWHUploads_Handler,
		},
		{
			MethodName: "ValidateObjectStorageDestination",
			Handler:    _Warehouse_ValidateObjectStorageDestination_Handler,
		},
		{
			MethodName: "CountWHUploadsToRetry",
			Handler:    _Warehouse_CountWHUploadsToRetry_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/warehouse/warehouse.proto",
}

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

Functions

func RegisterWarehouseServer

func RegisterWarehouseServer(s grpc.ServiceRegistrar, srv WarehouseServer)

Types

type Pagination

type Pagination struct {
	Total  int32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Limit  int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset int32 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*Pagination) Descriptor deprecated

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

Deprecated: Use Pagination.ProtoReflect.Descriptor instead.

func (*Pagination) GetLimit

func (x *Pagination) GetLimit() int32

func (*Pagination) GetOffset

func (x *Pagination) GetOffset() int32

func (*Pagination) GetTotal

func (x *Pagination) GetTotal() int32

func (*Pagination) ProtoMessage

func (*Pagination) ProtoMessage()

func (*Pagination) ProtoReflect

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

func (*Pagination) Reset

func (x *Pagination) Reset()

func (*Pagination) String

func (x *Pagination) String() string

type RetryWHUploadsRequest

type RetryWHUploadsRequest struct {
	WorkspaceId     string  `protobuf:"bytes,1,opt,name=workspaceId,proto3" json:"workspaceId,omitempty"`
	SourceId        string  `protobuf:"bytes,2,opt,name=sourceId,proto3" json:"sourceId,omitempty"`
	DestinationId   string  `protobuf:"bytes,3,opt,name=destinationId,proto3" json:"destinationId,omitempty"`
	DestinationType string  `protobuf:"bytes,4,opt,name=destinationType,proto3" json:"destinationType,omitempty"`
	IntervalInHours int64   `protobuf:"varint,5,opt,name=intervalInHours,proto3" json:"intervalInHours,omitempty"`
	UploadIds       []int64 `protobuf:"varint,6,rep,packed,name=uploadIds,proto3" json:"uploadIds,omitempty"`
	ForceRetry      bool    `protobuf:"varint,7,opt,name=forceRetry,proto3" json:"forceRetry,omitempty"`
	// contains filtered or unexported fields
}

func (*RetryWHUploadsRequest) Descriptor deprecated

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

Deprecated: Use RetryWHUploadsRequest.ProtoReflect.Descriptor instead.

func (*RetryWHUploadsRequest) GetDestinationId

func (x *RetryWHUploadsRequest) GetDestinationId() string

func (*RetryWHUploadsRequest) GetDestinationType

func (x *RetryWHUploadsRequest) GetDestinationType() string

func (*RetryWHUploadsRequest) GetForceRetry

func (x *RetryWHUploadsRequest) GetForceRetry() bool

func (*RetryWHUploadsRequest) GetIntervalInHours

func (x *RetryWHUploadsRequest) GetIntervalInHours() int64

func (*RetryWHUploadsRequest) GetSourceId

func (x *RetryWHUploadsRequest) GetSourceId() string

func (*RetryWHUploadsRequest) GetUploadIds

func (x *RetryWHUploadsRequest) GetUploadIds() []int64

func (*RetryWHUploadsRequest) GetWorkspaceId

func (x *RetryWHUploadsRequest) GetWorkspaceId() string

func (*RetryWHUploadsRequest) ProtoMessage

func (*RetryWHUploadsRequest) ProtoMessage()

func (*RetryWHUploadsRequest) ProtoReflect

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

func (*RetryWHUploadsRequest) Reset

func (x *RetryWHUploadsRequest) Reset()

func (*RetryWHUploadsRequest) String

func (x *RetryWHUploadsRequest) String() string

type RetryWHUploadsResponse

type RetryWHUploadsResponse struct {
	Message    string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Count      int64  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	StatusCode int32  `protobuf:"varint,3,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	// contains filtered or unexported fields
}

func (*RetryWHUploadsResponse) Descriptor deprecated

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

Deprecated: Use RetryWHUploadsResponse.ProtoReflect.Descriptor instead.

func (*RetryWHUploadsResponse) GetCount added in v1.2.0

func (x *RetryWHUploadsResponse) GetCount() int64

func (*RetryWHUploadsResponse) GetMessage

func (x *RetryWHUploadsResponse) GetMessage() string

func (*RetryWHUploadsResponse) GetStatusCode

func (x *RetryWHUploadsResponse) GetStatusCode() int32

func (*RetryWHUploadsResponse) ProtoMessage

func (*RetryWHUploadsResponse) ProtoMessage()

func (*RetryWHUploadsResponse) ProtoReflect

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

func (*RetryWHUploadsResponse) Reset

func (x *RetryWHUploadsResponse) Reset()

func (*RetryWHUploadsResponse) String

func (x *RetryWHUploadsResponse) String() string

type TriggerWhUploadsResponse

type TriggerWhUploadsResponse struct {
	Message    string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	StatusCode int32  `protobuf:"varint,2,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerWhUploadsResponse) Descriptor deprecated

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

Deprecated: Use TriggerWhUploadsResponse.ProtoReflect.Descriptor instead.

func (*TriggerWhUploadsResponse) GetMessage

func (x *TriggerWhUploadsResponse) GetMessage() string

func (*TriggerWhUploadsResponse) GetStatusCode

func (x *TriggerWhUploadsResponse) GetStatusCode() int32

func (*TriggerWhUploadsResponse) ProtoMessage

func (*TriggerWhUploadsResponse) ProtoMessage()

func (*TriggerWhUploadsResponse) ProtoReflect

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

func (*TriggerWhUploadsResponse) Reset

func (x *TriggerWhUploadsResponse) Reset()

func (*TriggerWhUploadsResponse) String

func (x *TriggerWhUploadsResponse) String() string

type UnimplementedWarehouseServer

type UnimplementedWarehouseServer struct {
}

UnimplementedWarehouseServer must be embedded to have forward compatible implementations.

func (UnimplementedWarehouseServer) CountWHUploadsToRetry added in v1.2.0

func (UnimplementedWarehouseServer) GetHealth

func (UnimplementedWarehouseServer) GetWHUpload

func (UnimplementedWarehouseServer) GetWHUploads

func (UnimplementedWarehouseServer) RetryWHUploads

func (UnimplementedWarehouseServer) TriggerWHUpload

func (UnimplementedWarehouseServer) TriggerWHUploads

func (UnimplementedWarehouseServer) Validate

func (UnimplementedWarehouseServer) ValidateObjectStorageDestination added in v1.2.0

type UnsafeWarehouseServer

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

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

type ValidateObjectStorageRequest added in v1.2.0

type ValidateObjectStorageRequest struct {
	Type   string           `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Config *structpb.Struct `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateObjectStorageRequest) Descriptor deprecated added in v1.2.0

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

Deprecated: Use ValidateObjectStorageRequest.ProtoReflect.Descriptor instead.

func (*ValidateObjectStorageRequest) GetConfig added in v1.2.0

func (*ValidateObjectStorageRequest) GetType added in v1.2.0

func (x *ValidateObjectStorageRequest) GetType() string

func (*ValidateObjectStorageRequest) ProtoMessage added in v1.2.0

func (*ValidateObjectStorageRequest) ProtoMessage()

func (*ValidateObjectStorageRequest) ProtoReflect added in v1.2.0

func (*ValidateObjectStorageRequest) Reset added in v1.2.0

func (x *ValidateObjectStorageRequest) Reset()

func (*ValidateObjectStorageRequest) String added in v1.2.0

type ValidateObjectStorageResponse added in v1.2.0

type ValidateObjectStorageResponse struct {
	IsValid bool   `protobuf:"varint,2,opt,name=isValid,proto3" json:"isValid,omitempty"`
	Error   string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateObjectStorageResponse) Descriptor deprecated added in v1.2.0

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

Deprecated: Use ValidateObjectStorageResponse.ProtoReflect.Descriptor instead.

func (*ValidateObjectStorageResponse) GetError added in v1.2.0

func (x *ValidateObjectStorageResponse) GetError() string

func (*ValidateObjectStorageResponse) GetIsValid added in v1.2.0

func (x *ValidateObjectStorageResponse) GetIsValid() bool

func (*ValidateObjectStorageResponse) ProtoMessage added in v1.2.0

func (*ValidateObjectStorageResponse) ProtoMessage()

func (*ValidateObjectStorageResponse) ProtoReflect added in v1.2.0

func (*ValidateObjectStorageResponse) Reset added in v1.2.0

func (x *ValidateObjectStorageResponse) Reset()

func (*ValidateObjectStorageResponse) String added in v1.2.0

type WHTable

type WHTable struct {
	Id         int64                  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UploadId   int64                  `protobuf:"varint,2,opt,name=upload_id,json=uploadId,proto3" json:"upload_id,omitempty"`
	Name       string                 `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Status     string                 `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	Error      string                 `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	LastExecAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=last_exec_at,json=lastExecAt,proto3" json:"last_exec_at,omitempty"`
	Count      int32                  `protobuf:"varint,7,opt,name=count,proto3" json:"count,omitempty"`
	Duration   int32                  `protobuf:"varint,8,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

func (*WHTable) Descriptor deprecated

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

Deprecated: Use WHTable.ProtoReflect.Descriptor instead.

func (*WHTable) GetCount

func (x *WHTable) GetCount() int32

func (*WHTable) GetDuration

func (x *WHTable) GetDuration() int32

func (*WHTable) GetError

func (x *WHTable) GetError() string

func (*WHTable) GetId

func (x *WHTable) GetId() int64

func (*WHTable) GetLastExecAt

func (x *WHTable) GetLastExecAt() *timestamppb.Timestamp

func (*WHTable) GetName

func (x *WHTable) GetName() string

func (*WHTable) GetStatus

func (x *WHTable) GetStatus() string

func (*WHTable) GetUploadId

func (x *WHTable) GetUploadId() int64

func (*WHTable) ProtoMessage

func (*WHTable) ProtoMessage()

func (*WHTable) ProtoReflect

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

func (*WHTable) Reset

func (x *WHTable) Reset()

func (*WHTable) String

func (x *WHTable) String() string

type WHUploadRequest

type WHUploadRequest struct {
	UploadId    int64  `protobuf:"varint,1,opt,name=upload_id,json=uploadId,proto3" json:"upload_id,omitempty"`
	WorkspaceId string `protobuf:"bytes,2,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WHUploadRequest) Descriptor deprecated

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

Deprecated: Use WHUploadRequest.ProtoReflect.Descriptor instead.

func (*WHUploadRequest) GetUploadId

func (x *WHUploadRequest) GetUploadId() int64

func (*WHUploadRequest) GetWorkspaceId

func (x *WHUploadRequest) GetWorkspaceId() string

func (*WHUploadRequest) ProtoMessage

func (*WHUploadRequest) ProtoMessage()

func (*WHUploadRequest) ProtoReflect

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

func (*WHUploadRequest) Reset

func (x *WHUploadRequest) Reset()

func (*WHUploadRequest) String

func (x *WHUploadRequest) String() string

type WHUploadResponse

type WHUploadResponse struct {
	Id               int64                  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	SourceId         string                 `protobuf:"bytes,2,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	DestinationId    string                 `protobuf:"bytes,3,opt,name=destination_id,json=destinationId,proto3" json:"destination_id,omitempty"`
	DestinationType  string                 `protobuf:"bytes,4,opt,name=destination_type,json=destinationType,proto3" json:"destination_type,omitempty"`
	Namespace        string                 `protobuf:"bytes,5,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Error            string                 `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	Attempt          int32                  `protobuf:"varint,7,opt,name=attempt,proto3" json:"attempt,omitempty"`
	Status           string                 `protobuf:"bytes,8,opt,name=status,proto3" json:"status,omitempty"`
	CreatedAt        *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	FirstEventAt     *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=first_event_at,json=firstEventAt,proto3" json:"first_event_at,omitempty"`
	LastEventAt      *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=last_event_at,json=lastEventAt,proto3" json:"last_event_at,omitempty"`
	LastExecAt       *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=last_exec_at,json=lastExecAt,proto3" json:"last_exec_at,omitempty"`
	NextRetryTime    *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=next_retry_time,json=nextRetryTime,proto3" json:"next_retry_time,omitempty"`
	Duration         int32                  `protobuf:"varint,14,opt,name=duration,proto3" json:"duration,omitempty"`
	Tables           []*WHTable             `protobuf:"bytes,15,rep,name=tables,proto3" json:"tables,omitempty"`
	IsArchivedUpload bool                   `protobuf:"varint,16,opt,name=isArchivedUpload,proto3" json:"isArchivedUpload,omitempty"`
	// contains filtered or unexported fields
}

func (*WHUploadResponse) Descriptor deprecated

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

Deprecated: Use WHUploadResponse.ProtoReflect.Descriptor instead.

func (*WHUploadResponse) GetAttempt

func (x *WHUploadResponse) GetAttempt() int32

func (*WHUploadResponse) GetCreatedAt

func (x *WHUploadResponse) GetCreatedAt() *timestamppb.Timestamp

func (*WHUploadResponse) GetDestinationId

func (x *WHUploadResponse) GetDestinationId() string

func (*WHUploadResponse) GetDestinationType

func (x *WHUploadResponse) GetDestinationType() string

func (*WHUploadResponse) GetDuration

func (x *WHUploadResponse) GetDuration() int32

func (*WHUploadResponse) GetError

func (x *WHUploadResponse) GetError() string

func (*WHUploadResponse) GetFirstEventAt

func (x *WHUploadResponse) GetFirstEventAt() *timestamppb.Timestamp

func (*WHUploadResponse) GetId

func (x *WHUploadResponse) GetId() int64

func (*WHUploadResponse) GetIsArchivedUpload

func (x *WHUploadResponse) GetIsArchivedUpload() bool

func (*WHUploadResponse) GetLastEventAt

func (x *WHUploadResponse) GetLastEventAt() *timestamppb.Timestamp

func (*WHUploadResponse) GetLastExecAt

func (x *WHUploadResponse) GetLastExecAt() *timestamppb.Timestamp

func (*WHUploadResponse) GetNamespace

func (x *WHUploadResponse) GetNamespace() string

func (*WHUploadResponse) GetNextRetryTime

func (x *WHUploadResponse) GetNextRetryTime() *timestamppb.Timestamp

func (*WHUploadResponse) GetSourceId

func (x *WHUploadResponse) GetSourceId() string

func (*WHUploadResponse) GetStatus

func (x *WHUploadResponse) GetStatus() string

func (*WHUploadResponse) GetTables

func (x *WHUploadResponse) GetTables() []*WHTable

func (*WHUploadResponse) ProtoMessage

func (*WHUploadResponse) ProtoMessage()

func (*WHUploadResponse) ProtoReflect

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

func (*WHUploadResponse) Reset

func (x *WHUploadResponse) Reset()

func (*WHUploadResponse) String

func (x *WHUploadResponse) String() string

type WHUploadsRequest

type WHUploadsRequest struct {
	SourceId        string `protobuf:"bytes,1,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	DestinationId   string `protobuf:"bytes,2,opt,name=destination_id,json=destinationId,proto3" json:"destination_id,omitempty"`
	DestinationType string `protobuf:"bytes,3,opt,name=destination_type,json=destinationType,proto3" json:"destination_type,omitempty"`
	Status          string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	Limit           int32  `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset          int32  `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"`
	WorkspaceId     string `protobuf:"bytes,7,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WHUploadsRequest) Descriptor deprecated

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

Deprecated: Use WHUploadsRequest.ProtoReflect.Descriptor instead.

func (*WHUploadsRequest) GetDestinationId

func (x *WHUploadsRequest) GetDestinationId() string

func (*WHUploadsRequest) GetDestinationType

func (x *WHUploadsRequest) GetDestinationType() string

func (*WHUploadsRequest) GetLimit

func (x *WHUploadsRequest) GetLimit() int32

func (*WHUploadsRequest) GetOffset

func (x *WHUploadsRequest) GetOffset() int32

func (*WHUploadsRequest) GetSourceId

func (x *WHUploadsRequest) GetSourceId() string

func (*WHUploadsRequest) GetStatus

func (x *WHUploadsRequest) GetStatus() string

func (*WHUploadsRequest) GetWorkspaceId

func (x *WHUploadsRequest) GetWorkspaceId() string

func (*WHUploadsRequest) ProtoMessage

func (*WHUploadsRequest) ProtoMessage()

func (*WHUploadsRequest) ProtoReflect

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

func (*WHUploadsRequest) Reset

func (x *WHUploadsRequest) Reset()

func (*WHUploadsRequest) String

func (x *WHUploadsRequest) String() string

type WHUploadsResponse

type WHUploadsResponse struct {
	Uploads    []*WHUploadResponse `protobuf:"bytes,1,rep,name=uploads,proto3" json:"uploads,omitempty"`
	Pagination *Pagination         `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

func (*WHUploadsResponse) Descriptor deprecated

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

Deprecated: Use WHUploadsResponse.ProtoReflect.Descriptor instead.

func (*WHUploadsResponse) GetPagination

func (x *WHUploadsResponse) GetPagination() *Pagination

func (*WHUploadsResponse) GetUploads

func (x *WHUploadsResponse) GetUploads() []*WHUploadResponse

func (*WHUploadsResponse) ProtoMessage

func (*WHUploadsResponse) ProtoMessage()

func (*WHUploadsResponse) ProtoReflect

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

func (*WHUploadsResponse) Reset

func (x *WHUploadsResponse) Reset()

func (*WHUploadsResponse) String

func (x *WHUploadsResponse) String() string

type WHValidationRequest

type WHValidationRequest struct {
	Role string `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Step string `protobuf:"bytes,3,opt,name=step,proto3" json:"step,omitempty"`
	Body string `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*WHValidationRequest) Descriptor deprecated

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

Deprecated: Use WHValidationRequest.ProtoReflect.Descriptor instead.

func (*WHValidationRequest) GetBody

func (x *WHValidationRequest) GetBody() string

func (*WHValidationRequest) GetPath

func (x *WHValidationRequest) GetPath() string

func (*WHValidationRequest) GetRole

func (x *WHValidationRequest) GetRole() string

func (*WHValidationRequest) GetStep

func (x *WHValidationRequest) GetStep() string

func (*WHValidationRequest) ProtoMessage

func (*WHValidationRequest) ProtoMessage()

func (*WHValidationRequest) ProtoReflect

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

func (*WHValidationRequest) Reset

func (x *WHValidationRequest) Reset()

func (*WHValidationRequest) String

func (x *WHValidationRequest) String() string

type WHValidationResponse

type WHValidationResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Data  string `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*WHValidationResponse) Descriptor deprecated

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

Deprecated: Use WHValidationResponse.ProtoReflect.Descriptor instead.

func (*WHValidationResponse) GetData

func (x *WHValidationResponse) GetData() string

func (*WHValidationResponse) GetError

func (x *WHValidationResponse) GetError() string

func (*WHValidationResponse) ProtoMessage

func (*WHValidationResponse) ProtoMessage()

func (*WHValidationResponse) ProtoReflect

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

func (*WHValidationResponse) Reset

func (x *WHValidationResponse) Reset()

func (*WHValidationResponse) String

func (x *WHValidationResponse) String() string

type WarehouseClient

type WarehouseClient interface {
	GetHealth(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)
	GetWHUploads(ctx context.Context, in *WHUploadsRequest, opts ...grpc.CallOption) (*WHUploadsResponse, error)
	GetWHUpload(ctx context.Context, in *WHUploadRequest, opts ...grpc.CallOption) (*WHUploadResponse, error)
	TriggerWHUpload(ctx context.Context, in *WHUploadRequest, opts ...grpc.CallOption) (*TriggerWhUploadsResponse, error)
	TriggerWHUploads(ctx context.Context, in *WHUploadsRequest, opts ...grpc.CallOption) (*TriggerWhUploadsResponse, error)
	Validate(ctx context.Context, in *WHValidationRequest, opts ...grpc.CallOption) (*WHValidationResponse, error)
	RetryWHUploads(ctx context.Context, in *RetryWHUploadsRequest, opts ...grpc.CallOption) (*RetryWHUploadsResponse, error)
	ValidateObjectStorageDestination(ctx context.Context, in *ValidateObjectStorageRequest, opts ...grpc.CallOption) (*ValidateObjectStorageResponse, error)
	CountWHUploadsToRetry(ctx context.Context, in *RetryWHUploadsRequest, opts ...grpc.CallOption) (*RetryWHUploadsResponse, error)
}

WarehouseClient is the client API for Warehouse 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 NewWarehouseClient

func NewWarehouseClient(cc grpc.ClientConnInterface) WarehouseClient

type WarehouseServer

WarehouseServer is the server API for Warehouse service. All implementations must embed UnimplementedWarehouseServer for forward compatibility

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL