jobmgmt

package
v2.0.0-alpha.6 Latest Latest
Warning

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

 Go to latest Published: Jan 14, 2025 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	JobmgmtAdminApiService_TriggerJob_FullMethodName = "/recon.jobmgmt.adminapi.JobmgmtAdminApiService/TriggerJob"
	JobmgmtAdminApiService_GetStatus_FullMethodName  = "/recon.jobmgmt.adminapi.JobmgmtAdminApiService/GetStatus"
)
View Source 
const (
	JobmgmtConfigProviderService_ReadConfig_FullMethodName = "/recon.jobmgmt.JobmgmtConfigProviderService/ReadConfig"
)
View Source 
const (
	JobmgmtLogWriterService_CreateLog_FullMethodName = "/recon.jobmgmt.JobmgmtLogWriterService/CreateLog"
)

Variables

View Source 
var (
	JobChannel_name = map[int32]string{
		0: "JOB_CHANNEL_UNSPECIFIED",
		1: "JOB_CHANNEL_CRON",
		2: "JOB_CHANNEL_MANUALLY_TRIGGERED",
	}
	JobChannel_value = map[string]int32{
		"JOB_CHANNEL_UNSPECIFIED":        0,
		"JOB_CHANNEL_CRON":               1,
		"JOB_CHANNEL_MANUALLY_TRIGGERED": 2,
	}
)

Enum value maps for JobChannel.

View Source 
var (
	JobStatus_name = map[int32]string{
		0: "JOB_STATUS_UNSPECIFIED",
		2: "JOB_STATUS_SUCCESS",
		3: "JOB_STATUS_HAS_ERRORS",
	}
	JobStatus_value = map[string]int32{
		"JOB_STATUS_UNSPECIFIED": 0,
		"JOB_STATUS_SUCCESS":     2,
		"JOB_STATUS_HAS_ERRORS":  3,
	}
)

Enum value maps for JobStatus.

View Source 
var (
	YesNoStatus_name = map[int32]string{
		0: "YES_NO_STATUS_UNSPECIFIED",
		1: "YES_NO_STATUS_YES",
		2: "YES_NO_STATUS_NO",
	}
	YesNoStatus_value = map[string]int32{
		"YES_NO_STATUS_UNSPECIFIED": 0,
		"YES_NO_STATUS_YES":         1,
		"YES_NO_STATUS_NO":          2,
	}
)

Enum value maps for YesNoStatus.

View Source 
var (
	SortDirection_name = map[int32]string{
		0: "SORT_DIRECTION_UNSPECIFIED",
		1: "SORT_DIRECTION_ASCENDING",
		2: "SORT_DIRECTION_DESCENDING",
	}
	SortDirection_value = map[string]int32{
		"SORT_DIRECTION_UNSPECIFIED": 0,
		"SORT_DIRECTION_ASCENDING":   1,
		"SORT_DIRECTION_DESCENDING":  2,
	}
)

Enum value maps for SortDirection.

View Source 
var (
	JobPriority_name = map[int32]string{
		0: "JOB_PRIORITY_UNSPECIFIED",
		1: "JOB_PRIORITY_LOW",
		2: "JOB_PRIORITY_MEDIUM",
		3: "JOB_PRIORITY_HIGH",
		4: "JOB_PRIORITY_CRITICAL",
	}
	JobPriority_value = map[string]int32{
		"JOB_PRIORITY_UNSPECIFIED": 0,
		"JOB_PRIORITY_LOW":         1,
		"JOB_PRIORITY_MEDIUM":      2,
		"JOB_PRIORITY_HIGH":        3,
		"JOB_PRIORITY_CRITICAL":    4,
	}
)

Enum value maps for JobPriority.

View Source 
var (
	User_LoginType_name = map[int32]string{
		0: "LOGIN_TYPE_UNSPECIFIED",
		1: "LOGIN_TYPE_PASSWORDLOGIN",
		2: "LOGIN_TYPEACTIVEDIRECTORYLOGIN",
	}
	User_LoginType_value = map[string]int32{
		"LOGIN_TYPE_UNSPECIFIED":         0,
		"LOGIN_TYPE_PASSWORDLOGIN":       1,
		"LOGIN_TYPEACTIVEDIRECTORYLOGIN": 2,
	}
)

Enum value maps for User_LoginType.

View Source 
var (
	LogRecord_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "STATUS_SUCCESS",
		2: "STATUS_FAILED",
	}
	LogRecord_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"STATUS_SUCCESS":     1,
		"STATUS_FAILED":      2,
	}
)

Enum value maps for LogRecord_Status.

View Source 
var (
	AdminLogline_Severity_name = map[int32]string{
		0: "SEVERITY_UNSPECIFIED",
		1: "SEVERITY_INFO",
		2: "SEVERITY_WARNING",
		3: "SEVERITY_ERROR",
	}
	AdminLogline_Severity_value = map[string]int32{
		"SEVERITY_UNSPECIFIED": 0,
		"SEVERITY_INFO":        1,
		"SEVERITY_WARNING":     2,
		"SEVERITY_ERROR":       3,
	}
)

Enum value maps for AdminLogline_Severity.

View Source 
var File_recon_jobmgmt_adminapi_worker_admin_proto protoreflect.FileDescriptor
View Source 
var File_recon_jobmgmt_config_proto protoreflect.FileDescriptor
View Source 
var File_recon_jobmgmt_log_proto protoreflect.FileDescriptor
View Source 
var File_recon_jobmgmt_messages_messages_proto protoreflect.FileDescriptor
View Source 
var JobmgmtAdminApiService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "recon.jobmgmt.adminapi.JobmgmtAdminApiService",
	HandlerType: (*JobmgmtAdminApiServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "TriggerJob",
			Handler:    _JobmgmtAdminApiService_TriggerJob_Handler,
		},
		{
			MethodName: "GetStatus",
			Handler:    _JobmgmtAdminApiService_GetStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "recon/jobmgmt/adminapi/worker_admin.proto",
}

