eventv1

package
v0.2.7 Latest Latest
Warning

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

Go to latest
Published: Feb 28, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package eventv1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package eventv1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
const (
	AuditLogService_GetAuditLog_FullMethodName           = "/rep.framework.event.v1.AuditLogService/GetAuditLog"
	AuditLogService_GetAuditLogByProjects_FullMethodName = "/rep.framework.event.v1.AuditLogService/GetAuditLogByProjects"
)
View Source
const (
	RelayAuditService_GetRelayAudit_FullMethodName           = "/rep.framework.event.v1.RelayAuditService/GetRelayAudit"
	RelayAuditService_GetRelayAuditByProjects_FullMethodName = "/rep.framework.event.v1.RelayAuditService/GetRelayAuditByProjects"
)

Variables

View Source
var AuditLogService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rep.framework.event.v1.AuditLogService",
	HandlerType: (*AuditLogServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetAuditLog",
			Handler:    _AuditLogService_GetAuditLog_Handler,
		},
		{
			MethodName: "GetAuditLogByProjects",
			Handler:    _AuditLogService_GetAuditLogByProjects_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/rpc/audit/auditlog.proto",
}

AuditLogService_ServiceDesc is the grpc.ServiceDesc for AuditLogService 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_proto_rpc_audit_auditlog_proto protoreflect.FileDescriptor
View Source
var File_proto_rpc_audit_relayaudit_proto protoreflect.FileDescriptor
View Source
var RelayAuditService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rep.framework.event.v1.RelayAuditService",
	HandlerType: (*RelayAuditServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetRelayAudit",
			Handler:    _RelayAuditService_GetRelayAudit_Handler,
		},
		{
			MethodName: "GetRelayAuditByProjects",
			Handler:    _RelayAuditService_GetRelayAuditByProjects_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/rpc/audit/relayaudit.proto",
}

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

Functions

func RegisterAuditLogServiceHandler added in v0.1.3

func RegisterAuditLogServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterAuditLogServiceHandler registers the http handlers for service AuditLogService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterAuditLogServiceHandlerClient added in v0.1.3

func RegisterAuditLogServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AuditLogServiceClient) error

RegisterAuditLogServiceHandlerClient registers the http handlers for service AuditLogService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AuditLogServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AuditLogServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AuditLogServiceClient" to call the correct interceptors.

func RegisterAuditLogServiceHandlerFromEndpoint added in v0.1.3

func RegisterAuditLogServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterAuditLogServiceHandlerFromEndpoint is same as RegisterAuditLogServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterAuditLogServiceHandlerServer added in v0.1.3

func RegisterAuditLogServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AuditLogServiceServer) error

RegisterAuditLogServiceHandlerServer registers the http handlers for service AuditLogService to "mux". UnaryRPC :call AuditLogServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterAuditLogServiceHandlerFromEndpoint instead.

func RegisterAuditLogServiceServer added in v0.1.3

func RegisterAuditLogServiceServer(s grpc.ServiceRegistrar, srv AuditLogServiceServer)

func RegisterRelayAuditServiceHandler added in v0.1.3

func RegisterRelayAuditServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterRelayAuditServiceHandler registers the http handlers for service RelayAuditService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterRelayAuditServiceHandlerClient added in v0.1.3

func RegisterRelayAuditServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RelayAuditServiceClient) error

RegisterRelayAuditServiceHandlerClient registers the http handlers for service RelayAuditService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "RelayAuditServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "RelayAuditServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "RelayAuditServiceClient" to call the correct interceptors.

func RegisterRelayAuditServiceHandlerFromEndpoint added in v0.1.3

func RegisterRelayAuditServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterRelayAuditServiceHandlerFromEndpoint is same as RegisterRelayAuditServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterRelayAuditServiceHandlerServer added in v0.1.3

func RegisterRelayAuditServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RelayAuditServiceServer) error

RegisterRelayAuditServiceHandlerServer registers the http handlers for service RelayAuditService to "mux". UnaryRPC :call RelayAuditServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterRelayAuditServiceHandlerFromEndpoint instead.

func RegisterRelayAuditServiceServer added in v0.1.3

func RegisterRelayAuditServiceServer(s grpc.ServiceRegistrar, srv RelayAuditServiceServer)

Types

type AuditLogQueryFilter

