collectsub

package
v0.7.2 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CollectDataType_name = map[int32]string{
		0: "DATATYPE_UNKNOWN",
		1: "DATATYPE_GIT",
		2: "DATATYPE_OCI",
		3: "DATATYPE_PURL",
		4: "DATATYPE_GITHUB_RELEASE",
	}
	CollectDataType_value = map[string]int32{
		"DATATYPE_UNKNOWN":        0,
		"DATATYPE_GIT":            1,
		"DATATYPE_OCI":            2,
		"DATATYPE_PURL":           3,
		"DATATYPE_GITHUB_RELEASE": 4,
	}
)

Enum value maps for CollectDataType.

View Source 
var CollectSubscriberService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "guacsec.guac.collect_subscriber.schema.CollectSubscriberService",
	HandlerType: (*CollectSubscriberServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddCollectEntries",
			Handler:    _CollectSubscriberService_AddCollectEntries_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetCollectEntries",
			Handler:       _CollectSubscriberService_GetCollectEntries_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/collectsub/collectsub/collectsub.proto",
}

CollectSubscriberService_ServiceDesc is the grpc.ServiceDesc for CollectSubscriberService 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_pkg_collectsub_collectsub_collectsub_proto protoreflect.FileDescriptor

Functions

func RegisterCollectSubscriberServiceServer added in v0.6.0 

func RegisterCollectSubscriberServiceServer(s grpc.ServiceRegistrar, srv CollectSubscriberServiceServer)

Types

type AddCollectEntriesRequest 

type AddCollectEntriesRequest struct {
	Entries []*CollectEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

rpc AddCollectEntries

func (*AddCollectEntriesRequest) Descriptor deprecated 

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

Deprecated: Use AddCollectEntriesRequest.ProtoReflect.Descriptor instead.

func (*AddCollectEntriesRequest) GetEntries 

func (x *AddCollectEntriesRequest) GetEntries() []*CollectEntry

func (*AddCollectEntriesRequest) ProtoMessage 

func (*AddCollectEntriesRequest) ProtoMessage()

func (*AddCollectEntriesRequest) ProtoReflect 

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

func (*AddCollectEntriesRequest) Reset 

func (x *AddCollectEntriesRequest) Reset()

func (*AddCollectEntriesRequest) String 

func (x *AddCollectEntriesRequest) String() string

type AddCollectEntriesResponse 

type AddCollectEntriesResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*AddCollectEntriesResponse) Descriptor deprecated 

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

Deprecated: Use AddCollectEntriesResponse.ProtoReflect.Descriptor instead.

func (*AddCollectEntriesResponse) GetSuccess 

func (x *AddCollectEntriesResponse) GetSuccess() bool

func (*AddCollectEntriesResponse) ProtoMessage 

func (*AddCollectEntriesResponse) ProtoMessage()

func (*AddCollectEntriesResponse) ProtoReflect 

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

func (*AddCollectEntriesResponse) Reset 

func (x *AddCollectEntriesResponse) Reset()

func (*AddCollectEntriesResponse) String 

func (x *AddCollectEntriesResponse) String() string

type CollectDataType 

type CollectDataType int32
const (
	CollectDataType_DATATYPE_UNKNOWN        CollectDataType = 0
	CollectDataType_DATATYPE_GIT            CollectDataType = 1
	CollectDataType_DATATYPE_OCI            CollectDataType = 2
	CollectDataType_DATATYPE_PURL           CollectDataType = 3
	CollectDataType_DATATYPE_GITHUB_RELEASE CollectDataType = 4
)

func (CollectDataType) Descriptor 

func (CollectDataType) Descriptor() protoreflect.EnumDescriptor

func (CollectDataType) Enum 

func (x CollectDataType) Enum() *CollectDataType

func (CollectDataType) EnumDescriptor deprecated 

func (CollectDataType) EnumDescriptor() ([]byte, []int)

Deprecated: Use CollectDataType.Descriptor instead.

func (CollectDataType) Number 

func (x CollectDataType) Number() protoreflect.EnumNumber

func (CollectDataType) String 

func (x CollectDataType) String() string

func (CollectDataType) Type 

func (CollectDataType) Type() protoreflect.EnumType

type CollectEntry 

