optimus

package
v0.8.5 Latest Latest
Warning

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

 Go to latest Published: Aug 4, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DependencyResolverModService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gotocompany.optimus.plugins.v1beta1.DependencyResolverModService",
	HandlerType: (*DependencyResolverModServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetName",
			Handler:    _DependencyResolverModService_GetName_Handler,
		},
		{
			MethodName: "GenerateDestination",
			Handler:    _DependencyResolverModService_GenerateDestination_Handler,
		},
		{
			MethodName: "GenerateDependencies",
			Handler:    _DependencyResolverModService_GenerateDependencies_Handler,
		},
		{
			MethodName: "CompileAssets",
			Handler:    _DependencyResolverModService_CompileAssets_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gotocompany/optimus/plugins/v1beta1/dependency_resolver.proto",
}

DependencyResolverModService_ServiceDesc is the grpc.ServiceDesc for DependencyResolverModService 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_gotocompany_optimus_plugins_v1beta1_dependency_resolver_proto protoreflect.FileDescriptor

Functions

func RegisterDependencyResolverModServiceServer 

func RegisterDependencyResolverModServiceServer(s grpc.ServiceRegistrar, srv DependencyResolverModServiceServer)

Types

type Assets 

type Assets struct {
	Assets []*Assets_Asset `protobuf:"bytes,1,rep,name=assets,proto3" json:"assets,omitempty"`
	// contains filtered or unexported fields
}

func (*Assets) Descriptor deprecated 

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

Deprecated: Use Assets.ProtoReflect.Descriptor instead.

func (*Assets) GetAssets 

func (x *Assets) GetAssets() []*Assets_Asset

func (*Assets) ProtoMessage 

func (*Assets) ProtoMessage()

func (*Assets) ProtoReflect 

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

func (*Assets) Reset 

func (x *Assets) Reset()

func (*Assets) String 

func (x *Assets) String() string

type Assets_Asset 

type Assets_Asset 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 (*Assets_Asset) Descriptor deprecated 

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

Deprecated: Use Assets_Asset.ProtoReflect.Descriptor instead.

func (*Assets_Asset) GetName 

func (x *Assets_Asset) GetName() string

func (*Assets_Asset) GetValue 

func (x *Assets_Asset) GetValue() string

func (*Assets_Asset) ProtoMessage 

func (*Assets_Asset) ProtoMessage()

func (*Assets_Asset) ProtoReflect 

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

func (*Assets_Asset) Reset 

func (x *Assets_Asset) Reset()

func (*Assets_Asset) String 

func (x *Assets_Asset) String() string

type CompileAssetsRequest 

type CompileAssetsRequest struct {
	Configs *Configs `protobuf:"bytes,1,opt,name=configs,proto3" json:"configs,omitempty"`
	Assets  *Assets  `protobuf:"bytes,2,opt,name=assets,proto3" json:"assets,omitempty"`
	// Deprecated: Do not use.
	Window *v1beta1.TaskWindow `protobuf:"bytes,3,opt,name=window,proto3" json:"window,omitempty"`
	// Deprecated: Do not use.
	InstanceSchedule *timestamppb.Timestamp      `protobuf:"bytes,4,opt,name=instance_schedule,json=instanceSchedule,proto3" json:"instance_schedule,omitempty"`
	InstanceData     []*v1beta1.InstanceSpecData `protobuf:"bytes,5,rep,name=instance_data,json=instanceData,proto3" json:"instance_data,omitempty"`
	StartTime        *timestamppb.Timestamp      `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime          *timestamppb.Timestamp      `protobuf:"bytes,7,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Options          *PluginOptions              `protobuf:"bytes,40,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CompileAssetsRequest) Descriptor deprecated 

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

Deprecated: Use CompileAssetsRequest.ProtoReflect.Descriptor instead.

func (*CompileAssetsRequest) GetAssets 

func (x *CompileAssetsRequest) GetAssets() *Assets

func (*CompileAssetsRequest) GetConfigs 

func (x *CompileAssetsRequest) GetConfigs() *Configs

func (*CompileAssetsRequest) GetEndTime 

func (x *CompileAssetsRequest) GetEndTime() *timestamppb.Timestamp

func (*CompileAssetsRequest) GetInstanceData 

