awsdeployer_tpb

package
v0.0.0-...-cdab844 Latest Latest
Warning

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

 Go to latest Published: Mar 6, 2025 License: MIT Imports: 17 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	DeploymentReplyTopic_DeploymentStatus_FullMethodName = "/o5.aws.deployer.v1.topic.DeploymentReplyTopic/DeploymentStatus"
)
View Source 
const (
	DeploymentRequestTopic_RequestDeployment_FullMethodName = "/o5.aws.deployer.v1.topic.DeploymentRequestTopic/RequestDeployment"
)

Variables

View Source 
var (
	DeploymentStatus_name = map[int32]string{
		0: "DEPLOYMENT_STATUS_UNSPECIFIED",
		1: "DEPLOYMENT_STATUS_PENDING",
		2: "DEPLOYMENT_STATUS_IN_PROGRESS",
		3: "DEPLOYMENT_STATUS_SUCCESS",
		4: "DEPLOYMENT_STATUS_FAILED",
	}
	DeploymentStatus_value = map[string]int32{
		"DEPLOYMENT_STATUS_UNSPECIFIED": 0,
		"DEPLOYMENT_STATUS_PENDING":     1,
		"DEPLOYMENT_STATUS_IN_PROGRESS": 2,
		"DEPLOYMENT_STATUS_SUCCESS":     3,
		"DEPLOYMENT_STATUS_FAILED":      4,
	}
)

Enum value maps for DeploymentStatus.

View Source 
var (
	DeploymentStatus_name_short = map[int32]string{
		0: "UNSPECIFIED",
		1: "PENDING",
		2: "IN_PROGRESS",
		3: "SUCCESS",
		4: "FAILED",
	}
	DeploymentStatus_value_short = map[string]int32{
		"UNSPECIFIED": 0,
		"PENDING":     1,
		"IN_PROGRESS": 2,
		"SUCCESS":     3,
		"FAILED":      4,
	}
	DeploymentStatus_value_either = map[string]int32{
		"UNSPECIFIED":                   0,
		"DEPLOYMENT_STATUS_UNSPECIFIED": 0,
		"PENDING":                       1,
		"DEPLOYMENT_STATUS_PENDING":     1,
		"IN_PROGRESS":                   2,
		"DEPLOYMENT_STATUS_IN_PROGRESS": 2,
		"SUCCESS":                       3,
		"DEPLOYMENT_STATUS_SUCCESS":     3,
		"FAILED":                        4,
		"DEPLOYMENT_STATUS_FAILED":      4,
	}
)
View Source 
var DeploymentReplyTopic_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "o5.aws.deployer.v1.topic.DeploymentReplyTopic",
	HandlerType: (*DeploymentReplyTopicServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DeploymentStatus",
			Handler:    _DeploymentReplyTopic_DeploymentStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "o5/aws/deployer/v1/topic/deployer.proto",
}

DeploymentReplyTopic_ServiceDesc is the grpc.ServiceDesc for DeploymentReplyTopic 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 DeploymentRequestTopic_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "o5.aws.deployer.v1.topic.DeploymentRequestTopic",
	HandlerType: (*DeploymentRequestTopicServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RequestDeployment",
			Handler:    _DeploymentRequestTopic_RequestDeployment_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "o5/aws/deployer/v1/topic/deployer.proto",
}

DeploymentRequestTopic_ServiceDesc is the grpc.ServiceDesc for DeploymentRequestTopic 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_o5_aws_deployer_v1_topic_deployer_proto protoreflect.FileDescriptor

Functions

func RegisterDeploymentReplyTopicServer 

func RegisterDeploymentReplyTopicServer(s grpc.ServiceRegistrar, srv DeploymentReplyTopicServer)

func RegisterDeploymentRequestTopicServer 

func RegisterDeploymentRequestTopicServer(s grpc.ServiceRegistrar, srv DeploymentRequestTopicServer)

Types

type DeploymentReplyTopicClient 