type AuditLogQueryFilter struct {
	Type          string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	User          string   `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	Client        string   `protobuf:"bytes,3,opt,name=client,proto3" json:"client,omitempty"`
	Timefrom      string   `protobuf:"bytes,4,opt,name=timefrom,proto3" json:"timefrom,omitempty"`
	Portal        string   `protobuf:"bytes,5,opt,name=portal,proto3" json:"portal,omitempty"`
	Cluster       string   `protobuf:"bytes,6,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Namespace     string   `protobuf:"bytes,7,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Kind          string   `protobuf:"bytes,8,opt,name=kind,proto3" json:"kind,omitempty"`
	Method        string   `protobuf:"bytes,9,opt,name=method,proto3" json:"method,omitempty"`
	Projects      []string `protobuf:"bytes,10,rep,name=projects,proto3" json:"projects,omitempty"`
	QueryString   string   `protobuf:"bytes,11,opt,name=queryString,proto3" json:"queryString,omitempty"`
	DashboardData bool     `protobuf:"varint,12,opt,name=dashboardData,proto3" json:"dashboardData,omitempty"`
	// contains filtered or unexported fields
}

func (*AuditLogQueryFilter) Descriptor deprecated

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

Deprecated: Use AuditLogQueryFilter.ProtoReflect.Descriptor instead.

func (*AuditLogQueryFilter) GetClient

func (x *AuditLogQueryFilter) GetClient() string

func (*AuditLogQueryFilter) GetCluster

func (x *AuditLogQueryFilter) GetCluster() string

func (*AuditLogQueryFilter) GetDashboardData

func (x *AuditLogQueryFilter) GetDashboardData() bool

func (*AuditLogQueryFilter) GetKind

func (x *AuditLogQueryFilter) GetKind() string

func (*AuditLogQueryFilter) GetMethod

func (x *AuditLogQueryFilter) GetMethod() string

func (*AuditLogQueryFilter) GetNamespace

func (x *AuditLogQueryFilter) GetNamespace() string

func (*AuditLogQueryFilter) GetPortal

func (x *AuditLogQueryFilter) GetPortal() string

func (*AuditLogQueryFilter) GetProjects

func (x *AuditLogQueryFilter) GetProjects() []string

func (*AuditLogQueryFilter) GetQueryString

func (x *AuditLogQueryFilter) GetQueryString() string

func (*AuditLogQueryFilter) GetTimefrom

func (x *AuditLogQueryFilter) GetTimefrom() string

func (*AuditLogQueryFilter) GetType

func (x *AuditLogQueryFilter) GetType() string

func (*AuditLogQueryFilter) GetUser

func (x *AuditLogQueryFilter) GetUser() string

func (*AuditLogQueryFilter) ProtoMessage

func (*AuditLogQueryFilter) ProtoMessage()

func (*AuditLogQueryFilter) ProtoReflect

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

func (*AuditLogQueryFilter) Reset

func (x *AuditLogQueryFilter) Reset()

func (*AuditLogQueryFilter) String

func (x *AuditLogQueryFilter) String() string

type AuditLogServiceClient added in v0.1.3

type AuditLogServiceClient interface {
	GetAuditLog(ctx context.Context, in *GetAuditLogSearchRequest, opts ...grpc.CallOption) (*GetAuditLogSearchResponse, error)
	GetAuditLogByProjects(ctx context.Context, in *GetAuditLogSearchRequest, opts ...grpc.CallOption) (*GetAuditLogSearchResponse, error)
}

AuditLogServiceClient is the client API for AuditLogService 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 NewAuditLogServiceClient added in v0.1.3

func NewAuditLogServiceClient(cc grpc.ClientConnInterface) AuditLogServiceClient

type AuditLogServiceServer added in v0.1.3

type AuditLogServiceServer interface {
	GetAuditLog(context.Context, *GetAuditLogSearchRequest) (*GetAuditLogSearchResponse, error)
	GetAuditLogByProjects(context.Context, *GetAuditLogSearchRequest) (*GetAuditLogSearchResponse, error)
}

AuditLogServiceServer is the server API for AuditLogService service. All implementations should embed UnimplementedAuditLogServiceServer for forward compatibility

type GetAuditLogSearchRequest added in v0.1.3

type GetAuditLogSearchRequest struct {
	Metadata *v3.Metadata         `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Filter   *AuditLogQueryFilter `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAuditLogSearchRequest) Descriptor deprecated added in v0.1.3

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

Deprecated: Use GetAuditLogSearchRequest.ProtoReflect.Descriptor instead.

func (*GetAuditLogSearchRequest) GetFilter added in v0.1.3

func (*GetAuditLogSearchRequest) GetMetadata added in v0.1.3

func (x *GetAuditLogSearchRequest) GetMetadata() *v3.Metadata

func (*GetAuditLogSearchRequest) ProtoMessage added in v0.1.3

func (*GetAuditLogSearchRequest) ProtoMessage()

