agentproto

Documentation

Index

• Variables
• func RegisterScrapingServiceServer(s *grpc.Server, srv ScrapingServiceServer)
• type FuncScrapingServiceServer
  • func (f *FuncScrapingServiceServer) Reshard(ctx context.Context, req *ReshardRequest) (*empty.Empty, error)
• 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
  • func NewScrapingServiceClient(cc *grpc.ClientConn) ScrapingServiceClient
• type ScrapingServiceServer
• type UnimplementedScrapingServiceServer
  • func (*UnimplementedScrapingServiceServer) Reshard(ctx context.Context, req *ReshardRequest) (*empty.Empty, error)

Variables

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

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

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

func (m *ReshardRequest) MarshalTo(dAtA []byte) (int, 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)