type CollectEntry struct {
	Type      CollectDataType `protobuf:"varint,1,opt,name=type,proto3,enum=guacsec.guac.collect_subscriber.schema.CollectDataType" json:"type,omitempty"`
	Value     string          `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	SinceTime int64           `protobuf:"varint,3,opt,name=since_time,json=sinceTime,proto3" json:"since_time,omitempty"`
	// contains filtered or unexported fields
}

Generic types

func (*CollectEntry) Descriptor deprecated 

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

Deprecated: Use CollectEntry.ProtoReflect.Descriptor instead.

func (*CollectEntry) GetSinceTime added in v0.1.1 

func (x *CollectEntry) GetSinceTime() int64

func (*CollectEntry) GetType 

func (x *CollectEntry) GetType() CollectDataType

func (*CollectEntry) GetValue 

func (x *CollectEntry) GetValue() string

func (*CollectEntry) ProtoMessage 

func (*CollectEntry) ProtoMessage()

func (*CollectEntry) ProtoReflect 

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

func (*CollectEntry) Reset 

func (x *CollectEntry) Reset()

func (*CollectEntry) String 

func (x *CollectEntry) String() string

type CollectEntryFilter 

type CollectEntryFilter struct {
	Type CollectDataType `protobuf:"varint,1,opt,name=type,proto3,enum=guacsec.guac.collect_subscriber.schema.CollectDataType" json:"type,omitempty"`
	Glob string          `protobuf:"bytes,2,opt,name=glob,proto3" json:"glob,omitempty"`
	// contains filtered or unexported fields
}

rpc GetCollectEntries

func (*CollectEntryFilter) Descriptor deprecated 

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

Deprecated: Use CollectEntryFilter.ProtoReflect.Descriptor instead.

func (*CollectEntryFilter) GetGlob 

func (x *CollectEntryFilter) GetGlob() string

func (*CollectEntryFilter) GetType 

func (x *CollectEntryFilter) GetType() CollectDataType

func (*CollectEntryFilter) ProtoMessage 

func (*CollectEntryFilter) ProtoMessage()

func (*CollectEntryFilter) ProtoReflect 

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

func (*CollectEntryFilter) Reset 

func (x *CollectEntryFilter) Reset()

func (*CollectEntryFilter) String 

func (x *CollectEntryFilter) String() string

type CollectSubscriberServiceClient added in v0.6.0 

type CollectSubscriberServiceClient interface {
	AddCollectEntries(ctx context.Context, in *AddCollectEntriesRequest, opts ...grpc.CallOption) (*AddCollectEntriesResponse, error)
	GetCollectEntries(ctx context.Context, in *GetCollectEntriesRequest, opts ...grpc.CallOption) (CollectSubscriberService_GetCollectEntriesClient, error)
}

CollectSubscriberServiceClient is the client API for CollectSubscriberService 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 NewCollectSubscriberServiceClient added in v0.6.0 

func NewCollectSubscriberServiceClient(cc grpc.ClientConnInterface) CollectSubscriberServiceClient

type CollectSubscriberServiceServer added in v0.6.0 

type CollectSubscriberServiceServer interface {
	AddCollectEntries(context.Context, *AddCollectEntriesRequest) (*AddCollectEntriesResponse, error)
	GetCollectEntries(*GetCollectEntriesRequest, CollectSubscriberService_GetCollectEntriesServer) error
	// contains filtered or unexported methods
}

CollectSubscriberServiceServer is the server API for CollectSubscriberService service. All implementations must embed UnimplementedCollectSubscriberServiceServer for forward compatibility

type CollectSubscriberService_GetCollectEntriesClient added in v0.6.0 

type CollectSubscriberService_GetCollectEntriesClient interface {
	Recv() (*GetCollectEntriesResponse, error)
	grpc.ClientStream
}

type CollectSubscriberService_GetCollectEntriesServer added in v0.6.0 

type CollectSubscriberService_GetCollectEntriesServer interface {
	Send(*GetCollectEntriesResponse) error
	grpc.ServerStream
}

type GetCollectEntriesRequest 

type GetCollectEntriesRequest struct {
	Filters []*CollectEntryFilter `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
	// since_time in unix epoch
	SinceTime int64 `protobuf:"varint,2,opt,name=since_time,json=sinceTime,proto3" json:"since_time,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCollectEntriesRequest) Descriptor deprecated 

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

Deprecated: Use GetCollectEntriesRequest.ProtoReflect.Descriptor instead.

func (*GetCollectEntriesRequest) GetFilters 

func (x *GetCollectEntriesRequest) GetFilters() []*CollectEntryFilter

func (*GetCollectEntriesRequest) GetSinceTime 

func (x *GetCollectEntriesRequest) GetSinceTime() int64

func (*GetCollectEntriesRequest) ProtoMessage 

func (*GetCollectEntriesRequest) ProtoMessage()

func (*GetCollectEntriesRequest) ProtoReflect 

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

func (*GetCollectEntriesRequest) Reset 

func (x *GetCollectEntriesRequest) Reset()

func (*GetCollectEntriesRequest) String 

func (x *GetCollectEntriesRequest) String() string

type GetCollectEntriesResponse 

type GetCollectEntriesResponse struct {
	Entries []*CollectEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCollectEntriesResponse) Descriptor deprecated 

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

Deprecated: Use GetCollectEntriesResponse.ProtoReflect.Descriptor instead.

func (*GetCollectEntriesResponse) GetEntries 

func (x *GetCollectEntriesResponse) GetEntries() []*CollectEntry

func (*GetCollectEntriesResponse) ProtoMessage 

func (*GetCollectEntriesResponse) ProtoMessage()

func (*GetCollectEntriesResponse) ProtoReflect 

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

func (*GetCollectEntriesResponse) Reset 

func (x *GetCollectEntriesResponse) Reset()

func (*GetCollectEntriesResponse) String 

func (x *GetCollectEntriesResponse) String() string

type UnimplementedCollectSubscriberServiceServer added in v0.6.0 

type UnimplementedCollectSubscriberServiceServer struct {
}

UnimplementedCollectSubscriberServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCollectSubscriberServiceServer) AddCollectEntries added in v0.6.0 

func (UnimplementedCollectSubscriberServiceServer) AddCollectEntries(context.Context, *AddCollectEntriesRequest) (*AddCollectEntriesResponse, error)

func (UnimplementedCollectSubscriberServiceServer) GetCollectEntries added in v0.6.0 

func (UnimplementedCollectSubscriberServiceServer) GetCollectEntries(*GetCollectEntriesRequest, CollectSubscriberService_GetCollectEntriesServer) error

type UnsafeCollectSubscriberServiceServer added in v0.6.0 

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

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

Source Files

View all Source files

Directories

Path Synopsis
input defines collectsub structs that can be used for human/application inputs that do not necessarily find it convenient to use protobuf (e.g.
 input defines collectsub structs that can be used for human/application inputs that do not necessarily find it convenient to use protobuf (e.g.

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.