tag

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: 18 Imported by: 7

Documentation

Index

Constants

View Source 
const TagSyncerName = "tagSyncer"

Variables

View Source 
var File_tag_tag_proto protoreflect.FileDescriptor
View Source 
var MinimalCliVersion = semver.MustParse("0.58.0-0")
View Source 
var TagSyncService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tag.TagSyncService",
	HandlerType: (*TagSyncServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CliVersionInformation",
			Handler:    _TagSyncService_CliVersionInformation_Handler,
		},
		{
			MethodName: "SyncTags",
			Handler:    _TagSyncService_SyncTags_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "tag/tag.proto",
}

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

Functions

func RegisterTagSyncServiceServer added in v0.61.0 

func RegisterTagSyncServiceServer(s grpc.ServiceRegistrar, srv TagSyncServiceServer)

Types

type Tag 

type Tag struct {
	Key    string `json:"key"`
	Value  string `json:"value"`
	Source string `json:"source"`
}

Tag represents a tag, which can be unused on different entity types like data objects, groups, users etc.

type TagFileCreator added in v0.61.0 

type TagFileCreator interface {
	AddTags(tags ...*TagImportObject) error
	Close()
	GetTagCount() int
}

func NewTagFileCreator added in v0.61.0 

func NewTagFileCreator(config *TagSyncConfig) (TagFileCreator, error)

type TagImportObject added in v0.61.0 

type TagImportObject struct {
	DataObjectFullName *string `json:"dataObjectFullName,omitempty"`
	UserId             *string `json:"userId,omitempty"`
	Key                string  `json:"key"`
	StringValue        string  `json:"stringValue"`
	Source             string  `json:"source"`
}

type TagSyncConfig added in v0.61.0 

type TagSyncConfig struct {
	ConfigMap       *config.ConfigMap `protobuf:"bytes,1,opt,name=config_map,json=configMap,proto3" json:"config_map,omitempty"`
	TargetFile      string            `protobuf:"bytes,2,opt,name=target_file,json=targetFile,proto3" json:"target_file,omitempty"`
	DataSourceId    string            `protobuf:"bytes,3,opt,name=data_source_id,json=dataSourceId,proto3" json:"data_source_id,omitempty"`
	IdentityStoreId string            `protobuf:"bytes,4,opt,name=identity_store_id,json=identityStoreId,proto3" json:"identity_store_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TagSyncConfig) Descriptor deprecated added in v0.61.0 

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

Deprecated: Use TagSyncConfig.ProtoReflect.Descriptor instead.

func (*TagSyncConfig) GetConfigMap added in v0.61.0 

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

func (*TagSyncConfig) GetDataSourceId added in v0.61.0 

func (x *TagSyncConfig) GetDataSourceId() string

func (*TagSyncConfig) GetIdentityStoreId added in v0.61.0 

func (x *TagSyncConfig) GetIdentityStoreId() string

func (*TagSyncConfig) GetTargetFile added in v0.61.0 

func (x *TagSyncConfig) GetTargetFile() string

func (*TagSyncConfig) ProtoMessage added in v0.61.0 

func (*TagSyncConfig) ProtoMessage()

func (*TagSyncConfig) ProtoReflect added in v0.61.0 

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

func (*TagSyncConfig) Reset added in v0.61.0 

func (x *TagSyncConfig) Reset()

func (*TagSyncConfig) String added in v0.61.0 

func (x *TagSyncConfig) String() string

type TagSyncResult added in v0.61.0 

type TagSyncResult struct {
	Tags            int32    `protobuf:"varint,1,opt,name=tags,proto3" json:"tags,omitempty"`
	TagSourcesScope []string `protobuf:"bytes,2,rep,name=tag_sources_scope,json=tagSourcesScope,proto3" json:"tag_sources_scope,omitempty"`
	// contains filtered or unexported fields
}

func (*TagSyncResult) Descriptor deprecated added in v0.61.0 

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

Deprecated: Use TagSyncResult.ProtoReflect.Descriptor instead.

func (*TagSyncResult) GetTagSourcesScope added in v0.61.0 

func (x *TagSyncResult) GetTagSourcesScope() []string

func (*TagSyncResult) GetTags added in v0.61.0 

func (x *TagSyncResult) GetTags() int32

func (*TagSyncResult) ProtoMessage added in v0.61.0 

func (*TagSyncResult) ProtoMessage()

func (*TagSyncResult) ProtoReflect added in v0.61.0 

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

func (*TagSyncResult) Reset added in v0.61.0 

func (x *TagSyncResult) Reset()

func (*TagSyncResult) String added in v0.61.0 

func (x *TagSyncResult) String() string

type TagSyncServiceClient added in v0.61.0 

type TagSyncServiceClient interface {
	CliVersionInformation(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*version.CliBuildInformation, error)
	SyncTags(ctx context.Context, in *TagSyncConfig, opts ...grpc.CallOption) (*TagSyncResult, error)
}

TagSyncServiceClient is the client API for TagSyncService 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 NewTagSyncServiceClient added in v0.61.0 

func NewTagSyncServiceClient(cc grpc.ClientConnInterface) TagSyncServiceClient

type TagSyncServiceServer added in v0.61.0 

type TagSyncServiceServer interface {
	CliVersionInformation(context.Context, *emptypb.Empty) (*version.CliBuildInformation, error)
	SyncTags(context.Context, *TagSyncConfig) (*TagSyncResult, error)
	// contains filtered or unexported methods
}

TagSyncServiceServer is the server API for TagSyncService service. All implementations must embed UnimplementedTagSyncServiceServer for forward compatibility

type TagSyncer added in v0.61.0 

type TagSyncer interface {
	version.CliVersionHandler

	SyncTags(ctx context.Context, config *TagSyncConfig) (*TagSyncResult, error)
}

type TagSyncerPlugin added in v0.61.0 

type TagSyncerPlugin struct {
	plugin.Plugin

	Impl TagSyncer
}

func (*TagSyncerPlugin) GRPCClient added in v0.61.0 

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

func (*TagSyncerPlugin) GRPCServer added in v0.61.0 

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

type TagSyncerVersionHandler added in v0.61.0 

type TagSyncerVersionHandler struct{}

func (*TagSyncerVersionHandler) CliVersionInformation added in v0.61.0 

func (h *TagSyncerVersionHandler) CliVersionInformation(_ context.Context) (*version.CliBuildInformation, error)

type UnimplementedTagSyncServiceServer added in v0.61.0 

type UnimplementedTagSyncServiceServer struct {
}

UnimplementedTagSyncServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTagSyncServiceServer) CliVersionInformation added in v0.61.0 

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

func (UnimplementedTagSyncServiceServer) SyncTags added in v0.61.0 

func (UnimplementedTagSyncServiceServer) SyncTags(context.Context, *TagSyncConfig) (*TagSyncResult, error)

type UnsafeTagSyncServiceServer added in v0.61.0 

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

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

Source Files

View all Source files

Directories

Path Synopsis

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.