service

package
v4.1.1 Latest Latest
Warning

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

 Go to latest Published: Mar 6, 2023 License: AGPL-3.0 Imports: 16 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 

func (m ArchiverEnhancedServer) Archive(ctx context.Context, r *Query) (*ArchiveResponse, error)

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 Error added in v4.0.7 

type Error struct {
	ID      string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Code    uint32 `protobuf:"varint,2,opt,name=Code,proto3" json:"Code,omitempty"`
	Status  string `protobuf:"bytes,3,opt,name=Status,proto3" json:"Status,omitempty"`
	Details string `protobuf:"bytes,4,opt,name=Details,proto3" json:"Details,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated added in v4.0.7 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetCode added in v4.0.7 

func (x *Error) GetCode() uint32

func (*Error) GetDetails added in v4.0.7 

func (x *Error) GetDetails() string

func (*Error) GetID added in v4.0.7 

func (x *Error) GetID() string

func (*Error) GetStatus added in v4.0.7 

func (x *Error) GetStatus() string

func (*Error) ProtoMessage added in v4.0.7 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect added in v4.0.7 

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

func (*Error) Reset added in v4.0.7 

func (x *Error) Reset()

func (*Error) String added in v4.0.7 

func (x *Error) String() string

func (*Error) Validate added in v4.0.7 

func (this *Error) Validate() error

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) Descriptor() protoreflect.EnumDescriptor

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 (x OperationType) Number() protoreflect.EnumNumber

func (OperationType) String 

func (x OperationType) String() string

func (OperationType) Type 

func (OperationType) Type() protoreflect.EnumType

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 

func (r *ResourcePoliciesBuilder) Reset() *ResourcePoliciesBuilder

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 (x *ResourcePolicy) GetEffect() ResourcePolicy_PolicyEffect

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) Descriptor() protoreflect.EnumDescriptor

func (ResourcePolicyAction) Enum 

func (x ResourcePolicyAction) Enum() *ResourcePolicyAction

func (ResourcePolicyAction) EnumDescriptor deprecated 

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

Deprecated: Use ResourcePolicyAction.Descriptor instead.

func (ResourcePolicyAction) Number 

func (x ResourcePolicyAction) Number() protoreflect.EnumNumber

func (ResourcePolicyAction) String 

func (x ResourcePolicyAction) String() string

func (ResourcePolicyAction) Type 

func (ResourcePolicyAction) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

func (ResourcePolicy_PolicyEffect) Enum 

func (x ResourcePolicy_PolicyEffect) Enum() *ResourcePolicy_PolicyEffect

func (ResourcePolicy_PolicyEffect) EnumDescriptor deprecated 

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

Deprecated: Use ResourcePolicy_PolicyEffect.Descriptor instead.

func (ResourcePolicy_PolicyEffect) Number 

func (x ResourcePolicy_PolicyEffect) Number() protoreflect.EnumNumber

func (ResourcePolicy_PolicyEffect) String 

func (x ResourcePolicy_PolicyEffect) String() string

func (ResourcePolicy_PolicyEffect) Type 

func (ResourcePolicy_PolicyEffect) Type() protoreflect.EnumType

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.

func NewServiceManagerClient 

func NewServiceManagerClient(cc grpc.ClientConnInterface) ServiceManagerClient

type ServiceManagerEnhancedServer 

type ServiceManagerEnhancedServer map[string]NamedServiceManagerServer

func (ServiceManagerEnhancedServer) Start 

func (m ServiceManagerEnhancedServer) Start(ctx context.Context, r *StartRequest) (*StartResponse, error)

func (ServiceManagerEnhancedServer) Stop 

func (m ServiceManagerEnhancedServer) Stop(ctx context.Context, r *StopRequest) (*StopResponse, error)

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 

func (UnimplementedArchiverServer) Archive(context.Context, *Query) (*ArchiveResponse, error)

type UnimplementedServiceManagerServer 

type UnimplementedServiceManagerServer struct {
}

UnimplementedServiceManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedServiceManagerServer) Start 

func (UnimplementedServiceManagerServer) Start(context.Context, *StartRequest) (*StartResponse, error)

func (UnimplementedServiceManagerServer) Stop 

func (UnimplementedServiceManagerServer) Stop(context.Context, *StopRequest) (*StopResponse, error)

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.

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.