proto

package
v0.0.0-...-0ade494 Latest Latest
Warning

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

 Go to latest Published: Aug 26, 2022 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,
		},
	},
	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"`
	StatusCode int32  `protobuf:"varint,2,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) 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) GetHealth 

func (UnimplementedWarehouseServer) GetHealth(context.Context, *emptypb.Empty) (*wrapperspb.BoolValue, error)

func (UnimplementedWarehouseServer) GetWHUpload 

func (UnimplementedWarehouseServer) GetWHUpload(context.Context, *WHUploadRequest) (*WHUploadResponse, error)

func (UnimplementedWarehouseServer) GetWHUploads 

func (UnimplementedWarehouseServer) GetWHUploads(context.Context, *WHUploadsRequest) (*WHUploadsResponse, error)

func (UnimplementedWarehouseServer) RetryWHUploads 

func (UnimplementedWarehouseServer) RetryWHUploads(context.Context, *RetryWHUploadsRequest) (*RetryWHUploadsResponse, error)

func (UnimplementedWarehouseServer) TriggerWHUpload 

func (UnimplementedWarehouseServer) TriggerWHUpload(context.Context, *WHUploadRequest) (*TriggerWhUploadsResponse, error)

func (UnimplementedWarehouseServer) TriggerWHUploads 

func (UnimplementedWarehouseServer) TriggerWHUploads(context.Context, *WHUploadsRequest) (*TriggerWhUploadsResponse, error)

func (UnimplementedWarehouseServer) Validate 

func (UnimplementedWarehouseServer) Validate(context.Context, *WHValidationRequest) (*WHValidationResponse, error)

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 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)
}

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 

type WarehouseServer interface {
	GetHealth(context.Context, *emptypb.Empty) (*wrapperspb.BoolValue, error)
	GetWHUploads(context.Context, *WHUploadsRequest) (*WHUploadsResponse, error)
	GetWHUpload(context.Context, *WHUploadRequest) (*WHUploadResponse, error)
	TriggerWHUpload(context.Context, *WHUploadRequest) (*TriggerWhUploadsResponse, error)
	TriggerWHUploads(context.Context, *WHUploadsRequest) (*TriggerWhUploadsResponse, error)
	Validate(context.Context, *WHValidationRequest) (*WHValidationResponse, error)
	RetryWHUploads(context.Context, *RetryWHUploadsRequest) (*RetryWHUploadsResponse, error)
	// contains filtered or unexported methods
}

WarehouseServer is the server API for Warehouse service. All implementations must embed UnimplementedWarehouseServer 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.