func (x *CompileAssetsRequest) GetInstanceData() []*v1beta1.InstanceSpecData

func (*CompileAssetsRequest) GetInstanceSchedule deprecated 

func (x *CompileAssetsRequest) GetInstanceSchedule() *timestamppb.Timestamp

Deprecated: Do not use.

func (*CompileAssetsRequest) GetOptions 

func (x *CompileAssetsRequest) GetOptions() *PluginOptions

func (*CompileAssetsRequest) GetStartTime 

func (x *CompileAssetsRequest) GetStartTime() *timestamppb.Timestamp

func (*CompileAssetsRequest) GetWindow deprecated 

func (x *CompileAssetsRequest) GetWindow() *v1beta1.TaskWindow

Deprecated: Do not use.

func (*CompileAssetsRequest) ProtoMessage 

func (*CompileAssetsRequest) ProtoMessage()

func (*CompileAssetsRequest) ProtoReflect 

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

func (*CompileAssetsRequest) Reset 

func (x *CompileAssetsRequest) Reset()

func (*CompileAssetsRequest) String 

func (x *CompileAssetsRequest) String() string

type CompileAssetsResponse 

type CompileAssetsResponse struct {
	Assets *Assets `protobuf:"bytes,1,opt,name=assets,proto3" json:"assets,omitempty"`
	// contains filtered or unexported fields
}

func (*CompileAssetsResponse) Descriptor deprecated 

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

Deprecated: Use CompileAssetsResponse.ProtoReflect.Descriptor instead.

func (*CompileAssetsResponse) GetAssets 

func (x *CompileAssetsResponse) GetAssets() *Assets

func (*CompileAssetsResponse) ProtoMessage 

func (*CompileAssetsResponse) ProtoMessage()

func (*CompileAssetsResponse) ProtoReflect 

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

func (*CompileAssetsResponse) Reset 

func (x *CompileAssetsResponse) Reset()

func (*CompileAssetsResponse) String 

func (x *CompileAssetsResponse) String() string

type Configs 

type Configs struct {
	Configs []*Configs_Config `protobuf:"bytes,1,rep,name=configs,proto3" json:"configs,omitempty"`
	// contains filtered or unexported fields
}

func (*Configs) Descriptor deprecated 

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

Deprecated: Use Configs.ProtoReflect.Descriptor instead.

func (*Configs) GetConfigs 

func (x *Configs) GetConfigs() []*Configs_Config

func (*Configs) ProtoMessage 

func (*Configs) ProtoMessage()

func (*Configs) ProtoReflect 

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

func (*Configs) Reset 

func (x *Configs) Reset()

func (*Configs) String 

func (x *Configs) String() string

type Configs_Config 

type Configs_Config 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 (*Configs_Config) Descriptor deprecated 

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

Deprecated: Use Configs_Config.ProtoReflect.Descriptor instead.

func (*Configs_Config) GetName 

func (x *Configs_Config) GetName() string

func (*Configs_Config) GetValue 

func (x *Configs_Config) GetValue() string

func (*Configs_Config) ProtoMessage 

func (*Configs_Config) ProtoMessage()

func (*Configs_Config) ProtoReflect 

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

func (*Configs_Config) Reset 

func (x *Configs_Config) Reset()

func (*Configs_Config) String 

func (x *Configs_Config) String() string

type DependencyResolverModServiceClient 

type DependencyResolverModServiceClient interface {
	// GetName returns name of the plugin
	GetName(ctx context.Context, in *GetNameRequest, opts ...grpc.CallOption) (*GetNameResponse, error)
	// GenerateDestination derive destination from config and assets
	GenerateDestination(ctx context.Context, in *GenerateDestinationRequest, opts ...grpc.CallOption) (*GenerateDestinationResponse, error)
	// GenerateDependencies return names of job destination on which this unit
	// is dependent on
	GenerateDependencies(ctx context.Context, in *GenerateDependenciesRequest, opts ...grpc.CallOption) (*GenerateDependenciesResponse, error)
	// CompileAssets overrides the default asset compilation behaviour
	CompileAssets(ctx context.Context, in *CompileAssetsRequest, opts ...grpc.CallOption) (*CompileAssetsResponse, error)
}

DependencyResolverModServiceClient is the client API for DependencyResolverModService 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 NewDependencyResolverModServiceClient 

