corredor

package
v0.0.0-...-7687a33 Latest Latest
Warning

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

 Go to latest Published: Sep 16, 2024 License: Apache-2.0 Imports: 30 Imported by: 0

README 

# pkg/corredor

This package is an interface to Corredor script runner service.

.It provides:
 - Connection to Corredor service
 - Subscriber service to handle events raised from Corteza services
 - Scheduling service for deferred events (scheduled, interval)

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_service_corredor_proto protoreflect.FileDescriptor
View Source 
var (
	ScriptExecAborted = errors.Plain(errors.KindAutomation, "aborted")
)

Functions

func GenericBundleHandler 

func GenericBundleHandler(ctx context.Context, svc *service, bundleName, bundleType, ext string) (interface{}, error)

func GenericListHandler 

func GenericListHandler(ctx context.Context, svc *service, f Filter, resourcePrefix string) (p *automationListSetPayload, err error)

GenericListHandler returns filtered list of scripts

func Healthcheck 

func Healthcheck(_ context.Context) error

Healtcheck for global

func NewConnection 

func NewConnection(ctx context.Context, opt options.CorredorOpt, logger *zap.Logger) (c *grpc.ClientConn, err error)

Corredor standard connector to Corredor service via gRPC

func NewService 

func NewService(logger *zap.Logger, opt options.CorredorOpt) *service

func RegisterClientScriptsServer 

func RegisterClientScriptsServer(s *grpc.Server, srv ClientScriptsServer)

func RegisterServerScriptsServer 

func RegisterServerScriptsServer(s *grpc.Server, srv ServerScriptsServer)

func RegisterStorageServer 

func RegisterStorageServer(s *grpc.Server, srv StorageServer)

func Service 

func Service() *service

func Setup 

func Setup(logger *zap.Logger, opt options.CorredorOpt) (err error)

Setup start connects to Corredor & initialize service

Types

type Bundle 

type Bundle struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Code string `protobuf:"bytes,3,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*Bundle) Descriptor deprecated 

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

Deprecated: Use Bundle.ProtoReflect.Descriptor instead.

func (*Bundle) GetCode 

func (x *Bundle) GetCode() string

func (*Bundle) GetName 

func (x *Bundle) GetName() string

func (*Bundle) GetType 

func (x *Bundle) GetType() string

func (*Bundle) ProtoMessage 

func (*Bundle) ProtoMessage()

func (*Bundle) ProtoReflect 

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

func (*Bundle) Reset 

func (x *Bundle) Reset()

func (*Bundle) String 

func (x *Bundle) String() string

type BundleRequest 

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

func (*BundleRequest) Descriptor deprecated 

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

Deprecated: Use BundleRequest.ProtoReflect.Descriptor instead.

func (*BundleRequest) GetName 

func (x *BundleRequest) GetName() string

func (*BundleRequest) ProtoMessage 

func (*BundleRequest) ProtoMessage()

func (*BundleRequest) ProtoReflect 

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

func (*BundleRequest) Reset 

func (x *BundleRequest) Reset()

func (*BundleRequest) String 

func (x *BundleRequest) String() string

type BundleResponse 

type BundleResponse struct {
	Bundles []*Bundle `protobuf:"bytes,1,rep,name=bundles,proto3" json:"bundles,omitempty"`
	// contains filtered or unexported fields
}

func (*BundleResponse) Descriptor deprecated 

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

Deprecated: Use BundleResponse.ProtoReflect.Descriptor instead.

func (*BundleResponse) GetBundles 

func (x *BundleResponse) GetBundles() []*Bundle

func (*BundleResponse) ProtoMessage 

func (*BundleResponse) ProtoMessage()

func (*BundleResponse) ProtoReflect 

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

func (*BundleResponse) Reset 

func (x *BundleResponse) Reset()

func (*BundleResponse) String 

func (x *BundleResponse) String() string

type ClientScript 

type ClientScript struct {
	Name        string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Label       string     `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Description string     `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Bundle      string     `protobuf:"bytes,4,opt,name=bundle,proto3" json:"bundle,omitempty"`
	Type        string     `protobuf:"bytes,6,opt,name=type,proto3" json:"type,omitempty"`
	UpdatedAt   string     `protobuf:"bytes,12,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	Security    *Security  `protobuf:"bytes,13,opt,name=security,proto3" json:"security,omitempty"`
	Triggers    []*Trigger `protobuf:"bytes,14,rep,name=triggers,proto3" json:"triggers,omitempty"`
	Errors      []string   `protobuf:"bytes,15,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientScript) Descriptor deprecated 

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

Deprecated: Use ClientScript.ProtoReflect.Descriptor instead.

func (*ClientScript) GetBundle 

func (x *ClientScript) GetBundle() string

func (*ClientScript) GetDescription 

func (x *ClientScript) GetDescription() string

func (*ClientScript) GetErrors 

func (x *ClientScript) GetErrors() []string

func (*ClientScript) GetLabel 

func (x *ClientScript) GetLabel() string

func (*ClientScript) GetName 

func (x *ClientScript) GetName() string

func (*ClientScript) GetSecurity 

func (x *ClientScript) GetSecurity() *Security

func (*ClientScript) GetTriggers 

func (x *ClientScript) GetTriggers() []*Trigger

func (*ClientScript) GetType 

func (x *ClientScript) GetType() string

func (*ClientScript) GetUpdatedAt 

func (x *ClientScript) GetUpdatedAt() string

func (*ClientScript) ProtoMessage 

func (*ClientScript) ProtoMessage()

func (*ClientScript) ProtoReflect 

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

func (*ClientScript) Reset 

func (x *ClientScript) Reset()

func (*ClientScript) String 

func (x *ClientScript) String() string

type ClientScriptListRequest 

type ClientScriptListRequest struct {

	// query by name, label, description
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// filter by resource - exact match
	ResourceType string `protobuf:"bytes,2,opt,name=resourceType,proto3" json:"resourceType,omitempty"`
	// filter by events - script must contain all specified events
	EventTypes []string `protobuf:"bytes,3,rep,name=eventTypes,proto3" json:"eventTypes,omitempty"`
	// filter by bundle - exact match
	Bundle string `protobuf:"bytes,4,opt,name=bundle,proto3" json:"bundle,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientScriptListRequest) Descriptor deprecated 

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

