service

package
v4.0.0-alpha1 Latest Latest
Warning

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

Go to latest
Published: Mar 17, 2022 License: AGPL-3.0 Imports: 17 Imported by: 0

Documentation

Overview

Package service provides protobuf "any" types used by other proto's

Index

Constants

This section is empty.

Variables

View Source
var (
	OperationType_name = map[int32]string{
		0: "OR",
		1: "AND",
	}
	OperationType_value = map[string]int32{
		"OR":  0,
		"AND": 1,
	}
)

Enum value maps for OperationType.

View Source
var (
	ResourcePolicyAction_name = map[int32]string{
		0: "ANY",
		1: "OWNER",
		2: "READ",
		3: "WRITE",
		4: "EDIT_RULES",
	}
	ResourcePolicyAction_value = map[string]int32{
		"ANY":        0,
		"OWNER":      1,
		"READ":       2,
		"WRITE":      3,
		"EDIT_RULES": 4,
	}
)

Enum value maps for ResourcePolicyAction.

View Source
var (
	ResourcePolicy_PolicyEffect_name = map[int32]string{
		0: "deny",
		1: "allow",
	}
	ResourcePolicy_PolicyEffect_value = map[string]int32{
		"deny":  0,
		"allow": 1,
	}
)

Enum value maps for ResourcePolicy_PolicyEffect.

View Source
var Archiver_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "service.Archiver",
	HandlerType: (*ArchiverServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Archive",
			Handler:    _Archiver_Archive_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cells-service.proto",
}

Archiver_ServiceDesc is the grpc.ServiceDesc for Archiver 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_cells_service_proto protoreflect.FileDescriptor
View Source
var ServiceManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "service.ServiceManager",
	HandlerType: (*ServiceManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Start",
			Handler:    _ServiceManager_Start_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _ServiceManager_Stop_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cells-service.proto",
}

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

Functions

func DeregisterArchiverEnhancedServer

func DeregisterArchiverEnhancedServer(s grpc.ServiceRegistrar, name string)

func DeregisterServiceManagerEnhancedServer

func DeregisterServiceManagerEnhancedServer(s grpc.ServiceRegistrar, name string)

func ReduceQueryBooleans

func ReduceQueryBooleans(results []bool, operation OperationType) bool

ReduceQueryBooleans combines multiple booleans depending on Operation Type

func RegisterArchiverEnhancedServer

func RegisterArchiverEnhancedServer(s grpc.ServiceRegistrar, srv NamedArchiverServer)

func RegisterArchiverServer

func RegisterArchiverServer(s grpc.ServiceRegistrar, srv ArchiverServer)

func RegisterServiceManagerEnhancedServer

func RegisterServiceManagerEnhancedServer(s grpc.ServiceRegistrar, srv NamedServiceManagerServer)

func RegisterServiceManagerServer

func RegisterServiceManagerServer(s grpc.ServiceRegistrar, srv ServiceManagerServer)

Types

type ArchiveResponse

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

func (*ArchiveResponse) Descriptor deprecated

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

Deprecated: Use ArchiveResponse.ProtoReflect.Descriptor instead.

func (*ArchiveResponse) GetOK

func (x *ArchiveResponse) GetOK() bool

func (*ArchiveResponse) ProtoMessage

func (*ArchiveResponse) ProtoMessage()

func (*ArchiveResponse) ProtoReflect

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

func (*ArchiveResponse) Reset

func (x *ArchiveResponse) Reset()

func (*ArchiveResponse) String

func (x *ArchiveResponse) String() string

func (*ArchiveResponse) Validate

func (this *ArchiveResponse) Validate() error

type ArchiverClient

type ArchiverClient interface {
	Archive(ctx context.Context, in *Query, opts ...grpc.CallOption) (*ArchiveResponse, error)
}

ArchiverClient is the client API for Archiver 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 NewArchiverClient