JobmgmtAdminApiService_ServiceDesc is the grpc.ServiceDesc for JobmgmtAdminApiService 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 JobmgmtConfigProviderService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "recon.jobmgmt.JobmgmtConfigProviderService",
	HandlerType: (*JobmgmtConfigProviderServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ReadConfig",
			Handler:    _JobmgmtConfigProviderService_ReadConfig_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "recon/jobmgmt/config.proto",
}

JobmgmtConfigProviderService_ServiceDesc is the grpc.ServiceDesc for JobmgmtConfigProviderService 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 JobmgmtLogWriterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "recon.jobmgmt.JobmgmtLogWriterService",
	HandlerType: (*JobmgmtLogWriterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateLog",
			Handler:    _JobmgmtLogWriterService_CreateLog_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "recon/jobmgmt/log.proto",
}

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

Functions

func RegisterJobmgmtAdminApiServiceServer 

func RegisterJobmgmtAdminApiServiceServer(s grpc.ServiceRegistrar, srv JobmgmtAdminApiServiceServer)

func RegisterJobmgmtConfigProviderServiceServer 

func RegisterJobmgmtConfigProviderServiceServer(s grpc.ServiceRegistrar, srv JobmgmtConfigProviderServiceServer)

func RegisterJobmgmtLogWriterServiceServer 

func RegisterJobmgmtLogWriterServiceServer(s grpc.ServiceRegistrar, srv JobmgmtLogWriterServiceServer)

Types

type AdminLogline 

type AdminLogline struct {
	Message  string                `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Severity AdminLogline_Severity `protobuf:"varint,2,opt,name=severity,proto3,enum=recon.jobmgmt.adminapi.AdminLogline_Severity" json:"severity,omitempty"`
	// contains filtered or unexported fields
}

func (*AdminLogline) Descriptor deprecated 

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

Deprecated: Use AdminLogline.ProtoReflect.Descriptor instead.

func (*AdminLogline) GetMessage 

func (x *AdminLogline) GetMessage() string

func (*AdminLogline) GetSeverity 

func (x *AdminLogline) GetSeverity() AdminLogline_Severity

func (*AdminLogline) ProtoMessage 

func (*AdminLogline) ProtoMessage()

func (*AdminLogline) ProtoReflect 

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

func (*AdminLogline) Reset 

func (x *AdminLogline) Reset()

func (*AdminLogline) String 

func (x *AdminLogline) String() string

type AdminLogline_Severity 

type AdminLogline_Severity int32
const (
	AdminLogline_SEVERITY_UNSPECIFIED AdminLogline_Severity = 0
	AdminLogline_SEVERITY_INFO        AdminLogline_Severity = 1
	AdminLogline_SEVERITY_WARNING     AdminLogline_Severity = 2
	AdminLogline_SEVERITY_ERROR       AdminLogline_Severity = 3
)

func (AdminLogline_Severity) Descriptor 

func (AdminLogline_Severity) Descriptor() protoreflect.EnumDescriptor

func (AdminLogline_Severity) Enum 

func (x AdminLogline_Severity) Enum() *AdminLogline_Severity

func (AdminLogline_Severity) EnumDescriptor deprecated 

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

Deprecated: Use AdminLogline_Severity.Descriptor instead.

func (AdminLogline_Severity) Number 

func (x AdminLogline_Severity) Number() protoreflect.EnumNumber

func (AdminLogline_Severity) String 

func (x AdminLogline_Severity) String() string

func (AdminLogline_Severity) Type 

func (AdminLogline_Severity) Type() protoreflect.EnumType

type AuditRecord 

type AuditRecord struct {
	RecordId string `protobuf:"bytes,1,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"`
	Message  string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	UserId   string `protobuf:"bytes,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// rfc3339
	DatetimeStr string `protobuf:"bytes,4,opt,name=datetime_str,json=datetimeStr,proto3" json:"datetime_str,omitempty"`
	Role        string `protobuf:"bytes,5,opt,name=role,proto3" json:"role,omitempty"`
	// contains filtered or unexported fields
}

func (*AuditRecord) Descriptor deprecated 

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

Deprecated: Use AuditRecord.ProtoReflect.Descriptor instead.

func (*AuditRecord) GetDatetimeStr 

func (x *AuditRecord) GetDatetimeStr() string

func (*AuditRecord) GetMessage 

func (x *AuditRecord) GetMessage() string

func (*AuditRecord) GetRecordId 

func (x *AuditRecord) GetRecordId() string

func (*AuditRecord) GetRole 

func (x *AuditRecord) GetRole() string

func (*AuditRecord) GetUserId 

func (x *AuditRecord) GetUserId() string

func (*AuditRecord) ProtoMessage 

func (*AuditRecord) ProtoMessage()

func (*AuditRecord) ProtoReflect 

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

func (*AuditRecord) Reset 

func (x *AuditRecord) Reset()

func (*AuditRecord) String 

func (x *AuditRecord) String() string

type CreateLogRequest 

