rpc

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Jul 20, 2026 License: GPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Services_Create_FullMethodName     = "/network.Services/Create"
	Services_Read_FullMethodName       = "/network.Services/Read"
	Services_List_FullMethodName       = "/network.Services/List"
	Services_Upsert_FullMethodName     = "/network.Services/Upsert"
	Services_Delete_FullMethodName     = "/network.Services/Delete"
	Services_ReadHost_FullMethodName   = "/network.Services/ReadHost"
	Services_ListHost_FullMethodName   = "/network.Services/ListHost"
	Services_UpsertHost_FullMethodName = "/network.Services/UpsertHost"
)

Variables

View Source 
var File_network_pb_rpc_services_proto protoreflect.FileDescriptor
View Source 
var Services_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "network.Services",
	HandlerType: (*ServicesServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _Services_Create_Handler,
		},
		{
			MethodName: "Read",
			Handler:    _Services_Read_Handler,
		},
		{
			MethodName: "List",
			Handler:    _Services_List_Handler,
		},
		{
			MethodName: "Upsert",
			Handler:    _Services_Upsert_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Services_Delete_Handler,
		},
		{
			MethodName: "ReadHost",
			Handler:    _Services_ReadHost_Handler,
		},
		{
			MethodName: "ListHost",
			Handler:    _Services_ListHost_Handler,
		},
		{
			MethodName: "UpsertHost",
			Handler:    _Services_UpsertHost_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "network/pb/rpc/services.proto",
}

Services_ServiceDesc is the grpc.ServiceDesc for Services service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterServicesServer 

func RegisterServicesServer(s grpc.ServiceRegistrar, srv ServicesServer)

Types

type CreateServiceRequest 

