services

package
v0.0.0-...-fb5451e Latest Latest
Warning

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

 Go to latest Published: Jul 13, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CatalogService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "peekaboo.v1.services.CatalogService",
	HandlerType: (*CatalogServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterSystem",
			Handler:    _CatalogService_RegisterSystem_Handler,
		},
		{
			MethodName: "SystemKeepAlive",
			Handler:    _CatalogService_SystemKeepAlive_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListSystems",
			Handler:       _CatalogService_ListSystems_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pb/v1/services/catalog.proto",
}

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

View Source 
var File_pb_v1_services_catalog_proto protoreflect.FileDescriptor
View Source 
var File_pb_v1_services_system_proto protoreflect.FileDescriptor
View Source 
var SystemService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "peekaboo.v1.services.SystemService",
	HandlerType: (*SystemServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetSystem",
			Handler:    _SystemService_GetSystem_Handler,
		},
		{
			MethodName: "ListUsers",
			Handler:    _SystemService_ListUsers_Handler,
		},
		{
			MethodName: "ListGroups",
			Handler:    _SystemService_ListGroups_Handler,
		},
		{
			MethodName: "ListFilesystems",
			Handler:    _SystemService_ListFilesystems_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pb/v1/services/system.proto",
}

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

Functions

func RegisterCatalogServiceServer 

func RegisterCatalogServiceServer(s grpc.ServiceRegistrar, srv CatalogServiceServer)

func RegisterSystemServiceServer 

func RegisterSystemServiceServer(s grpc.ServiceRegistrar, srv SystemServiceServer)

Types

type CatalogServiceClient 