type CreateLogRequest struct {
	Logs []*LogRecord `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

add single/multi logs

func (*CreateLogRequest) Descriptor deprecated 

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

Deprecated: Use CreateLogRequest.ProtoReflect.Descriptor instead.

func (*CreateLogRequest) GetLogs 

func (x *CreateLogRequest) GetLogs() []*LogRecord

func (*CreateLogRequest) ProtoMessage 

func (*CreateLogRequest) ProtoMessage()

func (*CreateLogRequest) ProtoReflect 

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

func (*CreateLogRequest) Reset 

func (x *CreateLogRequest) Reset()

func (*CreateLogRequest) String 

func (x *CreateLogRequest) String() string

type CreateLogResponse 

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

func (*CreateLogResponse) Descriptor deprecated 

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

Deprecated: Use CreateLogResponse.ProtoReflect.Descriptor instead.

func (*CreateLogResponse) ProtoMessage 

func (*CreateLogResponse) ProtoMessage()

func (*CreateLogResponse) ProtoReflect 

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

func (*CreateLogResponse) Reset 

func (x *CreateLogResponse) Reset()

func (*CreateLogResponse) String 

func (x *CreateLogResponse) String() string

type GetStatusRequest 

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

func (*GetStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetStatusRequest.ProtoReflect.Descriptor instead.

func (*GetStatusRequest) GetService 

func (x *GetStatusRequest) GetService() string

func (*GetStatusRequest) ProtoMessage 

func (*GetStatusRequest) ProtoMessage()

func (*GetStatusRequest) ProtoReflect 

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

func (*GetStatusRequest) Reset 

func (x *GetStatusRequest) Reset()

func (*GetStatusRequest) String 

func (x *GetStatusRequest) String() string

type GetStatusResponse 

type GetStatusResponse struct {
	Version                                int64             `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	ServiceName                            string            `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	LastStartedAtUnixmillis                int64             `` /* 135-byte string literal not displayed */
	MillisecondsSinceStart                 int64             `` /* 130-byte string literal not displayed */
	RecentMaybeErrors                      []*AdminLogline   `protobuf:"bytes,5,rep,name=recent_maybe_errors,json=recentMaybeErrors,proto3" json:"recent_maybe_errors,omitempty"`
	RecentMaybeLogs                        []*AdminLogline   `protobuf:"bytes,6,rep,name=recent_maybe_logs,json=recentMaybeLogs,proto3" json:"recent_maybe_logs,omitempty"`
	CurrentCronString                      string            `protobuf:"bytes,7,opt,name=current_cron_string,json=currentCronString,proto3" json:"current_cron_string,omitempty"`
	SomeConfigParams                       map[string]string `` /* 199-byte string literal not displayed */
	ConfigurationLastRefreshedAtUnixmillis int64             `` /* 182-byte string literal not displayed */
	CronEnabled                            bool              `protobuf:"varint,10,opt,name=cron_enabled,json=cronEnabled,proto3" json:"cron_enabled,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetStatusResponse.ProtoReflect.Descriptor instead.

func (*GetStatusResponse) GetConfigurationLastRefreshedAtUnixmillis 

func (x *GetStatusResponse) GetConfigurationLastRefreshedAtUnixmillis() int64

func (*GetStatusResponse) GetCronEnabled 

func (x *GetStatusResponse) GetCronEnabled() bool

func (*GetStatusResponse) GetCurrentCronString 

func (x *GetStatusResponse) GetCurrentCronString() string

func (*GetStatusResponse) GetLastStartedAtUnixmillis 

func (x *GetStatusResponse) GetLastStartedAtUnixmillis() int64

func (*GetStatusResponse) GetMillisecondsSinceStart 

func (x *GetStatusResponse) GetMillisecondsSinceStart() int64

func (*GetStatusResponse) GetRecentMaybeErrors 

func (x *GetStatusResponse) GetRecentMaybeErrors() []*AdminLogline

func (*GetStatusResponse) GetRecentMaybeLogs 

func (x *GetStatusResponse) GetRecentMaybeLogs() []*AdminLogline

func (*GetStatusResponse) GetServiceName 

func (x *GetStatusResponse) GetServiceName() string

func (*GetStatusResponse) GetSomeConfigParams 

func (x *GetStatusResponse) GetSomeConfigParams() map[string]string

func (*GetStatusResponse) GetVersion 

func (x *GetStatusResponse) GetVersion() int64

func (*GetStatusResponse) ProtoMessage 

func (*GetStatusResponse) ProtoMessage()

func (*GetStatusResponse) ProtoReflect 

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

func (*GetStatusResponse) Reset 

func (x *GetStatusResponse) Reset()

func (*GetStatusResponse) String 

func (x *GetStatusResponse) String() string

type Group 

type Group struct {
	GroupId string  `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Dn      string  `protobuf:"bytes,2,opt,name=dn,proto3" json:"dn,omitempty"`
	Members []*User `protobuf:"bytes,3,rep,name=members,proto3" json:"members,omitempty"`
	// contains filtered or unexported fields
}

AD group

func (*Group) Descriptor deprecated 

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

Deprecated: Use Group.ProtoReflect.Descriptor instead.

func (*Group) GetDn 

func (x *Group) GetDn() string

func (*Group) GetGroupId 

func (x *Group) GetGroupId() string

func (*Group) GetMembers 

func (x *Group) GetMembers() []*User

func (*Group) ProtoMessage 

func (*Group) ProtoMessage()

func (*Group) ProtoReflect 

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

func (*Group) Reset 

func (x *Group) Reset()

func (*Group) String 

func (x *Group) String() string

type JobChannel 

type JobChannel int32
const (
	JobChannel_JOB_CHANNEL_UNSPECIFIED        JobChannel = 0
	JobChannel_JOB_CHANNEL_CRON               JobChannel = 1
	JobChannel_JOB_CHANNEL_MANUALLY_TRIGGERED JobChannel = 2
)

func (JobChannel) Descriptor 

func (JobChannel) Descriptor() protoreflect.EnumDescriptor

func (JobChannel) Enum 

func (x JobChannel) Enum() *JobChannel

func (JobChannel) EnumDescriptor deprecated 

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

Deprecated: Use JobChannel.Descriptor instead.

func (JobChannel) Number 

func (x JobChannel) Number() protoreflect.EnumNumber

func (JobChannel) String 

func (x JobChannel) String() string

func (JobChannel) Type 

func (JobChannel) Type() protoreflect.EnumType

type JobConfig 

type JobConfig struct {
	RecordId       string      `protobuf:"bytes,1,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"`
	Service        string      `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Job            string      `protobuf:"bytes,3,opt,name=job,proto3" json:"job,omitempty"`
	CronSchedule   string      `protobuf:"bytes,4,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"`
	ConfigDbParams string      `protobuf:"bytes,5,opt,name=config_db_params,json=configDbParams,proto3" json:"config_db_params,omitempty"`
	Enabled        YesNoStatus `protobuf:"varint,6,opt,name=enabled,proto3,enum=recon.jobmgmt.messages.YesNoStatus" json:"enabled,omitempty"`
	SendNotif      YesNoStatus ``                                                                                          /* 129-byte string literal not displayed */
	CreatedAt      int64       `protobuf:"varint,8,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` // unix milliseconds
	UpdatedAt      int64       `protobuf:"varint,9,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` // unix milliseconds
	// contains filtered or unexported fields
}

Job execution log, stored in log collection Job logs should be gathered through GetJob or something

func (*JobConfig) Descriptor deprecated 

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

Deprecated: Use JobConfig.ProtoReflect.Descriptor instead.

func (*JobConfig) GetConfigDbParams 

func (x *JobConfig) GetConfigDbParams() string

func (*JobConfig) GetCreatedAt 

func (x *JobConfig) GetCreatedAt() int64

func (*JobConfig) GetCronSchedule 

func (x *JobConfig) GetCronSchedule() string

func (*JobConfig) GetEnabled 

func (x *JobConfig) GetEnabled() YesNoStatus

func (*JobConfig) GetJob 

func (x *JobConfig) GetJob() string

func (*JobConfig) GetRecordId 

func (x *JobConfig) GetRecordId() string

func (*JobConfig) GetSendNotif 

func (x *JobConfig) GetSendNotif() YesNoStatus

func (*JobConfig) GetService 

func (x *JobConfig) GetService() string

func (*JobConfig) GetUpdatedAt 

func (x *JobConfig) GetUpdatedAt() int64

func (*JobConfig) ProtoMessage 

func (*JobConfig) ProtoMessage()

func (*JobConfig) ProtoReflect 

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

func (*JobConfig) Reset 

func (x *JobConfig) Reset()

func (*JobConfig) String 

func (x *JobConfig) String() string

type JobPriority 

type JobPriority int32
const (
	JobPriority_JOB_PRIORITY_UNSPECIFIED JobPriority = 0
	JobPriority_JOB_PRIORITY_LOW         JobPriority = 1
	JobPriority_JOB_PRIORITY_MEDIUM      JobPriority = 2
	JobPriority_JOB_PRIORITY_HIGH        JobPriority = 3
	JobPriority_JOB_PRIORITY_CRITICAL    JobPriority = 4
)

func (JobPriority) Descriptor 

func (JobPriority) Descriptor() protoreflect.EnumDescriptor

func (JobPriority) Enum 

func (x JobPriority) Enum() *JobPriority

func (JobPriority) EnumDescriptor deprecated 

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

Deprecated: Use JobPriority.Descriptor instead.

func (JobPriority) Number 

func (x JobPriority) Number() protoreflect.EnumNumber

func (JobPriority) String 

func (x JobPriority) String() string

func (JobPriority) Type 

func (JobPriority) Type() protoreflect.EnumType

type JobStatus 

type JobStatus int32
const (
	JobStatus_JOB_STATUS_UNSPECIFIED JobStatus = 0
	JobStatus_JOB_STATUS_SUCCESS     JobStatus = 2
	JobStatus_JOB_STATUS_HAS_ERRORS  JobStatus = 3
)

func (JobStatus) Descriptor 

func (JobStatus) Descriptor() protoreflect.EnumDescriptor

func (JobStatus) Enum 

func (x JobStatus) Enum() *JobStatus

func (JobStatus) EnumDescriptor deprecated 

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

Deprecated: Use JobStatus.Descriptor instead.

func (JobStatus) Number 

func (x JobStatus) Number() protoreflect.EnumNumber

func (JobStatus) String 

func (x JobStatus) String() string

func (JobStatus) Type 

func (JobStatus) Type() protoreflect.EnumType

type Jobinstance 

type Jobinstance struct {
	Id          string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	InstanceId  string    `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"` // service instance id
	Name        string    `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Description string    `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	DateStr     string    `protobuf:"bytes,5,opt,name=date_str,json=dateStr,proto3" json:"date_str,omitempty"`
	JobStatus   JobStatus `` /* 127-byte string literal not displayed */
	// repeated LogRecord log_lines  = 7; // populated during reads only
	// repeated LogRecord error_lines  = 8; // populated during reads only
	CreatedBy string `protobuf:"bytes,9,opt,name=created_by,json=createdBy,proto3" json:"created_by,omitempty"`
	UpdatedBy string `protobuf:"bytes,10,opt,name=updated_by,json=updatedBy,proto3" json:"updated_by,omitempty"`
	CreatedAt int64  `protobuf:"varint,11,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt int64  `protobuf:"varint,12,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// seconds
	ExecutionTime int64      `protobuf:"varint,13,opt,name=execution_time,json=executionTime,proto3" json:"execution_time,omitempty"`
	JobConfig     *JobConfig `protobuf:"bytes,14,opt,name=job_config,json=jobConfig,proto3" json:"job_config,omitempty"` // service config
	// unixnano
	Timestamp  int64      `protobuf:"varint,15,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	JobChannel JobChannel `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

common struct for execution tasks

func (*Jobinstance) Descriptor deprecated 

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

Deprecated: Use Jobinstance.ProtoReflect.Descriptor instead.

func (*Jobinstance) GetCreatedAt 

func (x *Jobinstance) GetCreatedAt() int64

func (*Jobinstance) GetCreatedBy 

func (x *Jobinstance) GetCreatedBy() string

func (*Jobinstance) GetDateStr 

func (x *Jobinstance) GetDateStr() string

func (*Jobinstance) GetDescription 

func (x *Jobinstance) GetDescription() string

func (*Jobinstance) GetExecutionTime 

func (x *Jobinstance) GetExecutionTime() int64

func (*Jobinstance) GetId 

func (x *Jobinstance) GetId() string

func (*Jobinstance) GetInstanceId 

func (x *Jobinstance) GetInstanceId() string

func (*Jobinstance) GetJobChannel 

func (x *Jobinstance) GetJobChannel() JobChannel

func (*Jobinstance) GetJobConfig 

func (x *Jobinstance) GetJobConfig() *JobConfig

func (*Jobinstance) GetJobStatus 

func (x *Jobinstance) GetJobStatus() JobStatus

func (*Jobinstance) GetName 

func (x *Jobinstance) GetName() string

func (*Jobinstance) GetTimestamp 

func (x *Jobinstance) GetTimestamp() int64

func (*Jobinstance) GetUpdatedAt 

func (x *Jobinstance) GetUpdatedAt() int64

func (*Jobinstance) GetUpdatedBy 

func (x *Jobinstance) GetUpdatedBy() string

func (*Jobinstance) ProtoMessage 

func (*Jobinstance) ProtoMessage()

func (*Jobinstance) ProtoReflect 

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

func (*Jobinstance) Reset 

func (x *Jobinstance) Reset()

func (*Jobinstance) String 

func (x *Jobinstance) String() string

type JobmgmtAdminApiServiceClient 

type JobmgmtAdminApiServiceClient interface {
	TriggerJob(ctx context.Context, in *TriggerJobRequest, opts ...grpc.CallOption) (*TriggerJobResponse, error)
	// returns runtime status & parameters
	GetStatus(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*GetStatusResponse, error)
}

JobmgmtAdminApiServiceClient is the client API for JobmgmtAdminApiService 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.

GRPC-only to be implemented by worker microservices

func NewJobmgmtAdminApiServiceClient 

func NewJobmgmtAdminApiServiceClient(cc grpc.ClientConnInterface) JobmgmtAdminApiServiceClient

type JobmgmtAdminApiServiceServer 

type JobmgmtAdminApiServiceServer interface {
	TriggerJob(context.Context, *TriggerJobRequest) (*TriggerJobResponse, error)
	// returns runtime status & parameters
	GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)
}

JobmgmtAdminApiServiceServer is the server API for JobmgmtAdminApiService service. All implementations should embed UnimplementedJobmgmtAdminApiServiceServer for forward compatibility.

GRPC-only to be implemented by worker microservices

type JobmgmtConfigProviderServiceClient 

type JobmgmtConfigProviderServiceClient interface {
	// returns config to the caller.
	ReadConfig(ctx context.Context, in *ReadConfigRequest, opts ...grpc.CallOption) (*ReadConfigResponse, error)
}

JobmgmtConfigProviderServiceClient is the client API for JobmgmtConfigProviderService 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.

GRPC-only in-cluster only Provider service to be implemented by config provider service clients to be worker microservices

func NewJobmgmtConfigProviderServiceClient 

func NewJobmgmtConfigProviderServiceClient(cc grpc.ClientConnInterface) JobmgmtConfigProviderServiceClient

type JobmgmtConfigProviderServiceServer 

type JobmgmtConfigProviderServiceServer interface {
	// returns config to the caller.
	ReadConfig(context.Context, *ReadConfigRequest) (*ReadConfigResponse, error)
}

JobmgmtConfigProviderServiceServer is the server API for JobmgmtConfigProviderService service. All implementations should embed UnimplementedJobmgmtConfigProviderServiceServer for forward compatibility.

GRPC-only in-cluster only Provider service to be implemented by config provider service clients to be worker microservices

type JobmgmtLogWriterServiceClient 

type JobmgmtLogWriterServiceClient interface {
	CreateLog(ctx context.Context, in *CreateLogRequest, opts ...grpc.CallOption) (*CreateLogResponse, error)
}

JobmgmtLogWriterServiceClient is the client API for JobmgmtLogWriterService 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.

GRPC-only to be implemented by worker microservices

func NewJobmgmtLogWriterServiceClient 

func NewJobmgmtLogWriterServiceClient(cc grpc.ClientConnInterface) JobmgmtLogWriterServiceClient

type JobmgmtLogWriterServiceServer 

type JobmgmtLogWriterServiceServer interface {
	CreateLog(context.Context, *CreateLogRequest) (*CreateLogResponse, error)
}

JobmgmtLogWriterServiceServer is the server API for JobmgmtLogWriterService service. All implementations should embed UnimplementedJobmgmtLogWriterServiceServer for forward compatibility.

GRPC-only to be implemented by worker microservices

type ListLogRecordsFilter 

type ListLogRecordsFilter struct {
	PageSize      int64         `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageNum       int64         `protobuf:"varint,2,opt,name=page_num,json=pageNum,proto3" json:"page_num,omitempty"`
	SearchString  string        `protobuf:"bytes,3,opt,name=search_string,json=searchString,proto3" json:"search_string,omitempty"`
	SortFieldName string        `protobuf:"bytes,4,opt,name=sort_field_name,json=sortFieldName,proto3" json:"sort_field_name,omitempty"`
	SortDirection SortDirection `` /* 143-byte string literal not displayed */
	StartDate     string        `protobuf:"bytes,6,opt,name=start_date,json=startDate,proto3" json:"start_date,omitempty"`
	EndDate       string        `protobuf:"bytes,7,opt,name=end_date,json=endDate,proto3" json:"end_date,omitempty"`
	UserId        string        `protobuf:"bytes,8,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	ServiceName   string        `protobuf:"bytes,9,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// int64 start_timestamp = 10; // unix timestamp nano
	// int64 end_timestamp = 12; // unix timestamp nano
	JobStatus LogRecord_Status `` /* 135-byte string literal not displayed */
	Job       string           `protobuf:"bytes,11,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*ListLogRecordsFilter) Descriptor deprecated 

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

Deprecated: Use ListLogRecordsFilter.ProtoReflect.Descriptor instead.

func (*ListLogRecordsFilter) GetEndDate 

func (x *ListLogRecordsFilter) GetEndDate() string

func (*ListLogRecordsFilter) GetJob 

func (x *ListLogRecordsFilter) GetJob() string

func (*ListLogRecordsFilter) GetJobStatus 

func (x *ListLogRecordsFilter) GetJobStatus() LogRecord_Status

func (*ListLogRecordsFilter) GetPageNum 

func (x *ListLogRecordsFilter) GetPageNum() int64

func (*ListLogRecordsFilter) GetPageSize 

func (x *ListLogRecordsFilter) GetPageSize() int64

func (*ListLogRecordsFilter) GetSearchString 

func (x *ListLogRecordsFilter) GetSearchString() string

func (*ListLogRecordsFilter) GetServiceName 

func (x *ListLogRecordsFilter) GetServiceName() string

func (*ListLogRecordsFilter) GetSortDirection 

func (x *ListLogRecordsFilter) GetSortDirection() SortDirection

func (*ListLogRecordsFilter) GetSortFieldName 

func (x *ListLogRecordsFilter) GetSortFieldName() string

func (*ListLogRecordsFilter) GetStartDate 

func (x *ListLogRecordsFilter) GetStartDate() string

func (*ListLogRecordsFilter) GetUserId 

func (x *ListLogRecordsFilter) GetUserId() string

func (*ListLogRecordsFilter) ProtoMessage 

func (*ListLogRecordsFilter) ProtoMessage()

func (*ListLogRecordsFilter) ProtoReflect 

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

func (*ListLogRecordsFilter) Reset 

func (x *ListLogRecordsFilter) Reset()

func (*ListLogRecordsFilter) String 

func (x *ListLogRecordsFilter) String() string

type LogRecord 

type LogRecord struct {
	RecordId  string           `protobuf:"bytes,1,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"` // empty for create
	Timestamp int64            `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`              // UTC unixnano
	Message   string           `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Service   string           `protobuf:"bytes,10,opt,name=service,proto3" json:"service,omitempty"`
	Job       string           `protobuf:"bytes,11,opt,name=job,proto3" json:"job,omitempty"`
	Status    LogRecord_Status `protobuf:"varint,12,opt,name=status,proto3,enum=recon.jobmgmt.messages.LogRecord_Status" json:"status,omitempty"`
	Params    string           `protobuf:"bytes,13,opt,name=params,proto3" json:"params,omitempty"`                         // json string
	AckStatus bool             `protobuf:"varint,14,opt,name=ack_status,json=ackStatus,proto3" json:"ack_status,omitempty"` // is acknowledged ? default (false)
	// error_message (if failed)  -> use message
	BuildVersion string `protobuf:"bytes,15,opt,name=build_version,json=buildVersion,proto3" json:"build_version,omitempty"`
	Initiator    string `protobuf:"bytes,16,opt,name=initiator,proto3" json:"initiator,omitempty"` // either leave as cron, or reference some other method, UI, log message, for traceability,
	// contains filtered or unexported fields
}

Job execution log, stored in log collection Job logs should be gathered through GetJob or something

func (*LogRecord) Descriptor deprecated 

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

Deprecated: Use LogRecord.ProtoReflect.Descriptor instead.

func (*LogRecord) GetAckStatus 

func (x *LogRecord) GetAckStatus() bool

func (*LogRecord) GetBuildVersion 

func (x *LogRecord) GetBuildVersion() string

func (*LogRecord) GetInitiator 

func (x *LogRecord) GetInitiator() string

func (*LogRecord) GetJob 

func (x *LogRecord) GetJob() string

func (*LogRecord) GetMessage 

func (x *LogRecord) GetMessage() string

func (*LogRecord) GetParams 

func (x *LogRecord) GetParams() string

func (*LogRecord) GetRecordId 

func (x *LogRecord) GetRecordId() string

func (*LogRecord) GetService 

func (x *LogRecord) GetService() string

func (*LogRecord) GetStatus 

func (x *LogRecord) GetStatus() LogRecord_Status

func (*LogRecord) GetTimestamp 

func (x *LogRecord) GetTimestamp() int64

func (*LogRecord) ProtoMessage 

func (*LogRecord) ProtoMessage()

func (*LogRecord) ProtoReflect 

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

func (*LogRecord) Reset 

func (x *LogRecord) Reset()

func (*LogRecord) String 

func (x *LogRecord) String() string

type LogRecord_Status 

type LogRecord_Status int32

date-time -- use timestamp 

const (
	LogRecord_STATUS_UNSPECIFIED LogRecord_Status = 0
	LogRecord_STATUS_SUCCESS     LogRecord_Status = 1
	LogRecord_STATUS_FAILED      LogRecord_Status = 2
)

func (LogRecord_Status) Descriptor 

func (LogRecord_Status) Descriptor() protoreflect.EnumDescriptor

func (LogRecord_Status) Enum 

func (x LogRecord_Status) Enum() *LogRecord_Status

func (LogRecord_Status) EnumDescriptor deprecated 

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

Deprecated: Use LogRecord_Status.Descriptor instead.

func (LogRecord_Status) Number 

func (x LogRecord_Status) Number() protoreflect.EnumNumber

func (LogRecord_Status) String 

func (x LogRecord_Status) String() string

func (LogRecord_Status) Type 

func (LogRecord_Status) Type() protoreflect.EnumType

type ReadConfigRequest 

type ReadConfigRequest struct {
	Job     string `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` // original job id - leave it empty if new
	Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

add single/multi logs

func (*ReadConfigRequest) Descriptor deprecated 

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

Deprecated: Use ReadConfigRequest.ProtoReflect.Descriptor instead.

func (*ReadConfigRequest) GetJob 

func (x *ReadConfigRequest) GetJob() string

func (*ReadConfigRequest) GetService 

func (x *ReadConfigRequest) GetService() string

func (*ReadConfigRequest) ProtoMessage 

func (*ReadConfigRequest) ProtoMessage()

func (*ReadConfigRequest) ProtoReflect 

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

func (*ReadConfigRequest) Reset 

func (x *ReadConfigRequest) Reset()

func (*ReadConfigRequest) String 

func (x *ReadConfigRequest) String() string

type ReadConfigResponse 

type ReadConfigResponse struct {
	Config *JobConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadConfigResponse) Descriptor deprecated 

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

Deprecated: Use ReadConfigResponse.ProtoReflect.Descriptor instead.

func (*ReadConfigResponse) GetConfig 

func (x *ReadConfigResponse) GetConfig() *JobConfig

func (*ReadConfigResponse) ProtoMessage 

func (*ReadConfigResponse) ProtoMessage()

func (*ReadConfigResponse) ProtoReflect 

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

func (*ReadConfigResponse) Reset 

func (x *ReadConfigResponse) Reset()

func (*ReadConfigResponse) String 

func (x *ReadConfigResponse) String() string

type Role 

type Role struct {
	RoleId   string `protobuf:"bytes,1,opt,name=role_id,json=roleId,proto3" json:"role_id,omitempty"`
	RoleName string `protobuf:"bytes,2,opt,name=role_name,json=roleName,proto3" json:"role_name,omitempty"`
	// contains filtered or unexported fields
}

func (*Role) Descriptor deprecated 

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

Deprecated: Use Role.ProtoReflect.Descriptor instead.

func (*Role) GetRoleId 

func (x *Role) GetRoleId() string

func (*Role) GetRoleName 

func (x *Role) GetRoleName() string

func (*Role) ProtoMessage 

func (*Role) ProtoMessage()

func (*Role) ProtoReflect 

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

func (*Role) Reset 

func (x *Role) Reset()

func (*Role) String 

func (x *Role) String() string

type SortDirection 

type SortDirection int32
const (
	SortDirection_SORT_DIRECTION_UNSPECIFIED SortDirection = 0
	SortDirection_SORT_DIRECTION_ASCENDING   SortDirection = 1
	SortDirection_SORT_DIRECTION_DESCENDING  SortDirection = 2
)

func (SortDirection) Descriptor 

func (SortDirection) Descriptor() protoreflect.EnumDescriptor

func (SortDirection) Enum 

func (x SortDirection) Enum() *SortDirection

func (SortDirection) EnumDescriptor deprecated 

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

Deprecated: Use SortDirection.Descriptor instead.

func (SortDirection) Number 

func (x SortDirection) Number() protoreflect.EnumNumber

func (SortDirection) String 

func (x SortDirection) String() string

func (SortDirection) Type 

func (SortDirection) Type() protoreflect.EnumType

type TriggerJobRequest 

type TriggerJobRequest struct {

	// the admin service should call the remote service directly
	// and return the result
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// matching service name (will be checked by manager)
	Job       string `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	Params    string `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"` // json encoded
	Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerJobRequest) Descriptor deprecated 

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

Deprecated: Use TriggerJobRequest.ProtoReflect.Descriptor instead.

func (*TriggerJobRequest) GetJob 

func (x *TriggerJobRequest) GetJob() string

func (*TriggerJobRequest) GetNamespace 

func (x *TriggerJobRequest) GetNamespace() string

func (*TriggerJobRequest) GetParams 

func (x *TriggerJobRequest) GetParams() string

func (*TriggerJobRequest) GetService 

func (x *TriggerJobRequest) GetService() string

func (*TriggerJobRequest) ProtoMessage 

func (*TriggerJobRequest) ProtoMessage()

func (*TriggerJobRequest) ProtoReflect 

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

func (*TriggerJobRequest) Reset 

func (x *TriggerJobRequest) Reset()

func (*TriggerJobRequest) String 

func (x *TriggerJobRequest) String() string

type TriggerJobResponse 

type TriggerJobResponse struct {
	Status  JobStatus `protobuf:"varint,1,opt,name=status,proto3,enum=recon.jobmgmt.messages.JobStatus" json:"status,omitempty"`
	Message string    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Params  string    `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"` // json encoded
	// contains filtered or unexported fields
}

func (*TriggerJobResponse) Descriptor deprecated 

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

Deprecated: Use TriggerJobResponse.ProtoReflect.Descriptor instead.

func (*TriggerJobResponse) GetMessage 

func (x *TriggerJobResponse) GetMessage() string

func (*TriggerJobResponse) GetParams 

func (x *TriggerJobResponse) GetParams() string

func (*TriggerJobResponse) GetStatus 

func (x *TriggerJobResponse) GetStatus() JobStatus

func (*TriggerJobResponse) ProtoMessage 

func (*TriggerJobResponse) ProtoMessage()

func (*TriggerJobResponse) ProtoReflect 

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

func (*TriggerJobResponse) Reset 

func (x *TriggerJobResponse) Reset()

func (*TriggerJobResponse) String 

func (x *TriggerJobResponse) String() string

type UnimplementedJobmgmtAdminApiServiceServer 

type UnimplementedJobmgmtAdminApiServiceServer struct{}

UnimplementedJobmgmtAdminApiServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedJobmgmtAdminApiServiceServer) GetStatus 

func (UnimplementedJobmgmtAdminApiServiceServer) GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)

