Documentation
¶
Overview ¶
Package pb is a generated protocol buffer package.
It is generated from these files:
watermarksvc.proto
It has these top-level messages:
Document GetRequest GetReply StatusRequest StatusReply WatermarkRequest WatermarkReply AddDocumentRequest AddDocumentReply ServiceStatusRequest ServiceStatusReply
Index ¶
- Variables
- func RegisterWatermarkServer(s *grpc.Server, srv WatermarkServer)
- type AddDocumentReply
- type AddDocumentRequest
- type Document
- func (*Document) Descriptor() ([]byte, []int)
- func (m *Document) GetAuthor() string
- func (m *Document) GetContent() string
- func (m *Document) GetTitle() string
- func (m *Document) GetTopic() string
- func (m *Document) GetWatermark() string
- func (*Document) ProtoMessage()
- func (m *Document) Reset()
- func (m *Document) String() string
- type GetReply
- type GetRequest
- type GetRequest_Filters
- type ServiceStatusReply
- type ServiceStatusRequest
- type StatusReply
- type StatusReply_Status
- type StatusRequest
- type WatermarkClient
- type WatermarkReply
- type WatermarkRequest
- type WatermarkServer
Constants ¶
This section is empty.
Variables ¶
View Source
var StatusReply_Status_name = map[int32]string{
0: "PENDING",
1: "STARTED",
2: "IN_PROGRESS",
3: "FINISHED",
4: "FAILED",
}
View Source
var StatusReply_Status_value = map[string]int32{
"PENDING": 0,
"STARTED": 1,
"IN_PROGRESS": 2,
"FINISHED": 3,
"FAILED": 4,
}
Functions ¶
func RegisterWatermarkServer ¶
func RegisterWatermarkServer(s *grpc.Server, srv WatermarkServer)
Types ¶
type AddDocumentReply ¶
type AddDocumentReply struct {
TicketID string `protobuf:"bytes,1,opt,name=ticketID" json:"ticketID,omitempty"`
Err string `protobuf:"bytes,2,opt,name=err" json:"err,omitempty"`
}
func (*AddDocumentReply) Descriptor ¶
func (*AddDocumentReply) Descriptor() ([]byte, []int)
func (*AddDocumentReply) GetErr ¶
func (m *AddDocumentReply) GetErr() string
func (*AddDocumentReply) GetTicketID ¶
func (m *AddDocumentReply) GetTicketID() string
func (*AddDocumentReply) ProtoMessage ¶
func (*AddDocumentReply) ProtoMessage()
func (*AddDocumentReply) Reset ¶
func (m *AddDocumentReply) Reset()
func (*AddDocumentReply) String ¶
func (m *AddDocumentReply) String() string
type AddDocumentRequest ¶
type AddDocumentRequest struct {
Document *Document `protobuf:"bytes,1,opt,name=document" json:"document,omitempty"`
}
func (*AddDocumentRequest) Descriptor ¶
func (*AddDocumentRequest) Descriptor() ([]byte, []int)
func (*AddDocumentRequest) GetDocument ¶
func (m *AddDocumentRequest) GetDocument() *Document
func (*AddDocumentRequest) ProtoMessage ¶
func (*AddDocumentRequest) ProtoMessage()
func (*AddDocumentRequest) Reset ¶
func (m *AddDocumentRequest) Reset()
func (*AddDocumentRequest) String ¶
func (m *AddDocumentRequest) String() string
type Document ¶
type Document struct {
Content string `protobuf:"bytes,1,opt,name=content" json:"content,omitempty"`
Title string `protobuf:"bytes,2,opt,name=title" json:"title,omitempty"`
Author string `protobuf:"bytes,3,opt,name=author" json:"author,omitempty"`
Topic string `protobuf:"bytes,4,opt,name=topic" json:"topic,omitempty"`
Watermark string `protobuf:"bytes,5,opt,name=watermark" json:"watermark,omitempty"`
}
func (*Document) Descriptor ¶
func (*Document) GetContent ¶
func (*Document) GetWatermark ¶
func (*Document) ProtoMessage ¶
func (*Document) ProtoMessage()
type GetReply ¶
type GetReply struct {
Documents []*Document `protobuf:"bytes,1,rep,name=documents" json:"documents,omitempty"`
Err string `protobuf:"bytes,2,opt,name=Err,json=err" json:"Err,omitempty"`
}
func (*GetReply) Descriptor ¶
func (*GetReply) GetDocuments ¶
func (*GetReply) ProtoMessage ¶
func (*GetReply) ProtoMessage()
type GetRequest ¶
type GetRequest struct {
Filters []*GetRequest_Filters `protobuf:"bytes,1,rep,name=filters" json:"filters,omitempty"`
}
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) GetFilters ¶
func (m *GetRequest) GetFilters() []*GetRequest_Filters
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset ¶
func (m *GetRequest) Reset()
func (*GetRequest) String ¶
func (m *GetRequest) String() string
type GetRequest_Filters ¶
type GetRequest_Filters struct {
Key string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
Value string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
}
func (*GetRequest_Filters) Descriptor ¶
func (*GetRequest_Filters) Descriptor() ([]byte, []int)
func (*GetRequest_Filters) GetKey ¶
func (m *GetRequest_Filters) GetKey() string
func (*GetRequest_Filters) GetValue ¶
func (m *GetRequest_Filters) GetValue() string
func (*GetRequest_Filters) ProtoMessage ¶
func (*GetRequest_Filters) ProtoMessage()
func (*GetRequest_Filters) Reset ¶
func (m *GetRequest_Filters) Reset()
func (*GetRequest_Filters) String ¶
func (m *GetRequest_Filters) String() string
type ServiceStatusReply ¶
type ServiceStatusReply struct {
Code int64 `protobuf:"varint,1,opt,name=code" json:"code,omitempty"`
Err string `protobuf:"bytes,2,opt,name=err" json:"err,omitempty"`
}
func (*ServiceStatusReply) Descriptor ¶
func (*ServiceStatusReply) Descriptor() ([]byte, []int)
func (*ServiceStatusReply) GetCode ¶
func (m *ServiceStatusReply) GetCode() int64
func (*ServiceStatusReply) GetErr ¶
func (m *ServiceStatusReply) GetErr() string
func (*ServiceStatusReply) ProtoMessage ¶
func (*ServiceStatusReply) ProtoMessage()
func (*ServiceStatusReply) Reset ¶
func (m *ServiceStatusReply) Reset()
func (*ServiceStatusReply) String ¶
func (m *ServiceStatusReply) String() string
type ServiceStatusRequest ¶
type ServiceStatusRequest struct {
}
func (*ServiceStatusRequest) Descriptor ¶
func (*ServiceStatusRequest) Descriptor() ([]byte, []int)
func (*ServiceStatusRequest) ProtoMessage ¶
func (*ServiceStatusRequest) ProtoMessage()
func (*ServiceStatusRequest) Reset ¶
func (m *ServiceStatusRequest) Reset()
func (*ServiceStatusRequest) String ¶
func (m *ServiceStatusRequest) String() string
type StatusReply ¶
type StatusReply struct {
Status StatusReply_Status `protobuf:"varint,1,opt,name=status,enum=pb.StatusReply_Status" json:"status,omitempty"`
Err string `protobuf:"bytes,2,opt,name=Err,json=err" json:"Err,omitempty"`
}
func (*StatusReply) Descriptor ¶
func (*StatusReply) Descriptor() ([]byte, []int)
func (*StatusReply) GetErr ¶
func (m *StatusReply) GetErr() string
func (*StatusReply) GetStatus ¶
func (m *StatusReply) GetStatus() StatusReply_Status
func (*StatusReply) ProtoMessage ¶
func (*StatusReply) ProtoMessage()
func (*StatusReply) Reset ¶
func (m *StatusReply) Reset()
func (*StatusReply) String ¶
func (m *StatusReply) String() string
type StatusReply_Status ¶
type StatusReply_Status int32
const ( StatusReply_PENDING StatusReply_Status = 0 StatusReply_STARTED StatusReply_Status = 1 StatusReply_IN_PROGRESS StatusReply_Status = 2 StatusReply_FINISHED StatusReply_Status = 3 StatusReply_FAILED StatusReply_Status = 4 )
func (StatusReply_Status) EnumDescriptor ¶
func (StatusReply_Status) EnumDescriptor() ([]byte, []int)
func (StatusReply_Status) String ¶
func (x StatusReply_Status) String() string
type StatusRequest ¶
type StatusRequest struct {
TicketID string `protobuf:"bytes,1,opt,name=ticketID" json:"ticketID,omitempty"`
}
func (*StatusRequest) Descriptor ¶
func (*StatusRequest) Descriptor() ([]byte, []int)
func (*StatusRequest) GetTicketID ¶
func (m *StatusRequest) GetTicketID() string
func (*StatusRequest) ProtoMessage ¶
func (*StatusRequest) ProtoMessage()
func (*StatusRequest) Reset ¶
func (m *StatusRequest) Reset()
func (*StatusRequest) String ¶
func (m *StatusRequest) String() string
type WatermarkClient ¶
type WatermarkClient interface {
Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetReply, error)
Watermark(ctx context.Context, in *WatermarkRequest, opts ...grpc.CallOption) (*WatermarkReply, error)
Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusReply, error)
AddDocument(ctx context.Context, in *AddDocumentRequest, opts ...grpc.CallOption) (*AddDocumentReply, error)
ServiceStatus(ctx context.Context, in *ServiceStatusRequest, opts ...grpc.CallOption) (*ServiceStatusReply, error)
}
func NewWatermarkClient ¶
func NewWatermarkClient(cc *grpc.ClientConn) WatermarkClient
type WatermarkReply ¶
type WatermarkReply struct {
Code int64 `protobuf:"varint,1,opt,name=code" json:"code,omitempty"`
Err string `protobuf:"bytes,2,opt,name=err" json:"err,omitempty"`
}
func (*WatermarkReply) Descriptor ¶
func (*WatermarkReply) Descriptor() ([]byte, []int)
func (*WatermarkReply) GetCode ¶
func (m *WatermarkReply) GetCode() int64
func (*WatermarkReply) GetErr ¶
func (m *WatermarkReply) GetErr() string
func (*WatermarkReply) ProtoMessage ¶
func (*WatermarkReply) ProtoMessage()
func (*WatermarkReply) Reset ¶
func (m *WatermarkReply) Reset()
func (*WatermarkReply) String ¶
func (m *WatermarkReply) String() string
type WatermarkRequest ¶
type WatermarkRequest struct {
TicketID string `protobuf:"bytes,1,opt,name=ticketID" json:"ticketID,omitempty"`
Mark string `protobuf:"bytes,2,opt,name=mark" json:"mark,omitempty"`
}
func (*WatermarkRequest) Descriptor ¶
func (*WatermarkRequest) Descriptor() ([]byte, []int)
func (*WatermarkRequest) GetMark ¶
func (m *WatermarkRequest) GetMark() string
func (*WatermarkRequest) GetTicketID ¶
func (m *WatermarkRequest) GetTicketID() string
func (*WatermarkRequest) ProtoMessage ¶
func (*WatermarkRequest) ProtoMessage()
func (*WatermarkRequest) Reset ¶
func (m *WatermarkRequest) Reset()
func (*WatermarkRequest) String ¶
func (m *WatermarkRequest) String() string
type WatermarkServer ¶
type WatermarkServer interface {
Get(context.Context, *GetRequest) (*GetReply, error)
Watermark(context.Context, *WatermarkRequest) (*WatermarkReply, error)
Status(context.Context, *StatusRequest) (*StatusReply, error)
AddDocument(context.Context, *AddDocumentRequest) (*AddDocumentReply, error)
ServiceStatus(context.Context, *ServiceStatusRequest) (*ServiceStatusReply, error)
}
Source Files
Click to show internal directories.
Click to hide internal directories.