type CatalogServiceClient interface {
	RegisterSystem(ctx context.Context, in *resources.System, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SystemKeepAlive(ctx context.Context, in *SystemKeepAliveRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListSystems(ctx context.Context, in *ListSystemsRequest, opts ...grpc.CallOption) (CatalogService_ListSystemsClient, error)
}

CatalogServiceClient is the client API for CatalogService 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 NewCatalogServiceClient 

func NewCatalogServiceClient(cc grpc.ClientConnInterface) CatalogServiceClient

type CatalogServiceServer 

type CatalogServiceServer interface {
	RegisterSystem(context.Context, *resources.System) (*emptypb.Empty, error)
	SystemKeepAlive(context.Context, *SystemKeepAliveRequest) (*emptypb.Empty, error)
	ListSystems(*ListSystemsRequest, CatalogService_ListSystemsServer) error
	// contains filtered or unexported methods
}

CatalogServiceServer is the server API for CatalogService service. All implementations must embed UnimplementedCatalogServiceServer for forward compatibility

type CatalogService_ListSystemsClient 

type CatalogService_ListSystemsClient interface {
	Recv() (*resources.System, error)
	grpc.ClientStream
}

type CatalogService_ListSystemsServer 

type CatalogService_ListSystemsServer interface {
	Send(*resources.System) error
	grpc.ServerStream
}

type GetSystemRequest 

type GetSystemRequest struct {
	// contains filtered or unexported fields
}

func (*GetSystemRequest) Descriptor deprecated 

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

Deprecated: Use GetSystemRequest.ProtoReflect.Descriptor instead.

func (*GetSystemRequest) ProtoMessage 

func (*GetSystemRequest) ProtoMessage()

func (*GetSystemRequest) ProtoReflect 

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

func (*GetSystemRequest) Reset 

func (x *GetSystemRequest) Reset()

func (*GetSystemRequest) String 

func (x *GetSystemRequest) String() string

type ListFilesystemsRequest 

type ListFilesystemsRequest struct {
	// contains filtered or unexported fields
}

func (*ListFilesystemsRequest) Descriptor deprecated 

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

Deprecated: Use ListFilesystemsRequest.ProtoReflect.Descriptor instead.

func (*ListFilesystemsRequest) ProtoMessage 

func (*ListFilesystemsRequest) ProtoMessage()

func (*ListFilesystemsRequest) ProtoReflect 

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

func (*ListFilesystemsRequest) Reset 

func (x *ListFilesystemsRequest) Reset()

func (*ListFilesystemsRequest) String 

func (x *ListFilesystemsRequest) String() string

type ListFilesystemsResponse 

type ListFilesystemsResponse struct {
	Hostname    string                  `protobuf:"bytes,1,opt,name=Hostname,proto3" json:"Hostname" csv:"Hostname" yaml:"Hostname"`
	Filesystems []*resources.Filesystem `protobuf:"bytes,2,rep,name=filesystems,proto3" json:"filesystems" csv:"filesystems" yaml:"filesystems"`
	// contains filtered or unexported fields
}

func (*ListFilesystemsResponse) Descriptor deprecated 

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

Deprecated: Use ListFilesystemsResponse.ProtoReflect.Descriptor instead.

func (*ListFilesystemsResponse) GetFilesystems 

func (x *ListFilesystemsResponse) GetFilesystems() []*resources.Filesystem

func (*ListFilesystemsResponse) GetHostname 

func (x *ListFilesystemsResponse) GetHostname() string

func (*ListFilesystemsResponse) ProtoMessage 

func (*ListFilesystemsResponse) ProtoMessage()

func (*ListFilesystemsResponse) ProtoReflect 

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

func (*ListFilesystemsResponse) Reset 

func (x *ListFilesystemsResponse) Reset()

func (*ListFilesystemsResponse) String 

func (x *ListFilesystemsResponse) String() string

type ListGroupsRequest 

type ListGroupsRequest struct {
	// contains filtered or unexported fields
}

func (*ListGroupsRequest) Descriptor deprecated 

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

Deprecated: Use ListGroupsRequest.ProtoReflect.Descriptor instead.

func (*ListGroupsRequest) ProtoMessage 

func (*ListGroupsRequest) ProtoMessage()

func (*ListGroupsRequest) ProtoReflect 

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

func (*ListGroupsRequest) Reset 

func (x *ListGroupsRequest) Reset()

func (*ListGroupsRequest) String 

func (x *ListGroupsRequest) String() string

type ListGroupsResponse 

type ListGroupsResponse struct {
	Hostname string             `protobuf:"bytes,1,opt,name=Hostname,proto3" json:"Hostname" csv:"Hostname" yaml:"Hostname"`
	Groups   []*resources.Group `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups" csv:"groups" yaml:"groups"`
	// contains filtered or unexported fields
}

func (*ListGroupsResponse) Descriptor deprecated 

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

Deprecated: Use ListGroupsResponse.ProtoReflect.Descriptor instead.

func (*ListGroupsResponse) GetGroups 

func (x *ListGroupsResponse) GetGroups() []*resources.Group

func (*ListGroupsResponse) GetHostname 

func (x *ListGroupsResponse) GetHostname() string

func (*ListGroupsResponse) ProtoMessage 

func (*ListGroupsResponse) ProtoMessage()

func (*ListGroupsResponse) ProtoReflect 

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

func (*ListGroupsResponse) Reset 

func (x *ListGroupsResponse) Reset()

func (*ListGroupsResponse) String 

func (x *ListGroupsResponse) String() string

type ListSystemsRequest 

type ListSystemsRequest struct {
	Filter *resources.Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter" csv:"filter" yaml:"filter"`
	// contains filtered or unexported fields
}

func (*ListSystemsRequest) Descriptor deprecated 

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

Deprecated: Use ListSystemsRequest.ProtoReflect.Descriptor instead.

func (*ListSystemsRequest) GetFilter 

func (x *ListSystemsRequest) GetFilter() *resources.Filter

func (*ListSystemsRequest) ProtoMessage 

func (*ListSystemsRequest) ProtoMessage()

func (*ListSystemsRequest) ProtoReflect 

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

func (*ListSystemsRequest) Reset 

func (x *ListSystemsRequest) Reset()

func (*ListSystemsRequest) String 

func (x *ListSystemsRequest) String() string

type ListUsersRequest 

type ListUsersRequest struct {
	// contains filtered or unexported fields
}

func (*ListUsersRequest) Descriptor deprecated 

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

Deprecated: Use ListUsersRequest.ProtoReflect.Descriptor instead.

func (*ListUsersRequest) ProtoMessage 

func (*ListUsersRequest) ProtoMessage()

func (*ListUsersRequest) ProtoReflect 

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

func (*ListUsersRequest) Reset 

func (x *ListUsersRequest) Reset()

func (*ListUsersRequest) String 

func (x *ListUsersRequest) String() string

type ListUsersResponse 

type ListUsersResponse struct {
	Hostname string            `protobuf:"bytes,1,opt,name=Hostname,proto3" json:"Hostname" csv:"Hostname" yaml:"Hostname"`
	Users    []*resources.User `protobuf:"bytes,2,rep,name=users,proto3" json:"users" csv:"users" yaml:"users"`
	// contains filtered or unexported fields
}

func (*ListUsersResponse) Descriptor deprecated 

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

Deprecated: Use ListUsersResponse.ProtoReflect.Descriptor instead.

func (*ListUsersResponse) GetHostname 

func (x *ListUsersResponse) GetHostname() string

func (*ListUsersResponse) GetUsers 

func (x *ListUsersResponse) GetUsers() []*resources.User

func (*ListUsersResponse) ProtoMessage 

func (*ListUsersResponse) ProtoMessage()

func (*ListUsersResponse) ProtoReflect 

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

func (*ListUsersResponse) Reset 

func (x *ListUsersResponse) Reset()

func (*ListUsersResponse) String 

func (x *ListUsersResponse) String() string

type SystemKeepAliveRequest 

type SystemKeepAliveRequest struct {
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname" csv:"hostname" yaml:"hostname"`
	// contains filtered or unexported fields
}

func (*SystemKeepAliveRequest) Descriptor deprecated 

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

Deprecated: Use SystemKeepAliveRequest.ProtoReflect.Descriptor instead.

func (*SystemKeepAliveRequest) GetHostname 

func (x *SystemKeepAliveRequest) GetHostname() string

func (*SystemKeepAliveRequest) ProtoMessage 

func (*SystemKeepAliveRequest) ProtoMessage()

func (*SystemKeepAliveRequest) ProtoReflect 

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

func (*SystemKeepAliveRequest) Reset 

func (x *SystemKeepAliveRequest) Reset()

func (*SystemKeepAliveRequest) String 

func (x *SystemKeepAliveRequest) String() string

type SystemServiceClient 

type SystemServiceClient interface {
	GetSystem(ctx context.Context, in *GetSystemRequest, opts ...grpc.CallOption) (*resources.System, error)
	ListUsers(ctx context.Context, in *ListUsersRequest, opts ...grpc.CallOption) (*ListUsersResponse, error)
	ListGroups(ctx context.Context, in *ListGroupsRequest, opts ...grpc.CallOption) (*ListGroupsResponse, error)
	ListFilesystems(ctx context.Context, in *ListFilesystemsRequest, opts ...grpc.CallOption) (*ListFilesystemsResponse, error)
}

SystemServiceClient is the client API for SystemService 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 NewSystemServiceClient 

func NewSystemServiceClient(cc grpc.ClientConnInterface) SystemServiceClient

type SystemServiceServer 

type SystemServiceServer interface {
	GetSystem(context.Context, *GetSystemRequest) (*resources.System, error)
	ListUsers(context.Context, *ListUsersRequest) (*ListUsersResponse, error)
	ListGroups(context.Context, *ListGroupsRequest) (*ListGroupsResponse, error)
	ListFilesystems(context.Context, *ListFilesystemsRequest) (*ListFilesystemsResponse, error)
	// contains filtered or unexported methods
}

SystemServiceServer is the server API for SystemService service. All implementations must embed UnimplementedSystemServiceServer for forward compatibility

type UnimplementedCatalogServiceServer 

type UnimplementedCatalogServiceServer struct {
}

UnimplementedCatalogServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCatalogServiceServer) ListSystems 

func (UnimplementedCatalogServiceServer) ListSystems(*ListSystemsRequest, CatalogService_ListSystemsServer) error

func (UnimplementedCatalogServiceServer) RegisterSystem 

func (UnimplementedCatalogServiceServer) RegisterSystem(context.Context, *resources.System) (*emptypb.Empty, error)

func (UnimplementedCatalogServiceServer) SystemKeepAlive 

func (UnimplementedCatalogServiceServer) SystemKeepAlive(context.Context, *SystemKeepAliveRequest) (*emptypb.Empty, error)

type UnimplementedSystemServiceServer 

type UnimplementedSystemServiceServer struct {
}

UnimplementedSystemServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSystemServiceServer) GetSystem 

func (UnimplementedSystemServiceServer) GetSystem(context.Context, *GetSystemRequest) (*resources.System, error)

func (UnimplementedSystemServiceServer) ListFilesystems 

func (UnimplementedSystemServiceServer) ListFilesystems(context.Context, *ListFilesystemsRequest) (*ListFilesystemsResponse, error)

func (UnimplementedSystemServiceServer) ListGroups 

func (UnimplementedSystemServiceServer) ListGroups(context.Context, *ListGroupsRequest) (*ListGroupsResponse, error)

func (UnimplementedSystemServiceServer) ListUsers 

func (UnimplementedSystemServiceServer) ListUsers(context.Context, *ListUsersRequest) (*ListUsersResponse, error)

type UnsafeCatalogServiceServer 

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

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

type UnsafeSystemServiceServer 

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

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

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.