func (*GetAuditLogSearchRequest) ProtoReflect added in v0.1.3

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

func (*GetAuditLogSearchRequest) Reset added in v0.1.3

func (x *GetAuditLogSearchRequest) Reset()

func (*GetAuditLogSearchRequest) String added in v0.1.3

func (x *GetAuditLogSearchRequest) String() string

type GetAuditLogSearchResponse added in v0.1.3

type GetAuditLogSearchResponse struct {
	Result *structpb.Struct `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAuditLogSearchResponse) Descriptor deprecated added in v0.1.3

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

Deprecated: Use GetAuditLogSearchResponse.ProtoReflect.Descriptor instead.

func (*GetAuditLogSearchResponse) GetResult added in v0.1.3

func (x *GetAuditLogSearchResponse) GetResult() *structpb.Struct

func (*GetAuditLogSearchResponse) ProtoMessage added in v0.1.3

func (*GetAuditLogSearchResponse) ProtoMessage()

func (*GetAuditLogSearchResponse) ProtoReflect added in v0.1.3

func (*GetAuditLogSearchResponse) Reset added in v0.1.3

func (x *GetAuditLogSearchResponse) Reset()

func (*GetAuditLogSearchResponse) String added in v0.1.3

func (x *GetAuditLogSearchResponse) String() string

type RelayAuditQueryFilter

type RelayAuditQueryFilter struct {
	Type          string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	User          string   `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	Client        string   `protobuf:"bytes,3,opt,name=client,proto3" json:"client,omitempty"`
	Timefrom      string   `protobuf:"bytes,4,opt,name=timefrom,proto3" json:"timefrom,omitempty"`
	Portal        string   `protobuf:"bytes,5,opt,name=portal,proto3" json:"portal,omitempty"`
	Cluster       string   `protobuf:"bytes,6,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Namespace     string   `protobuf:"bytes,7,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Kind          string   `protobuf:"bytes,8,opt,name=kind,proto3" json:"kind,omitempty"`
	Method        string   `protobuf:"bytes,9,opt,name=method,proto3" json:"method,omitempty"`
	Projects      []string `protobuf:"bytes,10,rep,name=projects,proto3" json:"projects,omitempty"`
	QueryString   string   `protobuf:"bytes,11,opt,name=queryString,proto3" json:"queryString,omitempty"`
	DashboardData bool     `protobuf:"varint,12,opt,name=dashboardData,proto3" json:"dashboardData,omitempty"`
	ClusterNames  []string `protobuf:"bytes,13,rep,name=clusterNames,proto3" json:"clusterNames,omitempty"`
	// contains filtered or unexported fields
}

func (*RelayAuditQueryFilter) Descriptor deprecated

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

Deprecated: Use RelayAuditQueryFilter.ProtoReflect.Descriptor instead.

func (*RelayAuditQueryFilter) GetClient

func (x *RelayAuditQueryFilter) GetClient() string

func (*RelayAuditQueryFilter) GetCluster

func (x *RelayAuditQueryFilter) GetCluster() string

func (*RelayAuditQueryFilter) GetClusterNames

func (x *RelayAuditQueryFilter) GetClusterNames() []string

func (*RelayAuditQueryFilter) GetDashboardData

func (x *RelayAuditQueryFilter) GetDashboardData() bool

func (*RelayAuditQueryFilter) GetKind

func (x *RelayAuditQueryFilter) GetKind() string

func (*RelayAuditQueryFilter) GetMethod

func (x *RelayAuditQueryFilter) GetMethod() string

func (*RelayAuditQueryFilter) GetNamespace

func (x *RelayAuditQueryFilter) GetNamespace() string

func (*RelayAuditQueryFilter) GetPortal

func (x *RelayAuditQueryFilter) GetPortal() string

func (*RelayAuditQueryFilter) GetProjects

func (x *RelayAuditQueryFilter) GetProjects() []string

func (*RelayAuditQueryFilter) GetQueryString

func (x *RelayAuditQueryFilter) GetQueryString() string

func (*RelayAuditQueryFilter) GetTimefrom

func (x *RelayAuditQueryFilter) GetTimefrom() string

func (*RelayAuditQueryFilter) GetType

func (x *RelayAuditQueryFilter) GetType() string

func (*RelayAuditQueryFilter) GetUser

func (x *RelayAuditQueryFilter) GetUser() string

func (*RelayAuditQueryFilter) ProtoMessage

func (*RelayAuditQueryFilter) ProtoMessage()

func (*RelayAuditQueryFilter) ProtoReflect

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

func (*RelayAuditQueryFilter) Reset

func (x *RelayAuditQueryFilter) Reset()

