Documentation
¶
Index ¶
- Variables
- func RegisterScrapingServiceServer(s *grpc.Server, srv ScrapingServiceServer)
- type FuncScrapingServiceServer
- type ReshardRequest
- func (*ReshardRequest) Descriptor() ([]byte, []int)
- func (this *ReshardRequest) Equal(that interface{}) bool
- func (this *ReshardRequest) GoString() string
- func (m *ReshardRequest) Marshal() (dAtA []byte, err error)
- func (m *ReshardRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ReshardRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReshardRequest) ProtoMessage()
- func (m *ReshardRequest) Reset()
- func (m *ReshardRequest) Size() (n int)
- func (this *ReshardRequest) String() string
- func (m *ReshardRequest) Unmarshal(dAtA []byte) error
- func (m *ReshardRequest) XXX_DiscardUnknown()
- func (m *ReshardRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReshardRequest) XXX_Merge(src proto.Message)
- func (m *ReshardRequest) XXX_Size() int
- func (m *ReshardRequest) XXX_Unmarshal(b []byte) error
- type ScrapingServiceClient
- type ScrapingServiceServer
- type UnimplementedScrapingServiceServer
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthAgent = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowAgent = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterScrapingServiceServer ¶
func RegisterScrapingServiceServer(s *grpc.Server, srv ScrapingServiceServer)
Types ¶
type FuncScrapingServiceServer ¶ added in v0.14.0
type FuncScrapingServiceServer struct {
ReshardFunc func(context.Context, *ReshardRequest) (*empty.Empty, error)
}
FuncScrapingServiceServer is an implementation of ScrapingServiceServer that uses function fields to implement the interface. Useful for tests.
func (*FuncScrapingServiceServer) Reshard ¶ added in v0.14.0
func (f *FuncScrapingServiceServer) Reshard(ctx context.Context, req *ReshardRequest) (*empty.Empty, error)
Reshard implements ScrapingServiceServer.
type ReshardRequest ¶
type ReshardRequest struct {
}
func (*ReshardRequest) Descriptor ¶
func (*ReshardRequest) Descriptor() ([]byte, []int)
func (*ReshardRequest) Equal ¶
func (this *ReshardRequest) Equal(that interface{}) bool
func (*ReshardRequest) GoString ¶
func (this *ReshardRequest) GoString() string
func (*ReshardRequest) Marshal ¶
func (m *ReshardRequest) Marshal() (dAtA []byte, err error)
func (*ReshardRequest) MarshalToSizedBuffer ¶
func (m *ReshardRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReshardRequest) ProtoMessage ¶
func (*ReshardRequest) ProtoMessage()
func (*ReshardRequest) Reset ¶
func (m *ReshardRequest) Reset()
func (*ReshardRequest) Size ¶
func (m *ReshardRequest) Size() (n int)
func (*ReshardRequest) String ¶
func (this *ReshardRequest) String() string
func (*ReshardRequest) Unmarshal ¶
func (m *ReshardRequest) Unmarshal(dAtA []byte) error
func (*ReshardRequest) XXX_DiscardUnknown ¶
func (m *ReshardRequest) XXX_DiscardUnknown()
func (*ReshardRequest) XXX_Marshal ¶
func (m *ReshardRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReshardRequest) XXX_Merge ¶
func (m *ReshardRequest) XXX_Merge(src proto.Message)
func (*ReshardRequest) XXX_Size ¶
func (m *ReshardRequest) XXX_Size() int
func (*ReshardRequest) XXX_Unmarshal ¶
func (m *ReshardRequest) XXX_Unmarshal(b []byte) error
type ScrapingServiceClient ¶
type ScrapingServiceClient interface {
// Reshard tells the implementing service to reshard all of its running
// configs.
Reshard(ctx context.Context, in *ReshardRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}
ScrapingServiceClient is the client API for ScrapingService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewScrapingServiceClient ¶
func NewScrapingServiceClient(cc *grpc.ClientConn) ScrapingServiceClient
type ScrapingServiceServer ¶
type ScrapingServiceServer interface {
// Reshard tells the implementing service to reshard all of its running
// configs.
Reshard(context.Context, *ReshardRequest) (*empty.Empty, error)
}
ScrapingServiceServer is the server API for ScrapingService service.
type UnimplementedScrapingServiceServer ¶
type UnimplementedScrapingServiceServer struct {
}
UnimplementedScrapingServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedScrapingServiceServer) Reshard ¶
func (*UnimplementedScrapingServiceServer) Reshard(ctx context.Context, req *ReshardRequest) (*empty.Empty, error)
Source Files
Click to show internal directories.
Click to hide internal directories.