func NewArchiverClient(cc grpc.ClientConnInterface) ArchiverClient

type ArchiverEnhancedServer

type ArchiverEnhancedServer map[string]NamedArchiverServer

func (ArchiverEnhancedServer) Archive

type ArchiverServer

type ArchiverServer interface {
	Archive(context.Context, *Query) (*ArchiveResponse, error)
	// contains filtered or unexported methods
}

ArchiverServer is the server API for Archiver service. All implementations must embed UnimplementedArchiverServer for forward compatibility

type ChangesArchiveQuery

type ChangesArchiveQuery struct {
	RemainingRows uint64 `protobuf:"varint,1,opt,name=RemainingRows,proto3" json:"RemainingRows,omitempty"`
	// contains filtered or unexported fields
}

TODO - move from there

func (*ChangesArchiveQuery) Descriptor deprecated

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

Deprecated: Use ChangesArchiveQuery.ProtoReflect.Descriptor instead.

func (*ChangesArchiveQuery) GetRemainingRows

func (x *ChangesArchiveQuery) GetRemainingRows() uint64

func (*ChangesArchiveQuery) ProtoMessage

func (*ChangesArchiveQuery) ProtoMessage()

func (*ChangesArchiveQuery) ProtoReflect

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

func (*ChangesArchiveQuery) Reset

func (x *ChangesArchiveQuery) Reset()

func (*ChangesArchiveQuery) String

func (x *ChangesArchiveQuery) String() string

func (*ChangesArchiveQuery) Validate

func (this *ChangesArchiveQuery) Validate() error

type Converter

type Converter interface {
	Convert(*anypb.Any) (string, bool)
}

Converter interface

type Matcher

type Matcher interface {
	// Matches tries to apply a *SingleQuery on an existing object
	Matches(object interface{}) bool
}

Matcher interface provides a way to filter idm objects with standard XXXSingleQueries.

type MatcherParser

type MatcherParser func(o *anypb.Any) (Matcher, error)

MatcherParser is a generic function to parse a protobuf into Matcher

type MultiMatcher

type MultiMatcher struct {
	Operation OperationType
	// contains filtered or unexported fields
}

MultiMatcher parses a Query and transform it to a recursive tree of Matches

func (*MultiMatcher) Matches

func (mm *MultiMatcher) Matches(object interface{}) bool

Matches implements the Matcher interface

func (*MultiMatcher) Parse

func (mm *MultiMatcher) Parse(q *Query, parser MatcherParser) error

Parse transforms input query into Matcher interfaces

type NamedArchiverServer

type NamedArchiverServer interface {
	ArchiverServer
	Name() string
}

type NamedServiceManagerServer

type NamedServiceManagerServer interface {
	ServiceManagerServer
	Name() string
}

type OperationType

type OperationType int32
const (
	OperationType_OR  OperationType = 0
	OperationType_AND OperationType = 1
)

func (OperationType) Descriptor

func (OperationType) Enum

func (x OperationType) Enum() *OperationType

func (OperationType) EnumDescriptor deprecated

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

Deprecated: Use OperationType.Descriptor instead.

func (OperationType) Number

func (OperationType) String

func (x OperationType) String() string

func (OperationType) Type

type Query

type Query struct {
	SubQueries          []*anypb.Any         `protobuf:"bytes,1,rep,name=SubQueries,proto3" json:"SubQueries,omitempty"`
	Operation           OperationType        `protobuf:"varint,2,opt,name=Operation,proto3,enum=service.OperationType" json:"Operation,omitempty"`
	ResourcePolicyQuery *ResourcePolicyQuery `protobuf:"bytes,3,opt,name=ResourcePolicyQuery,proto3" json:"ResourcePolicyQuery,omitempty"`
	Offset              int64                `protobuf:"varint,4,opt,name=Offset,proto3" json:"Offset,omitempty"`
	Limit               int64                `protobuf:"varint,5,opt,name=Limit,proto3" json:"Limit,omitempty"`
	GroupBy             int32                `protobuf:"varint,6,opt,name=groupBy,proto3" json:"groupBy,omitempty"`
	// contains filtered or unexported fields
}

