notification

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Dec 15, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	JobEventType_name = map[int32]string{
		0: "UNKNOWN_EVENT_TYPE",
		1: "START_JOB",
		2: "STOP_JOB",
		3: "UPDATE_JOB",
	}
	JobEventType_value = map[string]int32{
		"UNKNOWN_EVENT_TYPE": 0,
		"START_JOB":          1,
		"STOP_JOB":           2,
		"UPDATE_JOB":         3,
	}
)

Enum value maps for JobEventType.

View Source 
var (
	DeployEventType_name = map[int32]string{
		0: "UNKNOWN_DEPLOYMENT_TYPE",
		1: "ADD_RESOURCE",
		2: "REVOKE_RESOURCE",
	}
	DeployEventType_value = map[string]int32{
		"UNKNOWN_DEPLOYMENT_TYPE": 0,
		"ADD_RESOURCE":            1,
		"REVOKE_RESOURCE":         2,
	}
)

Enum value maps for DeployEventType.

View Source 
var (
	JobResponse_Status_name = map[int32]string{
		0: "ERROR",
		1: "PARTIAL_SUCCESS",
		2: "SUCCESS",
	}
	JobResponse_Status_value = map[string]int32{
		"ERROR":           0,
		"PARTIAL_SUCCESS": 1,
		"SUCCESS":         2,
	}
)

Enum value maps for JobResponse_Status.

View Source 
var (
	DeployResponse_Status_name = map[int32]string{
		0: "ERROR",
		1: "PARTIAL_SUCCESS",
		2: "SUCCESS",
	}
	DeployResponse_Status_value = map[string]int32{
		"ERROR":           0,
		"PARTIAL_SUCCESS": 1,
		"SUCCESS":         2,
	}
)

Enum value maps for DeployResponse_Status.

View Source 
var DeployEventRoute_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpcNotification.DeployEventRoute",
	HandlerType: (*DeployEventRouteServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetDeployEvent",
			Handler:       _DeployEventRoute_GetDeployEvent_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "notification.proto",
}

DeployEventRoute_ServiceDesc is the grpc.ServiceDesc for DeployEventRoute 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 DeployTriggerRoute_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpcNotification.DeployTriggerRoute",
	HandlerType: (*DeployTriggerRouteServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NotifyDeploy",
			Handler:    _DeployTriggerRoute_NotifyDeploy_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "notification.proto",
}

DeployTriggerRoute_ServiceDesc is the grpc.ServiceDesc for DeployTriggerRoute 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_notification_proto protoreflect.FileDescriptor
View Source 
var JobEventRoute_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpcNotification.JobEventRoute",
	HandlerType: (*JobEventRouteServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetJobEvent",
			Handler:       _JobEventRoute_GetJobEvent_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "notification.proto",
}

JobEventRoute_ServiceDesc is the grpc.ServiceDesc for JobEventRoute 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 JobTriggerRoute_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpcNotification.JobTriggerRoute",
	HandlerType: (*JobTriggerRouteServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NotifyJob",
			Handler:    _JobTriggerRoute_NotifyJob_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "notification.proto",
}

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

Functions

func RegisterDeployEventRouteServer added in v0.1.5 

func RegisterDeployEventRouteServer(s grpc.ServiceRegistrar, srv DeployEventRouteServer)

func RegisterDeployTriggerRouteServer added in v0.1.5 

func RegisterDeployTriggerRouteServer(s grpc.ServiceRegistrar, srv DeployTriggerRouteServer)

func RegisterJobEventRouteServer added in v0.1.5 

func RegisterJobEventRouteServer(s grpc.ServiceRegistrar, srv JobEventRouteServer)

func RegisterJobTriggerRouteServer added in v0.1.5 

func RegisterJobTriggerRouteServer(s grpc.ServiceRegistrar, srv JobTriggerRouteServer)

Types

type DeployEvent added in v0.1.5 

