resource_provider

package
v0.68.4 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const ResourceProviderSyncerName = "resourceProviderSyncer"

Variables

View Source 
var File_resource_provider_resource_provider_proto protoreflect.FileDescriptor
View Source 
var MinimalCliVersion = semver.MustParse("0.57.0-0")
View Source 
var ResourceProviderService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "resource_provider.ResourceProviderService",
	HandlerType: (*ResourceProviderServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CliVersionInformation",
			Handler:    _ResourceProviderService_CliVersionInformation_Handler,
		},
		{
			MethodName: "UpdateResources",
			Handler:    _ResourceProviderService_UpdateResources_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "resource_provider/resource_provider.proto",
}

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

Functions

func RegisterResourceProviderServiceServer 

func RegisterResourceProviderServiceServer(s grpc.ServiceRegistrar, srv ResourceProviderServiceServer)

Types

type ApiCredentials 

type ApiCredentials struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*ApiCredentials) Descriptor deprecated 

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

Deprecated: Use ApiCredentials.ProtoReflect.Descriptor instead.

func (*ApiCredentials) GetPassword 

func (x *ApiCredentials) GetPassword() string

func (*ApiCredentials) GetUsername 

func (x *ApiCredentials) GetUsername() string

func (*ApiCredentials) ProtoMessage 

func (*ApiCredentials) ProtoMessage()

func (*ApiCredentials) ProtoReflect 

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

func (*ApiCredentials) Reset 

func (x *ApiCredentials) Reset()

func (*ApiCredentials) String 

func (x *ApiCredentials) String() string

type ResourceProviderServiceClient 

type ResourceProviderServiceClient interface {
	CliVersionInformation(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*version.CliBuildInformation, error)
	UpdateResources(ctx context.Context, in *UpdateResourceInput, opts ...grpc.CallOption) (*UpdateResourceResult, error)
}

ResourceProviderServiceClient is the client API for ResourceProviderService 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 NewResourceProviderServiceClient 

func NewResourceProviderServiceClient(cc grpc.ClientConnInterface) ResourceProviderServiceClient

type ResourceProviderServiceServer 

type ResourceProviderServiceServer interface {
	CliVersionInformation(context.Context, *emptypb.Empty) (*version.CliBuildInformation, error)
	UpdateResources(context.Context, *UpdateResourceInput) (*UpdateResourceResult, error)
	// contains filtered or unexported methods
}

ResourceProviderServiceServer is the server API for ResourceProviderService service. All implementations must embed UnimplementedResourceProviderServiceServer for forward compatibility

type ResourceProviderSyncer 

type ResourceProviderSyncer interface {
	version.CliVersionHandler

	UpdateResources(ctx context.Context, config *UpdateResourceInput) (*UpdateResourceResult, error)
}

ResourceProviderSyncer interface needs to be implemented by any plugin that wants to initialize resources on raito Cloud

type ResourceProviderSyncerPlugin 

type ResourceProviderSyncerPlugin struct {
	plugin.Plugin

	Impl ResourceProviderSyncer
}

ResourceProviderSyncerPlugin is used on the server (CLI) and client (plugin) side to integrate with the plugin system. A plugin should not be using this directly, but instead depend on the cli-plugin-base library to register the plugins.

func (*ResourceProviderSyncerPlugin) GRPCClient 