func (*Query) Descriptor deprecated

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

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) GetGroupBy

func (x *Query) GetGroupBy() int32

func (*Query) GetLimit

func (x *Query) GetLimit() int64

func (*Query) GetOffset

func (x *Query) GetOffset() int64

func (*Query) GetOperation

func (x *Query) GetOperation() OperationType

func (*Query) GetResourcePolicyQuery

func (x *Query) GetResourcePolicyQuery() *ResourcePolicyQuery

func (*Query) GetSubQueries

func (x *Query) GetSubQueries() []*anypb.Any

func (*Query) ProtoMessage

func (*Query) ProtoMessage()

func (*Query) ProtoReflect

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

func (*Query) Reset

func (x *Query) Reset()

func (*Query) String

func (x *Query) String() string

func (*Query) Validate

func (this *Query) Validate() error

type ResourcePoliciesBuilder

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

ResourcePoliciesBuilder is a helper for building ResourcePolicies lists

func NewResourcePoliciesBuilder

func NewResourcePoliciesBuilder() *ResourcePoliciesBuilder

NewResourcePoliciesBuilder creates a ResourcePoliciesBuilder

func (*ResourcePoliciesBuilder) Policies

func (r *ResourcePoliciesBuilder) Policies() []*ResourcePolicy

Policies returns internal buffer

func (*ResourcePoliciesBuilder) Reset

Reset clears internal buffer

func (*ResourcePoliciesBuilder) WithOwner

func (r *ResourcePoliciesBuilder) WithOwner(userUuid string) *ResourcePoliciesBuilder

WithOwner appends an owner policy with user uuid

func (*ResourcePoliciesBuilder) WithProfileRead

func (r *ResourcePoliciesBuilder) WithProfileRead(profile string) *ResourcePoliciesBuilder

WithProfileRead appends a read policy for profile:profileName

func (*ResourcePoliciesBuilder) WithProfileWrite

func (r *ResourcePoliciesBuilder) WithProfileWrite(profile string) *ResourcePoliciesBuilder

WithProfileWrite appends a write policy for profile:profileName

func (*ResourcePoliciesBuilder) WithResourcePolicy

func (r *ResourcePoliciesBuilder) WithResourcePolicy(policy *ResourcePolicy) *ResourcePoliciesBuilder

WithResourcePolicy appends arbitrary policy

func (*ResourcePoliciesBuilder) WithStandardUserPolicies

func (r *ResourcePoliciesBuilder) WithStandardUserPolicies(userLogin string) *ResourcePoliciesBuilder

WithStandardUserPolicies is a shortcut for WithProfileWrite(profile:admin).WithProfileRead(profile:standard).WithUserWrite(userLogin)

func (*ResourcePoliciesBuilder) WithUserRead

func (r *ResourcePoliciesBuilder) WithUserRead(login string) *ResourcePoliciesBuilder

WithUserRead appends a read policy for this user:login

func (*ResourcePoliciesBuilder) WithUserWrite

func (r *ResourcePoliciesBuilder) WithUserWrite(login string) *ResourcePoliciesBuilder

WithUserWrite appends a write policy for user:login

type ResourcePolicy