func (UnimplementedJobmgmtAdminApiServiceServer) TriggerJob 

func (UnimplementedJobmgmtAdminApiServiceServer) TriggerJob(context.Context, *TriggerJobRequest) (*TriggerJobResponse, error)

type UnimplementedJobmgmtConfigProviderServiceServer 

type UnimplementedJobmgmtConfigProviderServiceServer struct{}

UnimplementedJobmgmtConfigProviderServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedJobmgmtConfigProviderServiceServer) ReadConfig 

func (UnimplementedJobmgmtConfigProviderServiceServer) ReadConfig(context.Context, *ReadConfigRequest) (*ReadConfigResponse, error)

type UnimplementedJobmgmtLogWriterServiceServer 

type UnimplementedJobmgmtLogWriterServiceServer struct{}

UnimplementedJobmgmtLogWriterServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedJobmgmtLogWriterServiceServer) CreateLog 

func (UnimplementedJobmgmtLogWriterServiceServer) CreateLog(context.Context, *CreateLogRequest) (*CreateLogResponse, error)

type UnsafeJobmgmtAdminApiServiceServer 

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

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

type UnsafeJobmgmtConfigProviderServiceServer 

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

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

type UnsafeJobmgmtLogWriterServiceServer 

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

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

type User 

type User struct {
	UserId string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// comma separated roles
	Role      string         `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
	LoginType User_LoginType `` /* 132-byte string literal not displayed */
	// TODO: buraya daha fazla detay eklenebilir
	// bu detaylar
	Username string `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty"`
	Name     string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	Dn       string `protobuf:"bytes,6,opt,name=dn,proto3" json:"dn,omitempty"`
	// contains filtered or unexported fields
}