type DeployEvent struct {
	Type  DeployEventType `protobuf:"varint,1,opt,name=type,proto3,enum=grpcNotification.DeployEventType" json:"type,omitempty"`
	JobId string          `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployEvent) Descriptor deprecated added in v0.1.5 

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

Deprecated: Use DeployEvent.ProtoReflect.Descriptor instead.

func (*DeployEvent) GetJobId added in v0.1.5 

func (x *DeployEvent) GetJobId() string

func (*DeployEvent) GetType added in v0.1.5 

func (x *DeployEvent) GetType() DeployEventType

func (*DeployEvent) ProtoMessage added in v0.1.5 

func (*DeployEvent) ProtoMessage()

func (*DeployEvent) ProtoReflect added in v0.1.5 

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

func (*DeployEvent) Reset added in v0.1.5 

func (x *DeployEvent) Reset()

func (*DeployEvent) String added in v0.1.5 

func (x *DeployEvent) String() string

type DeployEventRequest added in v0.1.5 

type DeployEventRequest struct {
	Type       DeployEventType `protobuf:"varint,1,opt,name=type,proto3,enum=grpcNotification.DeployEventType" json:"type,omitempty"`
	ComputeIds []string        `protobuf:"bytes,2,rep,name=compute_ids,json=computeIds,proto3" json:"compute_ids,omitempty"`
	JobId      string          `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployEventRequest) Descriptor deprecated added in v0.1.5 

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

Deprecated: Use DeployEventRequest.ProtoReflect.Descriptor instead.

func (*DeployEventRequest) GetComputeIds added in v0.1.5 

func (x *DeployEventRequest) GetComputeIds() []string

func (*DeployEventRequest) GetJobId added in v0.1.5 

func (x *DeployEventRequest) GetJobId() string

func (*DeployEventRequest) GetType added in v0.1.5 

func (x *DeployEventRequest) GetType() DeployEventType

func (*DeployEventRequest) ProtoMessage added in v0.1.5 

func (*DeployEventRequest) ProtoMessage()

func (*DeployEventRequest) ProtoReflect added in v0.1.5 

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

func (*DeployEventRequest) Reset added in v0.1.5 

func (x *DeployEventRequest) Reset()

func (*DeployEventRequest) String added in v0.1.5 

func (x *DeployEventRequest) String() string

type DeployEventRouteClient added in v0.1.5 

type DeployEventRouteClient interface {
	GetDeployEvent(ctx context.Context, in *DeployInfo, opts ...grpc.CallOption) (DeployEventRoute_GetDeployEventClient, error)
}

DeployEventRouteClient is the client API for DeployEventRoute 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 NewDeployEventRouteClient added in v0.1.5 

func NewDeployEventRouteClient(cc grpc.ClientConnInterface) DeployEventRouteClient

type DeployEventRouteServer added in v0.1.5 

type DeployEventRouteServer interface {
	GetDeployEvent(*DeployInfo, DeployEventRoute_GetDeployEventServer) error
	// contains filtered or unexported methods
}

DeployEventRouteServer is the server API for DeployEventRoute service. All implementations must embed UnimplementedDeployEventRouteServer for forward compatibility

type DeployEventRoute_GetDeployEventClient added in v0.1.5 

type DeployEventRoute_GetDeployEventClient interface {
	Recv() (*DeployEvent, error)
	grpc.ClientStream
}

type DeployEventRoute_GetDeployEventServer added in v0.1.5 

type DeployEventRoute_GetDeployEventServer interface {
	Send(*DeployEvent) error
	grpc.ServerStream
}

type DeployEventType added in v0.1.5 

type DeployEventType int32
const (
	DeployEventType_UNKNOWN_DEPLOYMENT_TYPE DeployEventType = 0 // default
	DeployEventType_ADD_RESOURCE            DeployEventType = 1
	DeployEventType_REVOKE_RESOURCE         DeployEventType = 2
)