func (*RelayAuditQueryFilter) String

func (x *RelayAuditQueryFilter) String() string

type RelayAuditRequest added in v0.1.3

type RelayAuditRequest struct {

	// TODO: this was paralus.dev.common.types.v2.ParalusMeta
	Metadata  *v3.Metadata           `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Filter    *RelayAuditQueryFilter `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	AuditType string                 `protobuf:"bytes,3,opt,name=auditType,proto3" json:"auditType,omitempty"`
	// contains filtered or unexported fields
}

func (*RelayAuditRequest) Descriptor deprecated added in v0.1.3

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

Deprecated: Use RelayAuditRequest.ProtoReflect.Descriptor instead.

func (*RelayAuditRequest) GetAuditType added in v0.1.3

func (x *RelayAuditRequest) GetAuditType() string

func (*RelayAuditRequest) GetFilter added in v0.1.3

func (x *RelayAuditRequest) GetFilter() *RelayAuditQueryFilter

func (*RelayAuditRequest) GetMetadata added in v0.1.3

func (x *RelayAuditRequest) GetMetadata() *v3.Metadata

func (*RelayAuditRequest) ProtoMessage added in v0.1.3

func (*RelayAuditRequest) ProtoMessage()

func (*RelayAuditRequest) ProtoReflect added in v0.1.3

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

func (*RelayAuditRequest) Reset added in v0.1.3

func (x *RelayAuditRequest) Reset()

func (*RelayAuditRequest) String added in v0.1.3

func (x *RelayAuditRequest) String() string

type RelayAuditResponse added in v0.1.3

type RelayAuditResponse struct {
	Result    *structpb.Struct `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	AuditType string           `protobuf:"bytes,2,opt,name=auditType,proto3" json:"auditType,omitempty"`
	// contains filtered or unexported fields
}

func (*RelayAuditResponse) Descriptor deprecated added in v0.1.3

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

Deprecated: Use RelayAuditResponse.ProtoReflect.Descriptor instead.

func (*RelayAuditResponse) GetAuditType added in v0.1.3

func (x *RelayAuditResponse) GetAuditType() string

func (*RelayAuditResponse) GetResult added in v0.1.3

func (x *RelayAuditResponse) GetResult() *structpb.Struct

func (*RelayAuditResponse) ProtoMessage added in v0.1.3

func (*RelayAuditResponse) ProtoMessage()

func (*RelayAuditResponse) ProtoReflect added in v0.1.3

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

func (*RelayAuditResponse) Reset added in v0.1.3

func (x *RelayAuditResponse) Reset()

func (*RelayAuditResponse) String added in v0.1.3

func (x *RelayAuditResponse) String() string

type RelayAuditServiceClient added in v0.1.3

type RelayAuditServiceClient interface {
	GetRelayAudit(ctx context.Context, in *RelayAuditRequest, opts ...grpc.CallOption) (*RelayAuditResponse, error)
	GetRelayAuditByProjects(ctx context.Context, in *RelayAuditRequest, opts ...grpc.CallOption) (*RelayAuditResponse, error)
}

RelayAuditServiceClient is the client API for RelayAuditService 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 NewRelayAuditServiceClient added in v0.1.3

func NewRelayAuditServiceClient(cc grpc.ClientConnInterface) RelayAuditServiceClient

type RelayAuditServiceServer added in v0.1.3

type RelayAuditServiceServer interface {
	GetRelayAudit(context.Context, *RelayAuditRequest) (*RelayAuditResponse, error)
	GetRelayAuditByProjects(context.Context, *RelayAuditRequest) (*RelayAuditResponse, error)
}

RelayAuditServiceServer is the server API for RelayAuditService service. All implementations should embed UnimplementedRelayAuditServiceServer for forward compatibility

type UnimplementedAuditLogServiceServer added in v0.1.3

type UnimplementedAuditLogServiceServer struct {
}

UnimplementedAuditLogServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedAuditLogServiceServer) GetAuditLog added in v0.1.3

func (UnimplementedAuditLogServiceServer) GetAuditLogByProjects added in v0.1.3

type UnimplementedRelayAuditServiceServer added in v0.1.3

type UnimplementedRelayAuditServiceServer struct {
}

UnimplementedRelayAuditServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedRelayAuditServiceServer) GetRelayAudit added in v0.1.3

func (UnimplementedRelayAuditServiceServer) GetRelayAuditByProjects added in v0.1.3

type UnsafeAuditLogServiceServer added in v0.1.3

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

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

type UnsafeRelayAuditServiceServer added in v0.1.3

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

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

Jump to

Keyboard shortcuts

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