func NewDependencyResolverModServiceClient(cc grpc.ClientConnInterface) DependencyResolverModServiceClient

type DependencyResolverModServiceServer 

type DependencyResolverModServiceServer interface {
	// GetName returns name of the plugin
	GetName(context.Context, *GetNameRequest) (*GetNameResponse, error)
	// GenerateDestination derive destination from config and assets
	GenerateDestination(context.Context, *GenerateDestinationRequest) (*GenerateDestinationResponse, error)
	// GenerateDependencies return names of job destination on which this unit
	// is dependent on
	GenerateDependencies(context.Context, *GenerateDependenciesRequest) (*GenerateDependenciesResponse, error)
	// CompileAssets overrides the default asset compilation behaviour
	CompileAssets(context.Context, *CompileAssetsRequest) (*CompileAssetsResponse, error)
	// contains filtered or unexported methods
}

DependencyResolverModServiceServer is the server API for DependencyResolverModService service. All implementations must embed UnimplementedDependencyResolverModServiceServer for forward compatibility

type GenerateDependenciesRequest 

type GenerateDependenciesRequest struct {
	Config *Configs `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Assets *Assets  `protobuf:"bytes,2,opt,name=assets,proto3" json:"assets,omitempty"`
	// Deprecated: Do not use.
	Project *v1beta1.ProjectSpecification `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"`
	Options *PluginOptions                `protobuf:"bytes,40,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateDependenciesRequest) Descriptor deprecated 

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

Deprecated: Use GenerateDependenciesRequest.ProtoReflect.Descriptor instead.

func (*GenerateDependenciesRequest) GetAssets 

func (x *GenerateDependenciesRequest) GetAssets() *Assets

func (*GenerateDependenciesRequest) GetConfig 

func (x *GenerateDependenciesRequest) GetConfig() *Configs

func (*GenerateDependenciesRequest) GetOptions 

func (x *GenerateDependenciesRequest) GetOptions() *PluginOptions

func (*GenerateDependenciesRequest) GetProject deprecated 

func (x *GenerateDependenciesRequest) GetProject() *v1beta1.ProjectSpecification

Deprecated: Do not use.

func (*GenerateDependenciesRequest) ProtoMessage 

func (*GenerateDependenciesRequest) ProtoMessage()

func (*GenerateDependenciesRequest) ProtoReflect 

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

func (*GenerateDependenciesRequest) Reset 

func (x *GenerateDependenciesRequest) Reset()

func (*GenerateDependenciesRequest) String 

func (x *GenerateDependenciesRequest) String() string

type GenerateDependenciesResponse 

type GenerateDependenciesResponse struct {
	Dependencies []string `protobuf:"bytes,1,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateDependenciesResponse) Descriptor deprecated 

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

Deprecated: Use GenerateDependenciesResponse.ProtoReflect.Descriptor instead.

func (*GenerateDependenciesResponse) GetDependencies 

func (x *GenerateDependenciesResponse) GetDependencies() []string

func (*GenerateDependenciesResponse) ProtoMessage 

func (*GenerateDependenciesResponse) ProtoMessage()

func (*GenerateDependenciesResponse) ProtoReflect 

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

func (*GenerateDependenciesResponse) Reset 

func (x *GenerateDependenciesResponse) Reset()

func (*GenerateDependenciesResponse) String 

func (x *GenerateDependenciesResponse) String() string

type GenerateDestinationRequest 

type GenerateDestinationRequest struct {
	Config *Configs `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Assets *Assets  `protobuf:"bytes,2,opt,name=assets,proto3" json:"assets,omitempty"`
	// Deprecated: Do not use.
	Project *v1beta1.ProjectSpecification `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"`
	Options *PluginOptions                `protobuf:"bytes,40,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateDestinationRequest) Descriptor deprecated 

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

Deprecated: Use GenerateDestinationRequest.ProtoReflect.Descriptor instead.

func (*GenerateDestinationRequest) GetAssets 

func (x *GenerateDestinationRequest) GetAssets() *Assets

func (*GenerateDestinationRequest) GetConfig 

func (x *GenerateDestinationRequest) GetConfig() *Configs

func (*GenerateDestinationRequest) GetOptions 

func (x *GenerateDestinationRequest) GetOptions() *PluginOptions

func (*GenerateDestinationRequest) GetProject deprecated 

func (x *GenerateDestinationRequest) GetProject() *v1beta1.ProjectSpecification

Deprecated: Do not use.

func (*GenerateDestinationRequest) ProtoMessage 

func (*GenerateDestinationRequest) ProtoMessage()

func (*GenerateDestinationRequest) ProtoReflect 

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

func (*GenerateDestinationRequest) Reset 

func (x *GenerateDestinationRequest) Reset()

func (*GenerateDestinationRequest) String 

func (x *GenerateDestinationRequest) String() string

type GenerateDestinationResponse 

type GenerateDestinationResponse struct {
	Destination     string `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"`
	DestinationType string `protobuf:"bytes,2,opt,name=destination_type,json=destinationType,proto3" json:"destination_type,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateDestinationResponse) Descriptor deprecated 

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

Deprecated: Use GenerateDestinationResponse.ProtoReflect.Descriptor instead.

func (*GenerateDestinationResponse) GetDestination 

func (x *GenerateDestinationResponse) GetDestination() string

func (*GenerateDestinationResponse) GetDestinationType 

func (x *GenerateDestinationResponse) GetDestinationType() string

func (*GenerateDestinationResponse) ProtoMessage 

func (*GenerateDestinationResponse) ProtoMessage()

func (*GenerateDestinationResponse) ProtoReflect 

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

func (*GenerateDestinationResponse) Reset 

func (x *GenerateDestinationResponse) Reset()

func (*GenerateDestinationResponse) String 

func (x *GenerateDestinationResponse) String() string

type GetNameRequest 

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

func (*GetNameRequest) Descriptor deprecated 

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

Deprecated: Use GetNameRequest.ProtoReflect.Descriptor instead.

func (*GetNameRequest) ProtoMessage 

func (*GetNameRequest) ProtoMessage()

func (*GetNameRequest) ProtoReflect 

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

func (*GetNameRequest) Reset 

func (x *GetNameRequest) Reset()

func (*GetNameRequest) String 

func (x *GetNameRequest) String() string

type GetNameResponse 

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

func (*GetNameResponse) Descriptor deprecated 

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

Deprecated: Use GetNameResponse.ProtoReflect.Descriptor instead.

func (*GetNameResponse) GetName 

func (x *GetNameResponse) GetName() string

func (*GetNameResponse) ProtoMessage 

func (*GetNameResponse) ProtoMessage()

func (*GetNameResponse) ProtoReflect 

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

func (*GetNameResponse) Reset 

func (x *GetNameResponse) Reset()

func (*GetNameResponse) String 

func (x *GetNameResponse) String() string

type PluginOptions 

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

func (*PluginOptions) Descriptor deprecated 

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

Deprecated: Use PluginOptions.ProtoReflect.Descriptor instead.

func (*PluginOptions) GetDryRun 

func (x *PluginOptions) GetDryRun() bool

func (*PluginOptions) ProtoMessage 

func (*PluginOptions) ProtoMessage()

func (*PluginOptions) ProtoReflect 

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

func (*PluginOptions) Reset 

func (x *PluginOptions) Reset()

func (*PluginOptions) String 

func (x *PluginOptions) String() string

type UnimplementedDependencyResolverModServiceServer 

type UnimplementedDependencyResolverModServiceServer struct {
}

UnimplementedDependencyResolverModServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDependencyResolverModServiceServer) CompileAssets 

func (UnimplementedDependencyResolverModServiceServer) CompileAssets(context.Context, *CompileAssetsRequest) (*CompileAssetsResponse, error)

func (UnimplementedDependencyResolverModServiceServer) GenerateDependencies 

func (UnimplementedDependencyResolverModServiceServer) GenerateDependencies(context.Context, *GenerateDependenciesRequest) (*GenerateDependenciesResponse, error)

func (UnimplementedDependencyResolverModServiceServer) GenerateDestination 

func (UnimplementedDependencyResolverModServiceServer) GenerateDestination(context.Context, *GenerateDestinationRequest) (*GenerateDestinationResponse, error)

func (UnimplementedDependencyResolverModServiceServer) GetName 

func (UnimplementedDependencyResolverModServiceServer) GetName(context.Context, *GetNameRequest) (*GetNameResponse, error)

type UnsafeDependencyResolverModServiceServer 

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

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