type ResourcePolicy struct {
	Id             int64                       `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Resource       string                      `protobuf:"bytes,2,opt,name=Resource,proto3" json:"Resource,omitempty"`
	Action         ResourcePolicyAction        `protobuf:"varint,3,opt,name=Action,proto3,enum=service.ResourcePolicyAction" json:"Action,omitempty"`
	Subject        string                      `protobuf:"bytes,4,opt,name=Subject,proto3" json:"Subject,omitempty"`
	Effect         ResourcePolicy_PolicyEffect `protobuf:"varint,5,opt,name=Effect,proto3,enum=service.ResourcePolicy_PolicyEffect" json:"Effect,omitempty"`
	JsonConditions string                      `protobuf:"bytes,6,opt,name=JsonConditions,proto3" json:"JsonConditions,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourcePolicy) Descriptor deprecated

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

Deprecated: Use ResourcePolicy.ProtoReflect.Descriptor instead.

func (*ResourcePolicy) GetAction

func (x *ResourcePolicy) GetAction() ResourcePolicyAction

func (*ResourcePolicy) GetEffect

func (*ResourcePolicy) GetId

func (x *ResourcePolicy) GetId() int64

func (*ResourcePolicy) GetJsonConditions

func (x *ResourcePolicy) GetJsonConditions() string

func (*ResourcePolicy) GetResource

func (x *ResourcePolicy) GetResource() string

func (*ResourcePolicy) GetSubject

func (x *ResourcePolicy) GetSubject() string

func (*ResourcePolicy) ProtoMessage

func (*ResourcePolicy) ProtoMessage()

func (*ResourcePolicy) ProtoReflect

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

func (*ResourcePolicy) Reset

func (x *ResourcePolicy) Reset()

func (*ResourcePolicy) String

func (x *ResourcePolicy) String() string

func (*ResourcePolicy) Validate

func (this *ResourcePolicy) Validate() error

type ResourcePolicyAction

type ResourcePolicyAction int32
const (
	ResourcePolicyAction_ANY        ResourcePolicyAction = 0
	ResourcePolicyAction_OWNER      ResourcePolicyAction = 1
	ResourcePolicyAction_READ       ResourcePolicyAction = 2
	ResourcePolicyAction_WRITE      ResourcePolicyAction = 3
	ResourcePolicyAction_EDIT_RULES ResourcePolicyAction = 4
)

func (ResourcePolicyAction) Descriptor

func (ResourcePolicyAction) Enum

func (ResourcePolicyAction) EnumDescriptor deprecated

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

Deprecated: Use ResourcePolicyAction.Descriptor instead.

func (ResourcePolicyAction) Number

func (ResourcePolicyAction) String

func (x ResourcePolicyAction) String() string

func (ResourcePolicyAction) Type

type ResourcePolicyQuery

type ResourcePolicyQuery struct {
	Subjects []string `protobuf:"bytes,1,rep,name=Subjects,proto3" json:"Subjects,omitempty"`
	Empty    bool     `protobuf:"varint,2,opt,name=Empty,proto3" json:"Empty,omitempty"`
	Any      bool     `protobuf:"varint,3,opt,name=Any,proto3" json:"Any,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourcePolicyQuery) Descriptor deprecated

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

Deprecated: Use ResourcePolicyQuery.ProtoReflect.Descriptor instead.

func (*ResourcePolicyQuery) GetAny

func (x *ResourcePolicyQuery) GetAny() bool

func (*ResourcePolicyQuery) GetEmpty

func (x *ResourcePolicyQuery) GetEmpty() bool

func (*ResourcePolicyQuery) GetSubjects

func (x *ResourcePolicyQuery) GetSubjects() []string

func (*ResourcePolicyQuery) ProtoMessage

func (*ResourcePolicyQuery) ProtoMessage()

func (*ResourcePolicyQuery) ProtoReflect

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

func (*ResourcePolicyQuery) Reset

func (x *ResourcePolicyQuery) Reset()

func (*ResourcePolicyQuery) String

func (x *ResourcePolicyQuery) String() string

func (*ResourcePolicyQuery) Validate

func (this *ResourcePolicyQuery) Validate() error

type ResourcePolicy_PolicyEffect

type ResourcePolicy_PolicyEffect int32
const (
	ResourcePolicy_deny  ResourcePolicy_PolicyEffect = 0
	ResourcePolicy_allow ResourcePolicy_PolicyEffect = 1
)

func (ResourcePolicy_PolicyEffect) Descriptor

func (ResourcePolicy_PolicyEffect) Enum

func (ResourcePolicy_PolicyEffect) EnumDescriptor deprecated

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

Deprecated: Use ResourcePolicy_PolicyEffect.Descriptor instead.

func (ResourcePolicy_PolicyEffect) Number

func (ResourcePolicy_PolicyEffect) String

func (ResourcePolicy_PolicyEffect) Type

type ServiceManagerClient

type ServiceManagerClient interface {
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
	Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
}

ServiceManagerClient is the client API for ServiceManager 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.

type ServiceManagerEnhancedServer

type ServiceManagerEnhancedServer map[string]NamedServiceManagerServer

func (ServiceManagerEnhancedServer) Start

func (ServiceManagerEnhancedServer) Stop

type ServiceManagerServer

type ServiceManagerServer interface {
	Start(context.Context, *StartRequest) (*StartResponse, error)
	Stop(context.Context, *StopRequest) (*StopResponse, error)
	// contains filtered or unexported methods
}

ServiceManagerServer is the server API for ServiceManager service. All implementations must embed UnimplementedServiceManagerServer for forward compatibility

type StartRequest

type StartRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*StartRequest) Descriptor deprecated

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

Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.

func (*StartRequest) GetName

func (x *StartRequest) GetName() string

func (*StartRequest) ProtoMessage

func (*StartRequest) ProtoMessage()

func (*StartRequest) ProtoReflect

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

func (*StartRequest) Reset

func (x *StartRequest) Reset()

func (*StartRequest) String

func (x *StartRequest) String() string

func (*StartRequest) Validate

func (this *StartRequest) Validate() error

type StartResponse

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

func (*StartResponse) Descriptor deprecated

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

Deprecated: Use StartResponse.ProtoReflect.Descriptor instead.

func (*StartResponse) GetOK

func (x *StartResponse) GetOK() bool

func (*StartResponse) ProtoMessage

func (*StartResponse) ProtoMessage()

func (*StartResponse) ProtoReflect

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

func (*StartResponse) Reset

func (x *StartResponse) Reset()

func (*StartResponse) String

func (x *StartResponse) String() string

func (*StartResponse) Validate

func (this *StartResponse) Validate() error

type StopRequest

type StopRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*StopRequest) Descriptor deprecated

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

Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.

func (*StopRequest) GetName

func (x *StopRequest) GetName() string

func (*StopRequest) ProtoMessage

func (*StopRequest) ProtoMessage()

func (*StopRequest) ProtoReflect

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

func (*StopRequest) Reset

func (x *StopRequest) Reset()

func (*StopRequest) String

func (x *StopRequest) String() string

func (*StopRequest) Validate

func (this *StopRequest) Validate() error

type StopResponse

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

func (*StopResponse) Descriptor deprecated

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

Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.

func (*StopResponse) GetOK

func (x *StopResponse) GetOK() bool

func (*StopResponse) ProtoMessage

func (*StopResponse) ProtoMessage()

func (*StopResponse) ProtoReflect

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

func (*StopResponse) Reset

func (x *StopResponse) Reset()

func (*StopResponse) String

func (x *StopResponse) String() string

func (*StopResponse) Validate

func (this *StopResponse) Validate() error

type UnimplementedArchiverServer

type UnimplementedArchiverServer struct {
}

UnimplementedArchiverServer must be embedded to have forward compatible implementations.

func (UnimplementedArchiverServer) Archive

type UnimplementedServiceManagerServer

type UnimplementedServiceManagerServer struct {
}

UnimplementedServiceManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedServiceManagerServer) Start

func (UnimplementedServiceManagerServer) Stop

type UnsafeArchiverServer

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

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

type UnsafeServiceManagerServer

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

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

Jump to

Keyboard shortcuts

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