proto

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Oct 14, 2021 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,
		},
	},
	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 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) TriggerWHUpload 

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

func (UnimplementedWarehouseServer) TriggerWHUploads 

func (UnimplementedWarehouseServer) TriggerWHUploads(context.Context, *WHUploadsRequest) (*emptypb.Empty, 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 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) (*emptypb.Empty, error)
	TriggerWHUploads(ctx context.Context, in *WHUploadsRequest, opts ...grpc.CallOption) (*emptypb.Empty, 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) (*emptypb.Empty, error)
	TriggerWHUploads(context.Context, *WHUploadsRequest) (*emptypb.Empty, 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.