func (DeployEventType) Descriptor added in v0.1.5 

func (DeployEventType) Descriptor() protoreflect.EnumDescriptor

func (DeployEventType) Enum added in v0.1.5 

func (x DeployEventType) Enum() *DeployEventType

func (DeployEventType) EnumDescriptor deprecated added in v0.1.5 

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

Deprecated: Use DeployEventType.Descriptor instead.

func (DeployEventType) Number added in v0.1.5 

func (x DeployEventType) Number() protoreflect.EnumNumber

func (DeployEventType) String added in v0.1.5 

func (x DeployEventType) String() string

func (DeployEventType) Type added in v0.1.5 

func (DeployEventType) Type() protoreflect.EnumType

type DeployInfo added in v0.1.5 

type DeployInfo struct {
	ComputeId string `protobuf:"bytes,1,opt,name=compute_id,json=computeId,proto3" json:"compute_id,omitempty"`
	ApiKey    string `protobuf:"bytes,2,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployInfo) Descriptor deprecated added in v0.1.5 

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

Deprecated: Use DeployInfo.ProtoReflect.Descriptor instead.

func (*DeployInfo) GetApiKey added in v0.1.5 

func (x *DeployInfo) GetApiKey() string

func (*DeployInfo) GetComputeId added in v0.1.5 

func (x *DeployInfo) GetComputeId() string

func (*DeployInfo) ProtoMessage added in v0.1.5 

func (*DeployInfo) ProtoMessage()

func (*DeployInfo) ProtoReflect added in v0.1.5 

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

func (*DeployInfo) Reset added in v0.1.5 

func (x *DeployInfo) Reset()

func (*DeployInfo) String added in v0.1.5 

func (x *DeployInfo) String() string

type DeployResponse added in v0.1.5 

type DeployResponse struct {
	Status          DeployResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=grpcNotification.DeployResponse_Status" json:"status,omitempty"`
	Message         string                `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	FailedDeployers []string              `protobuf:"bytes,3,rep,name=failed_deployers,json=failedDeployers,proto3" json:"failed_deployers,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployResponse) Descriptor deprecated added in v0.1.5 

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

Deprecated: Use DeployResponse.ProtoReflect.Descriptor instead.

func (*DeployResponse) GetFailedDeployers added in v0.1.5 

func (x *DeployResponse) GetFailedDeployers() []string

func (*DeployResponse) GetMessage added in v0.1.5 

func (x *DeployResponse) GetMessage() string

func (*DeployResponse) GetStatus added in v0.1.5 

func (x *DeployResponse) GetStatus() DeployResponse_Status

func (*DeployResponse) ProtoMessage added in v0.1.5 

func (*DeployResponse) ProtoMessage()

func (*DeployResponse) ProtoReflect added in v0.1.5 

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

func (*DeployResponse) Reset added in v0.1.5 

func (x *DeployResponse) Reset()

func (*DeployResponse) String added in v0.1.5 

func (x *DeployResponse) String() string

type DeployResponse_Status added in v0.1.5 

type DeployResponse_Status int32
const (
	DeployResponse_ERROR           DeployResponse_Status = 0 // default
	DeployResponse_PARTIAL_SUCCESS DeployResponse_Status = 1 // e.g., not all deployers received event
	DeployResponse_SUCCESS         DeployResponse_Status = 2
)

func (DeployResponse_Status) Descriptor added in v0.1.5 

func (DeployResponse_Status) Descriptor() protoreflect.EnumDescriptor

func (DeployResponse_Status) Enum added in v0.1.5 

func (x DeployResponse_Status) Enum() *DeployResponse_Status

func (DeployResponse_Status) EnumDescriptor deprecated added in v0.1.5 

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

Deprecated: Use DeployResponse_Status.Descriptor instead.

func (DeployResponse_Status) Number added in v0.1.5 

func (x DeployResponse_Status) Number() protoreflect.EnumNumber

func (DeployResponse_Status) String added in v0.1.5 

func (x DeployResponse_Status) String() string

func (DeployResponse_Status) Type added in v0.1.5 

func (DeployResponse_Status) Type() protoreflect.EnumType

type DeployTriggerRouteClient added in v0.1.5 

type DeployTriggerRouteClient interface {
	NotifyDeploy(ctx context.Context, in *DeployEventRequest, opts ...grpc.CallOption) (*DeployResponse, error)
}

DeployTriggerRouteClient is the client API for DeployTriggerRoute 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 NewDeployTriggerRouteClient added in v0.1.5 

func NewDeployTriggerRouteClient(cc grpc.ClientConnInterface) DeployTriggerRouteClient

type DeployTriggerRouteServer added in v0.1.5 

type DeployTriggerRouteServer interface {
	NotifyDeploy(context.Context, *DeployEventRequest) (*DeployResponse, error)
	// contains filtered or unexported methods
}

DeployTriggerRouteServer is the server API for DeployTriggerRoute service. All implementations must embed UnimplementedDeployTriggerRouteServer for forward compatibility

type JobEvent added in v0.1.5 

type JobEvent struct {
	Type  JobEventType `protobuf:"varint,1,opt,name=type,proto3,enum=grpcNotification.JobEventType" json:"type,omitempty"`
	JobId string       `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*JobEvent) Descriptor deprecated added in v0.1.5 

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

Deprecated: Use JobEvent.ProtoReflect.Descriptor instead.

func (*JobEvent) GetJobId added in v0.1.5 

func (x *JobEvent) GetJobId() string

func (*JobEvent) GetType added in v0.1.5 

func (x *JobEvent) GetType() JobEventType

func (*JobEvent) ProtoMessage added in v0.1.5 

func (*JobEvent) ProtoMessage()

func (*JobEvent) ProtoReflect added in v0.1.5 

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

func (*JobEvent) Reset added in v0.1.5 

func (x *JobEvent) Reset()

func (*JobEvent) String added in v0.1.5 

func (x *JobEvent) String() string

type JobEventRequest added in v0.1.5 

type JobEventRequest struct {
	Type    JobEventType `protobuf:"varint,1,opt,name=type,proto3,enum=grpcNotification.JobEventType" json:"type,omitempty"`
	JobId   string       `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	TaskIds []string     `protobuf:"bytes,3,rep,name=task_ids,json=taskIds,proto3" json:"task_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*JobEventRequest) Descriptor deprecated added in v0.1.5 

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

Deprecated: Use JobEventRequest.ProtoReflect.Descriptor instead.

func (*JobEventRequest) GetJobId added in v0.1.5 

func (x *JobEventRequest) GetJobId() string

func (*JobEventRequest) GetTaskIds added in v0.1.5 

func (x *JobEventRequest) GetTaskIds() []string

func (*JobEventRequest) GetType added in v0.1.5 

func (x *JobEventRequest) GetType() JobEventType

func (*JobEventRequest) ProtoMessage added in v0.1.5 

func (*JobEventRequest) ProtoMessage()

func (*JobEventRequest) ProtoReflect added in v0.1.5 

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

func (*JobEventRequest) Reset added in v0.1.5 

func (x *JobEventRequest) Reset()

func (*JobEventRequest) String added in v0.1.5 

func (x *JobEventRequest) String() string

type JobEventRouteClient added in v0.1.5 

type JobEventRouteClient interface {
	// This implements a server side streaming RPC
	GetJobEvent(ctx context.Context, in *JobTaskInfo, opts ...grpc.CallOption) (JobEventRoute_GetJobEventClient, error)
}

JobEventRouteClient is the client API for JobEventRoute 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 NewJobEventRouteClient added in v0.1.5 

func NewJobEventRouteClient(cc grpc.ClientConnInterface) JobEventRouteClient

type JobEventRouteServer added in v0.1.5 

type JobEventRouteServer interface {
	// This implements a server side streaming RPC
	GetJobEvent(*JobTaskInfo, JobEventRoute_GetJobEventServer) error
	// contains filtered or unexported methods
}

JobEventRouteServer is the server API for JobEventRoute service. All implementations must embed UnimplementedJobEventRouteServer for forward compatibility

type JobEventRoute_GetJobEventClient added in v0.1.5 

type JobEventRoute_GetJobEventClient interface {
	Recv() (*JobEvent, error)
	grpc.ClientStream
}

type JobEventRoute_GetJobEventServer added in v0.1.5 

type JobEventRoute_GetJobEventServer interface {
	Send(*JobEvent) error
	grpc.ServerStream
}

type JobEventType added in v0.1.5 

type JobEventType int32
const (
	JobEventType_UNKNOWN_EVENT_TYPE JobEventType = 0 // default
	JobEventType_START_JOB          JobEventType = 1
	JobEventType_STOP_JOB           JobEventType = 2
	JobEventType_UPDATE_JOB         JobEventType = 3
)

func (JobEventType) Descriptor added in v0.1.5 

func (JobEventType) Descriptor() protoreflect.EnumDescriptor

func (JobEventType) Enum added in v0.1.5 

func (x JobEventType) Enum() *JobEventType

func (JobEventType) EnumDescriptor deprecated added in v0.1.5 

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

Deprecated: Use JobEventType.Descriptor instead.

func (JobEventType) Number added in v0.1.5 

func (x JobEventType) Number() protoreflect.EnumNumber

func (JobEventType) String added in v0.1.5 

func (x JobEventType) String() string

func (JobEventType) Type added in v0.1.5 

func (JobEventType) Type() protoreflect.EnumType

type JobResponse added in v0.1.5 

type JobResponse struct {
	Status      JobResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=grpcNotification.JobResponse_Status" json:"status,omitempty"`
	Message     string             `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	FailedTasks []string           `protobuf:"bytes,3,rep,name=failed_tasks,json=failedTasks,proto3" json:"failed_tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*JobResponse) Descriptor deprecated added in v0.1.5 

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

Deprecated: Use JobResponse.ProtoReflect.Descriptor instead.

func (*JobResponse) GetFailedTasks added in v0.1.5 

func (x *JobResponse) GetFailedTasks() []string

func (*JobResponse) GetMessage added in v0.1.5 

func (x *JobResponse) GetMessage() string

func (*JobResponse) GetStatus added in v0.1.5 

func (x *JobResponse) GetStatus() JobResponse_Status

func (*JobResponse) ProtoMessage added in v0.1.5 

func (*JobResponse) ProtoMessage()

func (*JobResponse) ProtoReflect added in v0.1.5 

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

func (*JobResponse) Reset added in v0.1.5 

func (x *JobResponse) Reset()

func (*JobResponse) String added in v0.1.5 

func (x *JobResponse) String() string

type JobResponse_Status added in v0.1.5 

type JobResponse_Status int32
const (
	JobResponse_ERROR           JobResponse_Status = 0 // default
	JobResponse_PARTIAL_SUCCESS JobResponse_Status = 1 // e.g., not all agents received event
	JobResponse_SUCCESS         JobResponse_Status = 2
)

func (JobResponse_Status) Descriptor added in v0.1.5 

func (JobResponse_Status) Descriptor() protoreflect.EnumDescriptor

func (JobResponse_Status) Enum added in v0.1.5 

func (x JobResponse_Status) Enum() *JobResponse_Status

func (JobResponse_Status) EnumDescriptor deprecated added in v0.1.5 

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

Deprecated: Use JobResponse_Status.Descriptor instead.

func (JobResponse_Status) Number added in v0.1.5 

func (x JobResponse_Status) Number() protoreflect.EnumNumber

func (JobResponse_Status) String added in v0.1.5 

func (x JobResponse_Status) String() string

func (JobResponse_Status) Type added in v0.1.5 

func (JobResponse_Status) Type() protoreflect.EnumType

type JobTaskInfo added in v0.1.5 

type JobTaskInfo struct {
	Id       string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

func (*JobTaskInfo) Descriptor deprecated added in v0.1.5 

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

Deprecated: Use JobTaskInfo.ProtoReflect.Descriptor instead.

func (*JobTaskInfo) GetHostname added in v0.1.5 

func (x *JobTaskInfo) GetHostname() string

func (*JobTaskInfo) GetId added in v0.1.5 

func (x *JobTaskInfo) GetId() string

func (*JobTaskInfo) ProtoMessage added in v0.1.5 

func (*JobTaskInfo) ProtoMessage()

func (*JobTaskInfo) ProtoReflect added in v0.1.5 

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

func (*JobTaskInfo) Reset added in v0.1.5 

func (x *JobTaskInfo) Reset()

func (*JobTaskInfo) String added in v0.1.5 

func (x *JobTaskInfo) String() string

type JobTriggerRouteClient added in v0.1.5 

type JobTriggerRouteClient interface {
	NotifyJob(ctx context.Context, in *JobEventRequest, opts ...grpc.CallOption) (*JobResponse, error)
}

JobTriggerRouteClient is the client API for JobTriggerRoute 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 NewJobTriggerRouteClient added in v0.1.5 

func NewJobTriggerRouteClient(cc grpc.ClientConnInterface) JobTriggerRouteClient

type JobTriggerRouteServer added in v0.1.5 

type JobTriggerRouteServer interface {
	NotifyJob(context.Context, *JobEventRequest) (*JobResponse, error)
	// contains filtered or unexported methods
}

JobTriggerRouteServer is the server API for JobTriggerRoute service. All implementations must embed UnimplementedJobTriggerRouteServer for forward compatibility

type UnimplementedDeployEventRouteServer added in v0.1.5 

type UnimplementedDeployEventRouteServer struct {
}

UnimplementedDeployEventRouteServer must be embedded to have forward compatible implementations.

func (UnimplementedDeployEventRouteServer) GetDeployEvent added in v0.1.5 

func (UnimplementedDeployEventRouteServer) GetDeployEvent(*DeployInfo, DeployEventRoute_GetDeployEventServer) error

type UnimplementedDeployTriggerRouteServer added in v0.1.5 

type UnimplementedDeployTriggerRouteServer struct {
}

UnimplementedDeployTriggerRouteServer must be embedded to have forward compatible implementations.

func (UnimplementedDeployTriggerRouteServer) NotifyDeploy added in v0.1.5 

func (UnimplementedDeployTriggerRouteServer) NotifyDeploy(context.Context, *DeployEventRequest) (*DeployResponse, error)

type UnimplementedJobEventRouteServer added in v0.1.5 

type UnimplementedJobEventRouteServer struct {
}

UnimplementedJobEventRouteServer must be embedded to have forward compatible implementations.

func (UnimplementedJobEventRouteServer) GetJobEvent added in v0.1.5 

func (UnimplementedJobEventRouteServer) GetJobEvent(*JobTaskInfo, JobEventRoute_GetJobEventServer) error

type UnimplementedJobTriggerRouteServer added in v0.1.5 

type UnimplementedJobTriggerRouteServer struct {
}

UnimplementedJobTriggerRouteServer must be embedded to have forward compatible implementations.

func (UnimplementedJobTriggerRouteServer) NotifyJob added in v0.1.5 

func (UnimplementedJobTriggerRouteServer) NotifyJob(context.Context, *JobEventRequest) (*JobResponse, error)

type UnsafeDeployEventRouteServer added in v0.1.5 

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

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

type UnsafeDeployTriggerRouteServer added in v0.1.5 

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

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

type UnsafeJobEventRouteServer added in v0.1.5 

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

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

type UnsafeJobTriggerRouteServer added in v0.1.5 

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

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