func (p *ResourceProviderSyncerPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (*ResourceProviderSyncerPlugin) GRPCServer 

func (p *ResourceProviderSyncerPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

type ResourceProviderSyncerVersionHandler 

type ResourceProviderSyncerVersionHandler struct{}

func (*ResourceProviderSyncerVersionHandler) CliVersionInformation 

func (h *ResourceProviderSyncerVersionHandler) CliVersionInformation(ctx context.Context) (*version.CliBuildInformation, error)

type UnimplementedResourceProviderServiceServer 

type UnimplementedResourceProviderServiceServer struct {
}

UnimplementedResourceProviderServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedResourceProviderServiceServer) CliVersionInformation 

func (UnimplementedResourceProviderServiceServer) CliVersionInformation(context.Context, *emptypb.Empty) (*version.CliBuildInformation, error)

func (UnimplementedResourceProviderServiceServer) UpdateResources 

func (UnimplementedResourceProviderServiceServer) UpdateResources(context.Context, *UpdateResourceInput) (*UpdateResourceResult, error)

type UnsafeResourceProviderServiceServer 

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

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

type UpdateResourceInput 

type UpdateResourceInput struct {
	ConfigMap       *config.ConfigMap `protobuf:"bytes,1,opt,name=config_map,json=configMap,proto3" json:"config_map,omitempty"`
	Domain          string            `protobuf:"bytes,11,opt,name=domain,proto3" json:"domain,omitempty"`
	DataSourceId    string            `protobuf:"bytes,12,opt,name=data_source_id,json=dataSourceId,proto3" json:"data_source_id,omitempty"`
	IdentityStoreId string            `protobuf:"bytes,13,opt,name=identity_store_id,json=identityStoreId,proto3" json:"identity_store_id,omitempty"`
	UrlOverride     *string           `protobuf:"bytes,14,opt,name=url_override,json=urlOverride,proto3,oneof" json:"url_override,omitempty"`
	Credentials     *ApiCredentials   `protobuf:"bytes,101,opt,name=credentials,proto3" json:"credentials,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateResourceInput) Descriptor deprecated 

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

Deprecated: Use UpdateResourceInput.ProtoReflect.Descriptor instead.

func (*UpdateResourceInput) GetConfigMap 

func (x *UpdateResourceInput) GetConfigMap() *config.ConfigMap

func (*UpdateResourceInput) GetCredentials 

func (x *UpdateResourceInput) GetCredentials() *ApiCredentials

func (*UpdateResourceInput) GetDataSourceId 

func (x *UpdateResourceInput) GetDataSourceId() string

func (*UpdateResourceInput) GetDomain 

func (x *UpdateResourceInput) GetDomain() string

func (*UpdateResourceInput) GetIdentityStoreId 

func (x *UpdateResourceInput) GetIdentityStoreId() string

func (*UpdateResourceInput) GetUrlOverride 

func (x *UpdateResourceInput) GetUrlOverride() string

func (*UpdateResourceInput) ProtoMessage 

func (*UpdateResourceInput) ProtoMessage()

func (*UpdateResourceInput) ProtoReflect 

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

func (*UpdateResourceInput) Reset 

func (x *UpdateResourceInput) Reset()

func (*UpdateResourceInput) String 

func (x *UpdateResourceInput) String() string

type UpdateResourceResult 

type UpdateResourceResult struct {
	AddedObjects   int32 `protobuf:"varint,1,opt,name=added_objects,json=addedObjects,proto3" json:"added_objects,omitempty"`
	UpdatedObjects int32 `protobuf:"varint,2,opt,name=updated_objects,json=updatedObjects,proto3" json:"updated_objects,omitempty"`
	DeletedObjects int32 `protobuf:"varint,3,opt,name=deleted_objects,json=deletedObjects,proto3" json:"deleted_objects,omitempty"`
	Failures       int32 `protobuf:"varint,4,opt,name=failures,proto3" json:"failures,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateResourceResult) Descriptor deprecated 

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

Deprecated: Use UpdateResourceResult.ProtoReflect.Descriptor instead.

func (*UpdateResourceResult) GetAddedObjects 

func (x *UpdateResourceResult) GetAddedObjects() int32

func (*UpdateResourceResult) GetDeletedObjects 

func (x *UpdateResourceResult) GetDeletedObjects() int32

func (*UpdateResourceResult) GetFailures 

func (x *UpdateResourceResult) GetFailures() int32

func (*UpdateResourceResult) GetUpdatedObjects 

func (x *UpdateResourceResult) GetUpdatedObjects() int32

func (*UpdateResourceResult) ProtoMessage 

func (*UpdateResourceResult) ProtoMessage()

func (*UpdateResourceResult) ProtoReflect 

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

func (*UpdateResourceResult) Reset 

func (x *UpdateResourceResult) Reset()

func (*UpdateResourceResult) String 

func (x *UpdateResourceResult) String() string

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.