agentproto

package
v0.34.0-rc.2 Latest Latest
Warning

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

Go to latest
Published: Jun 6, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL