api

package
v0.0.0-...-67bf82f Latest Latest
Warning

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

 Go to latest Published: Jul 4, 2020 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ReadCsvFileTaskStatus_Status_name = map[int32]string{
		0: "OK",
		1: "ERROR",
	}
	ReadCsvFileTaskStatus_Status_value = map[string]int32{
		"OK":    0,
		"ERROR": 1,
	}
)

Enum value maps for ReadCsvFileTaskStatus_Status.

View Source 
var File_api_controller_proto protoreflect.FileDescriptor

Functions

func RegisterControllerServer 

func RegisterControllerServer(s *grpc.Server, srv ControllerServer)

Types

type ControllerClient 

type ControllerClient interface {
	GetReadCsvFileTask(ctx context.Context, in *WorkerInfo, opts ...grpc.CallOption) (*ReadCsvFileTaskRequest, error)
	ReadCsvFileResult(ctx context.Context, in *ReadCsvFileTaskResult, opts ...grpc.CallOption) (*ReadCsvFileTaskStatus, error)
}

ControllerClient is the client API for Controller service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewControllerClient 

func NewControllerClient(cc grpc.ClientConnInterface) ControllerClient

type ControllerServer 

type ControllerServer interface {
	GetReadCsvFileTask(context.Context, *WorkerInfo) (*ReadCsvFileTaskRequest, error)
	ReadCsvFileResult(context.Context, *ReadCsvFileTaskResult) (*ReadCsvFileTaskStatus, error)
}

ControllerServer is the server API for Controller service.

type ReadCsvFileTaskRequest 