Deprecated: Use ClientScriptListRequest.ProtoReflect.Descriptor instead.

func (*ClientScriptListRequest) GetBundle 

func (x *ClientScriptListRequest) GetBundle() string

func (*ClientScriptListRequest) GetEventTypes 

func (x *ClientScriptListRequest) GetEventTypes() []string

func (*ClientScriptListRequest) GetQuery 

func (x *ClientScriptListRequest) GetQuery() string

func (*ClientScriptListRequest) GetResourceType 

func (x *ClientScriptListRequest) GetResourceType() string

func (*ClientScriptListRequest) ProtoMessage 

func (*ClientScriptListRequest) ProtoMessage()

func (*ClientScriptListRequest) ProtoReflect 

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

func (*ClientScriptListRequest) Reset 

func (x *ClientScriptListRequest) Reset()

func (*ClientScriptListRequest) String 

func (x *ClientScriptListRequest) String() string

type ClientScriptListResponse 

type ClientScriptListResponse struct {
	Scripts []*ClientScript `protobuf:"bytes,1,rep,name=scripts,proto3" json:"scripts,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientScriptListResponse) Descriptor deprecated 

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

Deprecated: Use ClientScriptListResponse.ProtoReflect.Descriptor instead.

func (*ClientScriptListResponse) GetScripts 

func (x *ClientScriptListResponse) GetScripts() []*ClientScript

func (*ClientScriptListResponse) ProtoMessage 

func (*ClientScriptListResponse) ProtoMessage()

func (*ClientScriptListResponse) ProtoReflect 

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

func (*ClientScriptListResponse) Reset 

func (x *ClientScriptListResponse) Reset()

func (*ClientScriptListResponse) String 

func (x *ClientScriptListResponse) String() string

type ClientScriptsClient 

type ClientScriptsClient interface {
	// Bundles
	Bundle(ctx context.Context, in *BundleRequest, opts ...grpc.CallOption) (*BundleResponse, error)
	// List of client scripts
	List(ctx context.Context, in *ClientScriptListRequest, opts ...grpc.CallOption) (*ClientScriptListResponse, error)
}

ClientScriptsClient is the client API for ClientScripts 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 NewClientScriptsClient 

func NewClientScriptsClient(cc grpc.ClientConnInterface) ClientScriptsClient

type ClientScriptsServer 

type ClientScriptsServer interface {
	// Bundles
	Bundle(context.Context, *BundleRequest) (*BundleResponse, error)
	// List of client scripts
	List(context.Context, *ClientScriptListRequest) (*ClientScriptListResponse, error)
	// contains filtered or unexported methods
}

ClientScriptsServer is the server API for ClientScripts service. All implementations must embed UnimplementedClientScriptsServer for forward compatibility

type ExecRequest 

type ExecRequest struct {
	Name string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Args map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecRequest) Descriptor deprecated 

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

Deprecated: Use ExecRequest.ProtoReflect.Descriptor instead.

func (*ExecRequest) GetArgs 

func (x *ExecRequest) GetArgs() map[string]string

func (*ExecRequest) GetName 

func (x *ExecRequest) GetName() string

func (*ExecRequest) ProtoMessage 

func (*ExecRequest) ProtoMessage()

func (*ExecRequest) ProtoReflect 

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

func (*ExecRequest) Reset 

func (x *ExecRequest) Reset()

func (*ExecRequest) String 

func (x *ExecRequest) String() string

type ExecResponse 

type ExecResponse struct {
	Result map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecResponse) Descriptor deprecated 

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

Deprecated: Use ExecResponse.ProtoReflect.Descriptor instead.

func (*ExecResponse) GetResult 

func (x *ExecResponse) GetResult() map[string]string

func (*ExecResponse) ProtoMessage 

func (*ExecResponse) ProtoMessage()

func (*ExecResponse) ProtoReflect 

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

func (*ExecResponse) Reset 

func (x *ExecResponse) Reset()

func (*ExecResponse) String 

func (x *ExecResponse) String() string

type Filter 

type Filter struct {
	ResourceTypePrefixes []string `json:"resourceTypePrefixes"`
	ResourceTypes        []string `json:"resourceTypes"`
	EventTypes           []string `json:"eventTypes"`
	ExcludeServerScripts bool     `json:"excludeServerScripts"`
	ExcludeClientScripts bool     `json:"excludeClientScripts"`
	ExcludeInvalid       bool     `json:"excludeInvalid"`

	//Page    uint `json:"page"`
	//PerPage uint `json:"perPage"`
	Count uint `json:"count"`
}

type Iterator 

type Iterator struct {
	EventType    string            `protobuf:"bytes,1,opt,name=eventType,proto3" json:"eventType,omitempty"`
	ResourceType string            `protobuf:"bytes,2,opt,name=resourceType,proto3" json:"resourceType,omitempty"`
	Deferred     []string          `protobuf:"bytes,3,rep,name=deferred,proto3" json:"deferred,omitempty"`
	Filter       map[string]string `` /* 153-byte string literal not displayed */
	Action       string            `protobuf:"bytes,5,opt,name=action,proto3" json:"action,omitempty"`
	UiProps      []*TUIProp        `protobuf:"bytes,14,rep,name=uiProps,proto3" json:"uiProps,omitempty"`
	// contains filtered or unexported fields
}

func (*Iterator) Descriptor deprecated 

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

Deprecated: Use Iterator.ProtoReflect.Descriptor instead.

func (*Iterator) GetAction 

func (x *Iterator) GetAction() string

func (*Iterator) GetDeferred 

func (x *Iterator) GetDeferred() []string

func (*Iterator) GetEventType 

func (x *Iterator) GetEventType() string

func (*Iterator) GetFilter 

func (x *Iterator) GetFilter() map[string]string

func (*Iterator) GetResourceType 

func (x *Iterator) GetResourceType() string

func (*Iterator) GetUiProps 

func (x *Iterator) GetUiProps() []*TUIProp

func (*Iterator) ProtoMessage 

func (*Iterator) ProtoMessage()

func (*Iterator) ProtoReflect 

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

func (*Iterator) Reset 

func (x *Iterator) Reset()

func (*Iterator) String 

func (x *Iterator) String() string

type IteratorResourceFinder 

type IteratorResourceFinder func(ctx context.Context, f map[string]string, h eventbus.HandlerFn, action string) error

IteratorResourceFinder acts as a middleware that converts iteration request to appropriate resource iterator (eg: Record Finder)

type Script 

type Script struct {
	Name        string          `json:"name"`
	Label       string          `json:"label"`
	Description string          `json:"description"`
	Errors      []string        `json:"errors,omitempty"`
	Triggers    []*Trigger      `json:"triggers"`
	Iterator    *Iterator       `json:"iterator"`
	Security    *ScriptSecurity `json:"security"`
	UpdatedAt   string          `json:"updatedAt,omitempty"`

	// If bundle or type is set, consider
	// this a frontend script
	Bundle string `json:"bundle,omitempty"`
	Type   string `json:"type,omitempty"`
}

type ScriptArgs 

type ScriptArgs interface {
	eventbus.Event

	// Encode (event) to arguments passed to
	// event handlers ([automation ]script runner)
	Encode() (map[string][]byte, error)

	// Decodes received data back to event
	Decode(map[string][]byte) error
}

func ExtendScriptArgs 

func ExtendScriptArgs(ev ScriptArgs, args map[string]interface{}) ScriptArgs

type ScriptSecurity 

type ScriptSecurity struct {
	*Security
	// contains filtered or unexported fields
}

ScriptSecurity sets script security and run-as flag

Determinate user (if >0) that script will run under and allow/deny combination for roles that can see & execute explicit (onManual) scripts

Please note that implicit scripts cannot have RBAC protection! These scripts are always executed as configured no mather who runs them.

func (*ScriptSecurity) String 

func (ss *ScriptSecurity) String() (o string)

String fn to make logging a bit friendlier

type ScriptSet 

type ScriptSet []*Script

ScriptSet slice of Script

This type is auto-generated.

func (ScriptSet) Filter 

func (set ScriptSet) Filter(f func(*Script) (bool, error)) (out ScriptSet, err error)

Filter iterates through every slice item, calls f(Script) (bool, err) and return filtered slice

This function is auto-generated.

func (ScriptSet) FindByName 

func (set ScriptSet) FindByName(name string) *Script

FindByName returns script from the set if it exists

func (ScriptSet) Walk 

func (set ScriptSet) Walk(w func(*Script) error) (err error)

Walk iterates through every slice item and calls w(Script) err

This function is auto-generated.

type Security 

type Security struct {
	RunAs string   `protobuf:"bytes,1,opt,name=runAs,proto3" json:"runAs,omitempty"`
	Deny  []string `protobuf:"bytes,2,rep,name=deny,proto3" json:"deny,omitempty"`
	Allow []string `protobuf:"bytes,3,rep,name=allow,proto3" json:"allow,omitempty"`
	// contains filtered or unexported fields
}

func (*Security) Descriptor deprecated 

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

Deprecated: Use Security.ProtoReflect.Descriptor instead.

func (*Security) GetAllow 

func (x *Security) GetAllow() []string

func (*Security) GetDeny 

func (x *Security) GetDeny() []string

func (*Security) GetRunAs 

func (x *Security) GetRunAs() string

func (*Security) ProtoMessage 

func (*Security) ProtoMessage()

func (*Security) ProtoReflect 

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

func (*Security) Reset 

func (x *Security) Reset()

func (*Security) String 

func (x *Security) String() string

type ServerScript 

type ServerScript struct {
	Name        string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Label       string     `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Description string     `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	UpdatedAt   string     `protobuf:"bytes,12,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	Security    *Security  `protobuf:"bytes,13,opt,name=security,proto3" json:"security,omitempty"`
	Triggers    []*Trigger `protobuf:"bytes,14,rep,name=triggers,proto3" json:"triggers,omitempty"`
	Iterator    *Iterator  `protobuf:"bytes,11,opt,name=iterator,proto3" json:"iterator,omitempty"`
	Errors      []string   `protobuf:"bytes,15,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerScript) Descriptor deprecated 

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

Deprecated: Use ServerScript.ProtoReflect.Descriptor instead.

func (*ServerScript) GetDescription 

func (x *ServerScript) GetDescription() string

func (*ServerScript) GetErrors 

func (x *ServerScript) GetErrors() []string

func (*ServerScript) GetIterator 

func (x *ServerScript) GetIterator() *Iterator

func (*ServerScript) GetLabel 

func (x *ServerScript) GetLabel() string

func (*ServerScript) GetName 

func (x *ServerScript) GetName() string

func (*ServerScript) GetSecurity 

func (x *ServerScript) GetSecurity() *Security

func (*ServerScript) GetTriggers 

func (x *ServerScript) GetTriggers() []*Trigger

func (*ServerScript) GetUpdatedAt 

func (x *ServerScript) GetUpdatedAt() string

func (*ServerScript) ProtoMessage 

func (*ServerScript) ProtoMessage()

func (*ServerScript) ProtoReflect 

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

func (*ServerScript) Reset 

func (x *ServerScript) Reset()

func (*ServerScript) String 

func (x *ServerScript) String() string

type ServerScriptListRequest 

type ServerScriptListRequest struct {

	// query by name, label, description
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// filter by resource - exact match
	ResourceType string `protobuf:"bytes,2,opt,name=resourceType,proto3" json:"resourceType,omitempty"`
	// filter by events - script must contain all specified events
	EventTypes []string `protobuf:"bytes,3,rep,name=eventTypes,proto3" json:"eventTypes,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerScriptListRequest) Descriptor deprecated 

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

Deprecated: Use ServerScriptListRequest.ProtoReflect.Descriptor instead.

func (*ServerScriptListRequest) GetEventTypes 

func (x *ServerScriptListRequest) GetEventTypes() []string

func (*ServerScriptListRequest) GetQuery 

func (x *ServerScriptListRequest) GetQuery() string

func (*ServerScriptListRequest) GetResourceType 

func (x *ServerScriptListRequest) GetResourceType() string

func (*ServerScriptListRequest) ProtoMessage 

func (*ServerScriptListRequest) ProtoMessage()

func (*ServerScriptListRequest) ProtoReflect 

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

func (*ServerScriptListRequest) Reset 

func (x *ServerScriptListRequest) Reset()

func (*ServerScriptListRequest) String 

func (x *ServerScriptListRequest) String() string

type ServerScriptListResponse 

type ServerScriptListResponse struct {
	Scripts []*ServerScript `protobuf:"bytes,1,rep,name=scripts,proto3" json:"scripts,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerScriptListResponse) Descriptor deprecated 

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

Deprecated: Use ServerScriptListResponse.ProtoReflect.Descriptor instead.

func (*ServerScriptListResponse) GetScripts 

func (x *ServerScriptListResponse) GetScripts() []*ServerScript

func (*ServerScriptListResponse) ProtoMessage 

func (*ServerScriptListResponse) ProtoMessage()

func (*ServerScriptListResponse) ProtoReflect 

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

func (*ServerScriptListResponse) Reset 

func (x *ServerScriptListResponse) Reset()

func (*ServerScriptListResponse) String 

func (x *ServerScriptListResponse) String() string

type ServerScriptsClient 

type ServerScriptsClient interface {
	// Executes server script
	Exec(ctx context.Context, in *ExecRequest, opts ...grpc.CallOption) (*ExecResponse, error)
	// List of server scripts
	List(ctx context.Context, in *ServerScriptListRequest, opts ...grpc.CallOption) (*ServerScriptListResponse, error)
}

ServerScriptsClient is the client API for ServerScripts 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 NewServerScriptsClient 

func NewServerScriptsClient(cc grpc.ClientConnInterface) ServerScriptsClient

type ServerScriptsServer 

type ServerScriptsServer interface {
	// Executes server script
	Exec(context.Context, *ExecRequest) (*ExecResponse, error)
	// List of server scripts
	List(context.Context, *ServerScriptListRequest) (*ServerScriptListResponse, error)
	// contains filtered or unexported methods
}

ServerScriptsServer is the server API for ServerScripts service. All implementations must embed UnimplementedServerScriptsServer for forward compatibility

type StorageClient 

type StorageClient interface {
}

StorageClient is the client API for Storage 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 NewStorageClient 

func NewStorageClient(cc grpc.ClientConnInterface) StorageClient

type StorageServer 

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

StorageServer is the server API for Storage service. All implementations must embed UnimplementedStorageServer for forward compatibility

type TConstraint 

type TConstraint struct {
	Name  string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Op    string   `protobuf:"bytes,2,opt,name=op,proto3" json:"op,omitempty"`
	Value []string `protobuf:"bytes,3,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*TConstraint) Descriptor deprecated 

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

Deprecated: Use TConstraint.ProtoReflect.Descriptor instead.

func (*TConstraint) GetName 

func (x *TConstraint) GetName() string

func (*TConstraint) GetOp 

func (x *TConstraint) GetOp() string

func (*TConstraint) GetValue 

func (x *TConstraint) GetValue() []string

func (*TConstraint) ProtoMessage 

func (*TConstraint) ProtoMessage()

func (*TConstraint) ProtoReflect 

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

func (*TConstraint) Reset 

func (x *TConstraint) Reset()

func (*TConstraint) String 

func (x *TConstraint) String() string

type TUIProp 

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

func (*TUIProp) Descriptor deprecated 

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

Deprecated: Use TUIProp.ProtoReflect.Descriptor instead.

func (*TUIProp) GetName 

func (x *TUIProp) GetName() string

func (*TUIProp) GetValue 

func (x *TUIProp) GetValue() string

func (*TUIProp) ProtoMessage 

func (*TUIProp) ProtoMessage()

func (*TUIProp) ProtoReflect 

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

func (*TUIProp) Reset 

func (x *TUIProp) Reset()

func (*TUIProp) String 

func (x *TUIProp) String() string

type Trigger 

type Trigger struct {
	EventTypes    []string       `protobuf:"bytes,1,rep,name=eventTypes,proto3" json:"eventTypes,omitempty"`
	ResourceTypes []string       `protobuf:"bytes,2,rep,name=resourceTypes,proto3" json:"resourceTypes,omitempty"`
	UiProps       []*TUIProp     `protobuf:"bytes,14,rep,name=uiProps,proto3" json:"uiProps,omitempty"`
	Constraints   []*TConstraint `protobuf:"bytes,15,rep,name=constraints,proto3" json:"constraints,omitempty"`
	// contains filtered or unexported fields
}

func (*Trigger) Descriptor deprecated 

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

Deprecated: Use Trigger.ProtoReflect.Descriptor instead.

func (*Trigger) GetConstraints 

func (x *Trigger) GetConstraints() []*TConstraint

func (*Trigger) GetEventTypes 

func (x *Trigger) GetEventTypes() []string

func (*Trigger) GetResourceTypes 

func (x *Trigger) GetResourceTypes() []string

func (*Trigger) GetUiProps 

func (x *Trigger) GetUiProps() []*TUIProp

func (*Trigger) ProtoMessage 

func (*Trigger) ProtoMessage()

func (*Trigger) ProtoReflect 

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

func (*Trigger) Reset 

func (x *Trigger) Reset()

func (*Trigger) String 

func (x *Trigger) String() string

type UnimplementedClientScriptsServer 

type UnimplementedClientScriptsServer struct {
}

UnimplementedClientScriptsServer must be embedded to have forward compatible implementations.

func (UnimplementedClientScriptsServer) Bundle 

func (UnimplementedClientScriptsServer) Bundle(context.Context, *BundleRequest) (*BundleResponse, error)

func (UnimplementedClientScriptsServer) List 

func (UnimplementedClientScriptsServer) List(context.Context, *ClientScriptListRequest) (*ClientScriptListResponse, error)

type UnimplementedServerScriptsServer 

type UnimplementedServerScriptsServer struct {
}

UnimplementedServerScriptsServer must be embedded to have forward compatible implementations.

func (UnimplementedServerScriptsServer) Exec 

func (UnimplementedServerScriptsServer) Exec(context.Context, *ExecRequest) (*ExecResponse, error)

func (UnimplementedServerScriptsServer) List 

func (UnimplementedServerScriptsServer) List(context.Context, *ServerScriptListRequest) (*ServerScriptListResponse, error)

type UnimplementedStorageServer 

type UnimplementedStorageServer struct {
}

UnimplementedStorageServer must be embedded to have forward compatible implementations.

type UnsafeClientScriptsServer 

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

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

type UnsafeServerScriptsServer 

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

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

type UnsafeStorageServer 

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

UnsafeStorageServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StorageServer 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.