type DeploymentReplyTopicClient interface {
	DeploymentStatus(ctx context.Context, in *DeploymentStatusMessage, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

DeploymentReplyTopicClient is the client API for DeploymentReplyTopic 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 NewDeploymentReplyTopicClient 

func NewDeploymentReplyTopicClient(cc grpc.ClientConnInterface) DeploymentReplyTopicClient

type DeploymentReplyTopicCollector 

type DeploymentReplyTopicCollector[C any] struct {
	// contains filtered or unexported fields
}

func NewDeploymentReplyTopicCollector 

func NewDeploymentReplyTopicCollector[C any](collector o5msg.Collector[C]) *DeploymentReplyTopicCollector[C]

func (DeploymentReplyTopicCollector[C]) DeploymentStatus 

func (collect DeploymentReplyTopicCollector[C]) DeploymentStatus(sendContext C, msg *DeploymentStatusMessage)

type DeploymentReplyTopicPublisher 

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

func NewDeploymentReplyTopicPublisher 

func NewDeploymentReplyTopicPublisher(publisher o5msg.Publisher) *DeploymentReplyTopicPublisher

func (DeploymentReplyTopicPublisher) DeploymentStatus 

func (publish DeploymentReplyTopicPublisher) DeploymentStatus(ctx context.Context, msg *DeploymentStatusMessage) error

type DeploymentReplyTopicServer 

type DeploymentReplyTopicServer interface {
	DeploymentStatus(context.Context, *DeploymentStatusMessage) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

DeploymentReplyTopicServer is the server API for DeploymentReplyTopic service. All implementations must embed UnimplementedDeploymentReplyTopicServer for forward compatibility

type DeploymentReplyTopicTxSender 

type DeploymentReplyTopicTxSender[C any] struct {
	// contains filtered or unexported fields
}

func NewDeploymentReplyTopicTxSender 

func NewDeploymentReplyTopicTxSender[C any](sender o5msg.TxSender[C]) *DeploymentReplyTopicTxSender[C]

func (DeploymentReplyTopicTxSender[C]) DeploymentStatus 

func (send DeploymentReplyTopicTxSender[C]) DeploymentStatus(ctx context.Context, sendContext C, msg *DeploymentStatusMessage) error

type DeploymentRequestTopicClient 

type DeploymentRequestTopicClient interface {
	RequestDeployment(ctx context.Context, in *RequestDeploymentMessage, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

DeploymentRequestTopicClient is the client API for DeploymentRequestTopic 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 NewDeploymentRequestTopicClient 

func NewDeploymentRequestTopicClient(cc grpc.ClientConnInterface) DeploymentRequestTopicClient

type DeploymentRequestTopicCollector 

type DeploymentRequestTopicCollector[C any] struct {
	// contains filtered or unexported fields
}

func NewDeploymentRequestTopicCollector 

func NewDeploymentRequestTopicCollector[C any](collector o5msg.Collector[C]) *DeploymentRequestTopicCollector[C]

func (DeploymentRequestTopicCollector[C]) RequestDeployment 

func (collect DeploymentRequestTopicCollector[C]) RequestDeployment(sendContext C, msg *RequestDeploymentMessage)

type DeploymentRequestTopicPublisher 

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

func NewDeploymentRequestTopicPublisher 

func NewDeploymentRequestTopicPublisher(publisher o5msg.Publisher) *DeploymentRequestTopicPublisher

func (DeploymentRequestTopicPublisher) RequestDeployment 

func (publish DeploymentRequestTopicPublisher) RequestDeployment(ctx context.Context, msg *RequestDeploymentMessage) error

type DeploymentRequestTopicServer 

type DeploymentRequestTopicServer interface {
	RequestDeployment(context.Context, *RequestDeploymentMessage) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

DeploymentRequestTopicServer is the server API for DeploymentRequestTopic service. All implementations must embed UnimplementedDeploymentRequestTopicServer for forward compatibility

type DeploymentRequestTopicTxSender 

type DeploymentRequestTopicTxSender[C any] struct {
	// contains filtered or unexported fields
}

func NewDeploymentRequestTopicTxSender 

func NewDeploymentRequestTopicTxSender[C any](sender o5msg.TxSender[C]) *DeploymentRequestTopicTxSender[C]

func (DeploymentRequestTopicTxSender[C]) RequestDeployment 

func (send DeploymentRequestTopicTxSender[C]) RequestDeployment(ctx context.Context, sendContext C, msg *RequestDeploymentMessage) error

type DeploymentStatus 

type DeploymentStatus int32
const (
	DeploymentStatus_DEPLOYMENT_STATUS_UNSPECIFIED DeploymentStatus = 0
	DeploymentStatus_DEPLOYMENT_STATUS_PENDING     DeploymentStatus = 1
	DeploymentStatus_DEPLOYMENT_STATUS_IN_PROGRESS DeploymentStatus = 2
	DeploymentStatus_DEPLOYMENT_STATUS_SUCCESS     DeploymentStatus = 3
	DeploymentStatus_DEPLOYMENT_STATUS_FAILED      DeploymentStatus = 4
)
const (
	DeploymentStatus_UNSPECIFIED DeploymentStatus = 0
	DeploymentStatus_PENDING     DeploymentStatus = 1
	DeploymentStatus_IN_PROGRESS DeploymentStatus = 2
	DeploymentStatus_SUCCESS     DeploymentStatus = 3
	DeploymentStatus_FAILED      DeploymentStatus = 4
)

DeploymentStatus

func (DeploymentStatus) Descriptor 

func (DeploymentStatus) Descriptor() protoreflect.EnumDescriptor

func (DeploymentStatus) Enum 

func (x DeploymentStatus) Enum() *DeploymentStatus

func (DeploymentStatus) EnumDescriptor deprecated 

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

Deprecated: Use DeploymentStatus.Descriptor instead.

func (DeploymentStatus) Number 

func (x DeploymentStatus) Number() protoreflect.EnumNumber

func (*DeploymentStatus) Scan 

func (x *DeploymentStatus) Scan(value interface{}) error

func (DeploymentStatus) ShortString 

func (x DeploymentStatus) ShortString() string

ShortString returns the un-prefixed string representation of the enum value

func (DeploymentStatus) String 

func (x DeploymentStatus) String() string

func (DeploymentStatus) Type 

func (DeploymentStatus) Type() protoreflect.EnumType

func (DeploymentStatus) Value 

func (x DeploymentStatus) Value() (driver.Value, error)

type DeploymentStatusMessage 

type DeploymentStatusMessage struct {
	Request      *messaging_j5pb.RequestMetadata `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	DeploymentId string                          `protobuf:"bytes,2,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	Status       DeploymentStatus                `protobuf:"varint,3,opt,name=status,proto3,enum=o5.aws.deployer.v1.topic.DeploymentStatus" json:"status,omitempty"`
	Message      string                          `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploymentStatusMessage) Descriptor deprecated 

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

Deprecated: Use DeploymentStatusMessage.ProtoReflect.Descriptor instead.

func (*DeploymentStatusMessage) GetDeploymentId 

func (x *DeploymentStatusMessage) GetDeploymentId() string

func (*DeploymentStatusMessage) GetJ5RequestMetadata 

func (msg *DeploymentStatusMessage) GetJ5RequestMetadata() *messaging_j5pb.RequestMetadata

func (*DeploymentStatusMessage) GetMessage 

func (x *DeploymentStatusMessage) GetMessage() string

func (*DeploymentStatusMessage) GetRequest 

func (x *DeploymentStatusMessage) GetRequest() *messaging_j5pb.RequestMetadata

func (*DeploymentStatusMessage) GetStatus 

func (x *DeploymentStatusMessage) GetStatus() DeploymentStatus

func (*DeploymentStatusMessage) O5MessageHeader 

func (msg *DeploymentStatusMessage) O5MessageHeader() o5msg.Header

func (*DeploymentStatusMessage) ProtoMessage 

func (*DeploymentStatusMessage) ProtoMessage()

func (*DeploymentStatusMessage) ProtoReflect 

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

func (*DeploymentStatusMessage) Reset 

func (x *DeploymentStatusMessage) Reset()

func (*DeploymentStatusMessage) SetJ5RequestMetadata 

func (msg *DeploymentStatusMessage) SetJ5RequestMetadata(md *messaging_j5pb.RequestMetadata)

Service: DeploymentReplyTopic Expose Request Metadata

func (*DeploymentStatusMessage) String 

func (x *DeploymentStatusMessage) String() string

type RequestDeploymentMessage 

type RequestDeploymentMessage struct {
	Request       *messaging_j5pb.RequestMetadata `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	DeploymentId  string                          `protobuf:"bytes,2,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	EnvironmentId string                          `protobuf:"bytes,3,opt,name=environment_id,json=environmentId,proto3" json:"environment_id,omitempty"`
	Application   *application_pb.Application     `protobuf:"bytes,4,opt,name=application,proto3" json:"application,omitempty"`
	Version       string                          `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	Flags         *awsdeployer_pb.DeploymentFlags `protobuf:"bytes,6,opt,name=flags,proto3" json:"flags,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestDeploymentMessage) Descriptor deprecated 

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

Deprecated: Use RequestDeploymentMessage.ProtoReflect.Descriptor instead.

func (*RequestDeploymentMessage) GetApplication 

func (x *RequestDeploymentMessage) GetApplication() *application_pb.Application

func (*RequestDeploymentMessage) GetDeploymentId 

func (x *RequestDeploymentMessage) GetDeploymentId() string

func (*RequestDeploymentMessage) GetEnvironmentId 

func (x *RequestDeploymentMessage) GetEnvironmentId() string

func (*RequestDeploymentMessage) GetFlags 

func (x *RequestDeploymentMessage) GetFlags() *awsdeployer_pb.DeploymentFlags

func (*RequestDeploymentMessage) GetJ5RequestMetadata 

func (msg *RequestDeploymentMessage) GetJ5RequestMetadata() *messaging_j5pb.RequestMetadata

func (*RequestDeploymentMessage) GetRequest 

func (x *RequestDeploymentMessage) GetRequest() *messaging_j5pb.RequestMetadata

func (*RequestDeploymentMessage) GetVersion 

func (x *RequestDeploymentMessage) GetVersion() string

func (*RequestDeploymentMessage) O5MessageHeader 

func (msg *RequestDeploymentMessage) O5MessageHeader() o5msg.Header

func (*RequestDeploymentMessage) ProtoMessage 

func (*RequestDeploymentMessage) ProtoMessage()

func (*RequestDeploymentMessage) ProtoReflect 

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

func (*RequestDeploymentMessage) Reset 

func (x *RequestDeploymentMessage) Reset()

func (*RequestDeploymentMessage) SetJ5RequestMetadata 

func (msg *RequestDeploymentMessage) SetJ5RequestMetadata(md *messaging_j5pb.RequestMetadata)

Service: DeploymentRequestTopic Expose Request Metadata

func (*RequestDeploymentMessage) String 

func (x *RequestDeploymentMessage) String() string

type UnimplementedDeploymentReplyTopicServer 

type UnimplementedDeploymentReplyTopicServer struct {
}

UnimplementedDeploymentReplyTopicServer must be embedded to have forward compatible implementations.

func (UnimplementedDeploymentReplyTopicServer) DeploymentStatus 

func (UnimplementedDeploymentReplyTopicServer) DeploymentStatus(context.Context, *DeploymentStatusMessage) (*emptypb.Empty, error)

type UnimplementedDeploymentRequestTopicServer 

type UnimplementedDeploymentRequestTopicServer struct {
}

UnimplementedDeploymentRequestTopicServer must be embedded to have forward compatible implementations.

func (UnimplementedDeploymentRequestTopicServer) RequestDeployment 

func (UnimplementedDeploymentRequestTopicServer) RequestDeployment(context.Context, *RequestDeploymentMessage) (*emptypb.Empty, error)

type UnsafeDeploymentReplyTopicServer 

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

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

type UnsafeDeploymentRequestTopicServer 

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

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