type ReadCsvFileTaskRequest struct {
	TaskId      string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	FilePath    string `protobuf:"bytes,2,opt,name=file_path,json=filePath,proto3" json:"file_path,omitempty"`
	FilePattern string `protobuf:"bytes,3,opt,name=file_pattern,json=filePattern,proto3" json:"file_pattern,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadCsvFileTaskRequest) Descriptor deprecated 

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

Deprecated: Use ReadCsvFileTaskRequest.ProtoReflect.Descriptor instead.

func (*ReadCsvFileTaskRequest) GetFilePath 

func (x *ReadCsvFileTaskRequest) GetFilePath() string

func (*ReadCsvFileTaskRequest) GetFilePattern 

func (x *ReadCsvFileTaskRequest) GetFilePattern() string

func (*ReadCsvFileTaskRequest) GetTaskId 

func (x *ReadCsvFileTaskRequest) GetTaskId() string

func (*ReadCsvFileTaskRequest) ProtoMessage 

func (*ReadCsvFileTaskRequest) ProtoMessage()

func (*ReadCsvFileTaskRequest) ProtoReflect 

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

func (*ReadCsvFileTaskRequest) Reset 

func (x *ReadCsvFileTaskRequest) Reset()

func (*ReadCsvFileTaskRequest) String 

func (x *ReadCsvFileTaskRequest) String() string

type ReadCsvFileTaskResult 

type ReadCsvFileTaskResult struct {
	TaskId   string                            `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Filename string                            `protobuf:"bytes,2,opt,name=filename,proto3" json:"filename,omitempty"`
	Lines    *ReadCsvFileTaskResult_LineResult `protobuf:"bytes,3,opt,name=lines,proto3" json:"lines,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadCsvFileTaskResult) Descriptor deprecated 

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

Deprecated: Use ReadCsvFileTaskResult.ProtoReflect.Descriptor instead.

func (*ReadCsvFileTaskResult) GetFilename 

func (x *ReadCsvFileTaskResult) GetFilename() string

func (*ReadCsvFileTaskResult) GetLines 

func (x *ReadCsvFileTaskResult) GetLines() *ReadCsvFileTaskResult_LineResult

func (*ReadCsvFileTaskResult) GetTaskId 

func (x *ReadCsvFileTaskResult) GetTaskId() string

func (*ReadCsvFileTaskResult) ProtoMessage 

func (*ReadCsvFileTaskResult) ProtoMessage()

func (*ReadCsvFileTaskResult) ProtoReflect 

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

func (*ReadCsvFileTaskResult) Reset 

func (x *ReadCsvFileTaskResult) Reset()

func (*ReadCsvFileTaskResult) String 

func (x *ReadCsvFileTaskResult) String() string

type ReadCsvFileTaskResult_LineResult 

type ReadCsvFileTaskResult_LineResult struct {
	Columns map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ReadCsvFileTaskResult_LineResult) Descriptor deprecated 

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

Deprecated: Use ReadCsvFileTaskResult_LineResult.ProtoReflect.Descriptor instead.

func (*ReadCsvFileTaskResult_LineResult) GetColumns 

func (x *ReadCsvFileTaskResult_LineResult) GetColumns() map[string]string

func (*ReadCsvFileTaskResult_LineResult) ProtoMessage 

func (*ReadCsvFileTaskResult_LineResult) ProtoMessage()

func (*ReadCsvFileTaskResult_LineResult) ProtoReflect 

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

func (*ReadCsvFileTaskResult_LineResult) Reset 

func (x *ReadCsvFileTaskResult_LineResult) Reset()

func (*ReadCsvFileTaskResult_LineResult) String 

func (x *ReadCsvFileTaskResult_LineResult) String() string

type ReadCsvFileTaskStatus 

type ReadCsvFileTaskStatus struct {
	Status ReadCsvFileTaskStatus_Status `protobuf:"varint,1,opt,name=status,proto3,enum=api.ReadCsvFileTaskStatus_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadCsvFileTaskStatus) Descriptor deprecated 

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

Deprecated: Use ReadCsvFileTaskStatus.ProtoReflect.Descriptor instead.

func (*ReadCsvFileTaskStatus) GetStatus 

func (x *ReadCsvFileTaskStatus) GetStatus() ReadCsvFileTaskStatus_Status

func (*ReadCsvFileTaskStatus) ProtoMessage 

func (*ReadCsvFileTaskStatus) ProtoMessage()

func (*ReadCsvFileTaskStatus) ProtoReflect 

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

func (*ReadCsvFileTaskStatus) Reset 

func (x *ReadCsvFileTaskStatus) Reset()

func (*ReadCsvFileTaskStatus) String 

func (x *ReadCsvFileTaskStatus) String() string

type ReadCsvFileTaskStatus_Status 

type ReadCsvFileTaskStatus_Status int32
const (
	ReadCsvFileTaskStatus_OK    ReadCsvFileTaskStatus_Status = 0
	ReadCsvFileTaskStatus_ERROR ReadCsvFileTaskStatus_Status = 1
)

func (ReadCsvFileTaskStatus_Status) Descriptor 

func (ReadCsvFileTaskStatus_Status) Descriptor() protoreflect.EnumDescriptor

func (ReadCsvFileTaskStatus_Status) Enum 

func (x ReadCsvFileTaskStatus_Status) Enum() *ReadCsvFileTaskStatus_Status

func (ReadCsvFileTaskStatus_Status) EnumDescriptor deprecated 

func (ReadCsvFileTaskStatus_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use ReadCsvFileTaskStatus_Status.Descriptor instead.

func (ReadCsvFileTaskStatus_Status) Number 

func (x ReadCsvFileTaskStatus_Status) Number() protoreflect.EnumNumber

func (ReadCsvFileTaskStatus_Status) String 

func (x ReadCsvFileTaskStatus_Status) String() string

func (ReadCsvFileTaskStatus_Status) Type 

func (ReadCsvFileTaskStatus_Status) Type() protoreflect.EnumType

type UnimplementedControllerServer 

type UnimplementedControllerServer struct {
}

UnimplementedControllerServer can be embedded to have forward compatible implementations.

func (*UnimplementedControllerServer) GetReadCsvFileTask 

func (*UnimplementedControllerServer) GetReadCsvFileTask(context.Context, *WorkerInfo) (*ReadCsvFileTaskRequest, error)

func (*UnimplementedControllerServer) ReadCsvFileResult 

func (*UnimplementedControllerServer) ReadCsvFileResult(context.Context, *ReadCsvFileTaskResult) (*ReadCsvFileTaskStatus, error)

type WorkerInfo 

type WorkerInfo struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerInfo) Descriptor deprecated 

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

Deprecated: Use WorkerInfo.ProtoReflect.Descriptor instead.

func (*WorkerInfo) GetName 

func (x *WorkerInfo) GetName() string

func (*WorkerInfo) ProtoMessage 

func (*WorkerInfo) ProtoMessage()

func (*WorkerInfo) ProtoReflect 

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

func (*WorkerInfo) Reset 

func (x *WorkerInfo) Reset()

func (*WorkerInfo) String 

func (x *WorkerInfo) String() string

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.