func (*User) Descriptor deprecated 

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

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetDn 

func (x *User) GetDn() string

func (*User) GetLoginType 

func (x *User) GetLoginType() User_LoginType

func (*User) GetName 

func (x *User) GetName() string

func (*User) GetRole 

func (x *User) GetRole() string

func (*User) GetUserId 

func (x *User) GetUserId() string

func (*User) GetUsername 

func (x *User) GetUsername() string

func (*User) ProtoMessage 

func (*User) ProtoMessage()

func (*User) ProtoReflect 

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

func (*User) Reset 

func (x *User) Reset()

func (*User) String 

func (x *User) String() string

type User_LoginType 

type User_LoginType int32
const (
	User_LOGIN_TYPE_UNSPECIFIED         User_LoginType = 0
	User_LOGIN_TYPE_PASSWORDLOGIN       User_LoginType = 1
	User_LOGIN_TYPEACTIVEDIRECTORYLOGIN User_LoginType = 2
)

func (User_LoginType) Descriptor 

func (User_LoginType) Descriptor() protoreflect.EnumDescriptor

func (User_LoginType) Enum 

func (x User_LoginType) Enum() *User_LoginType

func (User_LoginType) EnumDescriptor deprecated 

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

Deprecated: Use User_LoginType.Descriptor instead.

func (User_LoginType) Number 

func (x User_LoginType) Number() protoreflect.EnumNumber

func (User_LoginType) String 

func (x User_LoginType) String() string

func (User_LoginType) Type 

func (User_LoginType) Type() protoreflect.EnumType

type YesNoStatus 

type YesNoStatus int32
const (
	YesNoStatus_YES_NO_STATUS_UNSPECIFIED YesNoStatus = 0
	YesNoStatus_YES_NO_STATUS_YES         YesNoStatus = 1
	YesNoStatus_YES_NO_STATUS_NO          YesNoStatus = 2
)

func (YesNoStatus) Descriptor 

func (YesNoStatus) Descriptor() protoreflect.EnumDescriptor

func (YesNoStatus) Enum 

func (x YesNoStatus) Enum() *YesNoStatus

func (YesNoStatus) EnumDescriptor deprecated 

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

Deprecated: Use YesNoStatus.Descriptor instead.

func (YesNoStatus) Number 

func (x YesNoStatus) Number() protoreflect.EnumNumber

func (YesNoStatus) String 

func (x YesNoStatus) String() string

func (YesNoStatus) Type 

func (YesNoStatus) Type() protoreflect.EnumType

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.