type CreateServiceRequest struct {
	Services []*pb.Service `protobuf:"bytes,1,rep,name=Services,proto3" json:"Services,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateServiceRequest) Descriptor deprecated 

func (*CreateServiceRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateServiceRequest.ProtoReflect.Descriptor instead.

func (*CreateServiceRequest) GetServices 

func (x *CreateServiceRequest) GetServices() []*pb.Service

func (*CreateServiceRequest) ProtoMessage 

func (*CreateServiceRequest) ProtoMessage()

func (*CreateServiceRequest) ProtoReflect 

func (x *CreateServiceRequest) ProtoReflect() protoreflect.Message

func (*CreateServiceRequest) Reset 

func (x *CreateServiceRequest) Reset()

func (*CreateServiceRequest) String 

func (x *CreateServiceRequest) String() string

type CreateServiceResponse 

type CreateServiceResponse struct {
	Services []*pb.Service `protobuf:"bytes,1,rep,name=Services,proto3" json:"Services,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateServiceResponse) Descriptor deprecated 

func (*CreateServiceResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateServiceResponse.ProtoReflect.Descriptor instead.

func (*CreateServiceResponse) GetServices 

func (x *CreateServiceResponse) GetServices() []*pb.Service

func (*CreateServiceResponse) ProtoMessage 

func (*CreateServiceResponse) ProtoMessage()

func (*CreateServiceResponse) ProtoReflect 

func (x *CreateServiceResponse) ProtoReflect() protoreflect.Message

func (*CreateServiceResponse) Reset 

func (x *CreateServiceResponse) Reset()

func (*CreateServiceResponse) String 

func (x *CreateServiceResponse) String() string

type DeleteServiceRequest 

type DeleteServiceRequest struct {
	Services []*pb.Service `protobuf:"bytes,1,rep,name=Services,proto3" json:"Services,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteServiceRequest) Descriptor deprecated 

func (*DeleteServiceRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteServiceRequest.ProtoReflect.Descriptor instead.

func (*DeleteServiceRequest) GetServices 

func (x *DeleteServiceRequest) GetServices() []*pb.Service

func (*DeleteServiceRequest) ProtoMessage 

func (*DeleteServiceRequest) ProtoMessage()

func (*DeleteServiceRequest) ProtoReflect 

func (x *DeleteServiceRequest) ProtoReflect() protoreflect.Message

func (*DeleteServiceRequest) Reset 

func (x *DeleteServiceRequest) Reset()

func (*DeleteServiceRequest) String 

func (x *DeleteServiceRequest) String() string

type DeleteServiceResponse 

type DeleteServiceResponse struct {
	Services []*pb.Service `protobuf:"bytes,1,rep,name=Services,proto3" json:"Services,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteServiceResponse) Descriptor deprecated 

func (*DeleteServiceResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteServiceResponse.ProtoReflect.Descriptor instead.

func (*DeleteServiceResponse) GetServices 

func (x *DeleteServiceResponse) GetServices() []*pb.Service

func (*DeleteServiceResponse) ProtoMessage 

func (*DeleteServiceResponse) ProtoMessage()

func (*DeleteServiceResponse) ProtoReflect 

func (x *DeleteServiceResponse) ProtoReflect() protoreflect.Message

func (*DeleteServiceResponse) Reset 

func (x *DeleteServiceResponse) Reset()

func (*DeleteServiceResponse) String 

func (x *DeleteServiceResponse) String() string

type ReadServiceManyRequest 

type ReadServiceManyRequest struct {
	Service *pb.Service `protobuf:"bytes,1,opt,name=Service,proto3" json:"Service,omitempty"`
	Host    *pb1.Host   `protobuf:"bytes,2,opt,name=Host,proto3" json:"Host,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadServiceManyRequest) Descriptor deprecated 

func (*ReadServiceManyRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReadServiceManyRequest.ProtoReflect.Descriptor instead.

func (*ReadServiceManyRequest) GetHost 

func (x *ReadServiceManyRequest) GetHost() *pb1.Host

func (*ReadServiceManyRequest) GetService 

func (x *ReadServiceManyRequest) GetService() *pb.Service

func (*ReadServiceManyRequest) ProtoMessage 

func (*ReadServiceManyRequest) ProtoMessage()

func (*ReadServiceManyRequest) ProtoReflect 

func (x *ReadServiceManyRequest) ProtoReflect() protoreflect.Message

func (*ReadServiceManyRequest) Reset 

func (x *ReadServiceManyRequest) Reset()

func (*ReadServiceManyRequest) String 

func (x *ReadServiceManyRequest) String() string

type ReadServiceManyResponse 

type ReadServiceManyResponse struct {
	Services []*pb.Service `protobuf:"bytes,1,rep,name=Services,proto3" json:"Services,omitempty"`
	Host     []*pb1.Host   `protobuf:"bytes,2,rep,name=Host,proto3" json:"Host,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadServiceManyResponse) Descriptor deprecated 

func (*ReadServiceManyResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReadServiceManyResponse.ProtoReflect.Descriptor instead.

func (*ReadServiceManyResponse) GetHost 

func (x *ReadServiceManyResponse) GetHost() []*pb1.Host

func (*ReadServiceManyResponse) GetServices 

func (x *ReadServiceManyResponse) GetServices() []*pb.Service

func (*ReadServiceManyResponse) ProtoMessage 

func (*ReadServiceManyResponse) ProtoMessage()

func (*ReadServiceManyResponse) ProtoReflect 

func (x *ReadServiceManyResponse) ProtoReflect() protoreflect.Message

func (*ReadServiceManyResponse) Reset 

func (x *ReadServiceManyResponse) Reset()

func (*ReadServiceManyResponse) String 

func (x *ReadServiceManyResponse) String() string

type ReadServiceRequest 

type ReadServiceRequest struct {
	Service *pb.Service `protobuf:"bytes,1,opt,name=Service,proto3" json:"Service,omitempty"`
	Host    *pb1.Host   `protobuf:"bytes,2,opt,name=Host,proto3" json:"Host,omitempty"`
	// Source: if set, scope the read to only the services contributed by this tool
	// (matched against provenance.Source.Tool via the service_sources join) — the "give me
	// only my objects" filter. Empty means the default cross-tool shared view.
	Source string `protobuf:"bytes,3,opt,name=Source,proto3" json:"Source,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadServiceRequest) Descriptor deprecated 

func (*ReadServiceRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReadServiceRequest.ProtoReflect.Descriptor instead.

func (*ReadServiceRequest) GetHost 

func (x *ReadServiceRequest) GetHost() *pb1.Host

func (*ReadServiceRequest) GetService 

func (x *ReadServiceRequest) GetService() *pb.Service

func (*ReadServiceRequest) GetSource 

func (x *ReadServiceRequest) GetSource() string

func (*ReadServiceRequest) ProtoMessage 

func (*ReadServiceRequest) ProtoMessage()

func (*ReadServiceRequest) ProtoReflect 

func (x *ReadServiceRequest) ProtoReflect() protoreflect.Message

func (*ReadServiceRequest) Reset 

func (x *ReadServiceRequest) Reset()

func (*ReadServiceRequest) String 

func (x *ReadServiceRequest) String() string

type ReadServiceResponse 

type ReadServiceResponse struct {
	Services []*pb.Service `protobuf:"bytes,1,rep,name=Services,proto3" json:"Services,omitempty"`
	Host     []*pb1.Host   `protobuf:"bytes,2,rep,name=Host,proto3" json:"Host,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadServiceResponse) Descriptor deprecated 

func (*ReadServiceResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReadServiceResponse.ProtoReflect.Descriptor instead.

func (*ReadServiceResponse) GetHost 

func (x *ReadServiceResponse) GetHost() []*pb1.Host

func (*ReadServiceResponse) GetServices 

func (x *ReadServiceResponse) GetServices() []*pb.Service

func (*ReadServiceResponse) ProtoMessage 

func (*ReadServiceResponse) ProtoMessage()

func (*ReadServiceResponse) ProtoReflect 

func (x *ReadServiceResponse) ProtoReflect() protoreflect.Message

func (*ReadServiceResponse) Reset 

func (x *ReadServiceResponse) Reset()

func (*ReadServiceResponse) String 

func (x *ReadServiceResponse) String() string

type ServicesClient 

type ServicesClient interface {
	// Services alone, without detailed port/host information
	Create(ctx context.Context, in *CreateServiceRequest, opts ...grpc.CallOption) (*CreateServiceResponse, error)
	Read(ctx context.Context, in *ReadServiceRequest, opts ...grpc.CallOption) (*ReadServiceResponse, error)
	List(ctx context.Context, in *ReadServiceRequest, opts ...grpc.CallOption) (*ReadServiceResponse, error)
	Upsert(ctx context.Context, in *UpsertServiceRequest, opts ...grpc.CallOption) (*UpsertServiceResponse, error)
	Delete(ctx context.Context, in *DeleteServiceRequest, opts ...grpc.CallOption) (*DeleteServiceResponse, error)
	// Host services (with extra ports and lower-level stuff)
	ReadHost(ctx context.Context, in *ReadServiceRequest, opts ...grpc.CallOption) (*ReadServiceResponse, error)
	ListHost(ctx context.Context, in *ReadServiceRequest, opts ...grpc.CallOption) (*ReadServiceResponse, error)
	UpsertHost(ctx context.Context, in *UpsertServiceRequest, opts ...grpc.CallOption) (*UpsertServiceResponse, error)
}

ServicesClient is the client API for Services service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewServicesClient 

func NewServicesClient(cc grpc.ClientConnInterface) ServicesClient

type ServicesServer 

type ServicesServer interface {
	// Services alone, without detailed port/host information
	Create(context.Context, *CreateServiceRequest) (*CreateServiceResponse, error)
	Read(context.Context, *ReadServiceRequest) (*ReadServiceResponse, error)
	List(context.Context, *ReadServiceRequest) (*ReadServiceResponse, error)
	Upsert(context.Context, *UpsertServiceRequest) (*UpsertServiceResponse, error)
	Delete(context.Context, *DeleteServiceRequest) (*DeleteServiceResponse, error)
	// Host services (with extra ports and lower-level stuff)
	ReadHost(context.Context, *ReadServiceRequest) (*ReadServiceResponse, error)
	ListHost(context.Context, *ReadServiceRequest) (*ReadServiceResponse, error)
	UpsertHost(context.Context, *UpsertServiceRequest) (*UpsertServiceResponse, error)
	// contains filtered or unexported methods
}

ServicesServer is the server API for Services service. All implementations must embed UnimplementedServicesServer for forward compatibility

type UnimplementedServicesServer 

type UnimplementedServicesServer struct {
}

UnimplementedServicesServer must be embedded to have forward compatible implementations.

func (UnimplementedServicesServer) Create 

func (UnimplementedServicesServer) Create(context.Context, *CreateServiceRequest) (*CreateServiceResponse, error)

func (UnimplementedServicesServer) Delete 

func (UnimplementedServicesServer) Delete(context.Context, *DeleteServiceRequest) (*DeleteServiceResponse, error)

func (UnimplementedServicesServer) List 

func (UnimplementedServicesServer) List(context.Context, *ReadServiceRequest) (*ReadServiceResponse, error)

func (UnimplementedServicesServer) ListHost 

func (UnimplementedServicesServer) ListHost(context.Context, *ReadServiceRequest) (*ReadServiceResponse, error)

func (UnimplementedServicesServer) Read 

func (UnimplementedServicesServer) Read(context.Context, *ReadServiceRequest) (*ReadServiceResponse, error)

func (UnimplementedServicesServer) ReadHost 

func (UnimplementedServicesServer) ReadHost(context.Context, *ReadServiceRequest) (*ReadServiceResponse, error)

func (UnimplementedServicesServer) Upsert 

func (UnimplementedServicesServer) Upsert(context.Context, *UpsertServiceRequest) (*UpsertServiceResponse, error)

func (UnimplementedServicesServer) UpsertHost 

func (UnimplementedServicesServer) UpsertHost(context.Context, *UpsertServiceRequest) (*UpsertServiceResponse, error)

type UnsafeServicesServer 

type UnsafeServicesServer interface {
	// contains filtered or unexported methods
}

UnsafeServicesServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServicesServer will result in compilation errors.

type UpsertServiceRequest 

type UpsertServiceRequest struct {
	Services []*pb.Service `protobuf:"bytes,1,rep,name=Services,proto3" json:"Services,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertServiceRequest) Descriptor deprecated 

func (*UpsertServiceRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpsertServiceRequest.ProtoReflect.Descriptor instead.

func (*UpsertServiceRequest) GetServices 

func (x *UpsertServiceRequest) GetServices() []*pb.Service

func (*UpsertServiceRequest) ProtoMessage 

func (*UpsertServiceRequest) ProtoMessage()

func (*UpsertServiceRequest) ProtoReflect 

func (x *UpsertServiceRequest) ProtoReflect() protoreflect.Message

func (*UpsertServiceRequest) Reset 

func (x *UpsertServiceRequest) Reset()

func (*UpsertServiceRequest) String 

func (x *UpsertServiceRequest) String() string

type UpsertServiceResponse 

type UpsertServiceResponse struct {
	Services []*pb.Service `protobuf:"bytes,1,rep,name=Services,proto3" json:"Services,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertServiceResponse) Descriptor deprecated 

func (*UpsertServiceResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpsertServiceResponse.ProtoReflect.Descriptor instead.

func (*UpsertServiceResponse) GetServices 

func (x *UpsertServiceResponse) GetServices() []*pb.Service

func (*UpsertServiceResponse) ProtoMessage 

func (*UpsertServiceResponse) ProtoMessage()

func (*UpsertServiceResponse) ProtoReflect 

func (x *UpsertServiceResponse) ProtoReflect() protoreflect.Message

func (*UpsertServiceResponse) Reset 

func (x *UpsertServiceResponse) Reset()

func (*UpsertServiceResponse) String 

func (x *UpsertServiceResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.