Documentation
¶
Index ¶
- Variables
- func RegisterProcessorServer(s grpc.ServiceRegistrar, srv ProcessorServer)
- type Config
- func (*Config) Descriptor() ([]byte, []int)deprecated
- func (x *Config) GetCertFile() string
- func (x *Config) GetInsecure() bool
- func (x *Config) GetTarget() string
- func (*Config) ProtoMessage()
- func (x *Config) ProtoReflect() protoreflect.Message
- func (x *Config) Reset()
- func (x *Config) String() string
- type ProcessorClient
- type ProcessorServer
- type UnimplementedProcessorServer
- type UnsafeProcessorServer
Constants ¶
This section is empty.
Variables ¶
var File_fleetspeak_src_server_grpcservice_proto_fleetspeak_grpcservice_grpcservice_proto protoreflect.FileDescriptor
var Processor_ServiceDesc = grpc.ServiceDesc{ ServiceName: "fleetspeak.grpcservice.Processor", HandlerType: (*ProcessorServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Process", Handler: _Processor_Process_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "fleetspeak/src/server/grpcservice/proto/fleetspeak_grpcservice/grpcservice.proto", }
Processor_ServiceDesc is the grpc.ServiceDesc for Processor service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterProcessorServer ¶
func RegisterProcessorServer(s grpc.ServiceRegistrar, srv ProcessorServer)
Types ¶
type Config ¶
type Config struct {
Target string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"` // The address to dial.
Insecure bool `protobuf:"varint,2,opt,name=insecure,proto3" json:"insecure,omitempty"` // If set, will not secure connection to the target.
CertFile string `protobuf:"bytes,3,opt,name=cert_file,json=certFile,proto3" json:"cert_file,omitempty"` // If set, a pool of trusted certificates will be read from this file
// contains filtered or unexported fields
}
func (*Config) Descriptor
deprecated
func (*Config) GetCertFile ¶
func (*Config) GetInsecure ¶
func (*Config) ProtoMessage ¶
func (*Config) ProtoMessage()
func (*Config) ProtoReflect ¶
func (x *Config) ProtoReflect() protoreflect.Message
type ProcessorClient ¶
type ProcessorClient interface {
// Process accepts message and processes it.
Process(ctx context.Context, in *fleetspeak.Message, opts ...grpc.CallOption) (*fleetspeak.EmptyMessage, error)
}
ProcessorClient is the client API for Processor service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewProcessorClient ¶
func NewProcessorClient(cc grpc.ClientConnInterface) ProcessorClient
type ProcessorServer ¶
type ProcessorServer interface {
// Process accepts message and processes it.
Process(context.Context, *fleetspeak.Message) (*fleetspeak.EmptyMessage, error)
// contains filtered or unexported methods
}
ProcessorServer is the server API for Processor service. All implementations must embed UnimplementedProcessorServer for forward compatibility
type UnimplementedProcessorServer ¶
type UnimplementedProcessorServer struct {
}
UnimplementedProcessorServer must be embedded to have forward compatible implementations.
func (UnimplementedProcessorServer) Process ¶
func (UnimplementedProcessorServer) Process(context.Context, *fleetspeak.Message) (*fleetspeak.EmptyMessage, error)
type UnsafeProcessorServer ¶
type UnsafeProcessorServer interface {
// contains filtered or unexported methods
}
UnsafeProcessorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProcessorServer will result in compilation errors.
Source Files