awsdeployer_epb

package
v0.0.0-...-a444f70 Latest Latest
Warning

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

 Go to latest Published: Dec 27, 2024 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DeployerEvents_Deployment_FullMethodName  = "/o5.aws.deployer.v1.events.DeployerEvents/Deployment"
	DeployerEvents_Stack_FullMethodName       = "/o5.aws.deployer.v1.events.DeployerEvents/Stack"
	DeployerEvents_Environment_FullMethodName = "/o5.aws.deployer.v1.events.DeployerEvents/Environment"
)

Variables

View Source 
var DeployerEvents_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "o5.aws.deployer.v1.events.DeployerEvents",
	HandlerType: (*DeployerEventsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Deployment",
			Handler:    _DeployerEvents_Deployment_Handler,
		},
		{
			MethodName: "Stack",
			Handler:    _DeployerEvents_Stack_Handler,
		},
		{
			MethodName: "Environment",
			Handler:    _DeployerEvents_Environment_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "o5/aws/deployer/v1/events/deployer_event.proto",
}

DeployerEvents_ServiceDesc is the grpc.ServiceDesc for DeployerEvents 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_events_deployer_event_proto protoreflect.FileDescriptor

Functions

func RegisterDeployerEventsServer 

func RegisterDeployerEventsServer(s grpc.ServiceRegistrar, srv DeployerEventsServer)

Types

type DeployerEventsClient 

type DeployerEventsClient interface {
	Deployment(ctx context.Context, in *DeploymentEvent, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Stack(ctx context.Context, in *StackEvent, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Environment(ctx context.Context, in *EnvironmentEvent, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

DeployerEventsClient is the client API for DeployerEvents 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 NewDeployerEventsClient 

func NewDeployerEventsClient(cc grpc.ClientConnInterface) DeployerEventsClient

type DeployerEventsCollector 

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

func NewDeployerEventsCollector 

func NewDeployerEventsCollector[C any](collector o5msg.Collector[C]) *DeployerEventsCollector[C]

func (DeployerEventsCollector[C]) Deployment 

func (collect DeployerEventsCollector[C]) Deployment(sendContext C, msg *DeploymentEvent)

func (DeployerEventsCollector[C]) Environment 

func (collect DeployerEventsCollector[C]) Environment(sendContext C, msg *EnvironmentEvent)

func (DeployerEventsCollector[C]) Stack 

func (collect DeployerEventsCollector[C]) Stack(sendContext C, msg *StackEvent)

type DeployerEventsPublisher 

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

func NewDeployerEventsPublisher 

func NewDeployerEventsPublisher(publisher o5msg.Publisher) *DeployerEventsPublisher

func (DeployerEventsPublisher) Deployment 

func (publish DeployerEventsPublisher) Deployment(ctx context.Context, msg *DeploymentEvent) error

func (DeployerEventsPublisher) Environment 

func (publish DeployerEventsPublisher) Environment(ctx context.Context, msg *EnvironmentEvent) error

func (DeployerEventsPublisher) Stack 

func (publish DeployerEventsPublisher) Stack(ctx context.Context, msg *StackEvent) error

type DeployerEventsServer 

type DeployerEventsServer interface {
	Deployment(context.Context, *DeploymentEvent) (*emptypb.Empty, error)
	Stack(context.Context, *StackEvent) (*emptypb.Empty, error)
	Environment(context.Context, *EnvironmentEvent) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

DeployerEventsServer is the server API for DeployerEvents service. All implementations must embed UnimplementedDeployerEventsServer for forward compatibility

type DeployerEventsTxSender 

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

Service: DeployerEvents

func NewDeployerEventsTxSender 

func NewDeployerEventsTxSender[C any](sender o5msg.TxSender[C]) *DeployerEventsTxSender[C]

func (DeployerEventsTxSender[C]) Deployment 

func (send DeployerEventsTxSender[C]) Deployment(ctx context.Context, sendContext C, msg *DeploymentEvent) error

func (DeployerEventsTxSender[C]) Environment 

func (send DeployerEventsTxSender[C]) Environment(ctx context.Context, sendContext C, msg *EnvironmentEvent) error

func (DeployerEventsTxSender[C]) Stack 

func (send DeployerEventsTxSender[C]) Stack(ctx context.Context, sendContext C, msg *StackEvent) error

type DeploymentEvent 

type DeploymentEvent struct {
	Event  *awsdeployer_pb.DeploymentEvent     `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	Status awsdeployer_pb.DeploymentStatus     `protobuf:"varint,2,opt,name=status,proto3,enum=o5.aws.deployer.v1.DeploymentStatus" json:"status,omitempty"`
	State  *awsdeployer_pb.DeploymentStateData `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploymentEvent) Descriptor deprecated 

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

Deprecated: Use DeploymentEvent.ProtoReflect.Descriptor instead.

func (*DeploymentEvent) GetEvent 

func (x *DeploymentEvent) GetEvent() *awsdeployer_pb.DeploymentEvent

func (*DeploymentEvent) GetState 

func (x *DeploymentEvent) GetState() *awsdeployer_pb.DeploymentStateData

func (*DeploymentEvent) GetStatus 

func (x *DeploymentEvent) GetStatus() awsdeployer_pb.DeploymentStatus

func (*DeploymentEvent) O5MessageHeader 

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

func (*DeploymentEvent) ProtoMessage 

func (*DeploymentEvent) ProtoMessage()

func (*DeploymentEvent) ProtoReflect 

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

func (*DeploymentEvent) Reset 

func (x *DeploymentEvent) Reset()

func (*DeploymentEvent) String 

func (x *DeploymentEvent) String() string

type EnvironmentEvent 

type EnvironmentEvent struct {
	Event  *awsdeployer_pb.EnvironmentEvent     `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	Status awsdeployer_pb.EnvironmentStatus     `protobuf:"varint,2,opt,name=status,proto3,enum=o5.aws.deployer.v1.EnvironmentStatus" json:"status,omitempty"`
	State  *awsdeployer_pb.EnvironmentStateData `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvironmentEvent) Descriptor deprecated 

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

Deprecated: Use EnvironmentEvent.ProtoReflect.Descriptor instead.

func (*EnvironmentEvent) GetEvent 

func (x *EnvironmentEvent) GetEvent() *awsdeployer_pb.EnvironmentEvent

func (*EnvironmentEvent) GetState 

func (x *EnvironmentEvent) GetState() *awsdeployer_pb.EnvironmentStateData

func (*EnvironmentEvent) GetStatus 

func (x *EnvironmentEvent) GetStatus() awsdeployer_pb.EnvironmentStatus

func (*EnvironmentEvent) O5MessageHeader 

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

func (*EnvironmentEvent) ProtoMessage 

func (*EnvironmentEvent) ProtoMessage()

func (*EnvironmentEvent) ProtoReflect 

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

func (*EnvironmentEvent) Reset 

func (x *EnvironmentEvent) Reset()

func (*EnvironmentEvent) String 

func (x *EnvironmentEvent) String() string

type StackEvent 

type StackEvent struct {
	Event  *awsdeployer_pb.StackEvent     `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	Status awsdeployer_pb.StackStatus     `protobuf:"varint,2,opt,name=status,proto3,enum=o5.aws.deployer.v1.StackStatus" json:"status,omitempty"`
	State  *awsdeployer_pb.StackStateData `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*StackEvent) Descriptor deprecated 

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

Deprecated: Use StackEvent.ProtoReflect.Descriptor instead.

func (*StackEvent) GetEvent 

func (x *StackEvent) GetEvent() *awsdeployer_pb.StackEvent

func (*StackEvent) GetState 

func (x *StackEvent) GetState() *awsdeployer_pb.StackStateData

func (*StackEvent) GetStatus 

func (x *StackEvent) GetStatus() awsdeployer_pb.StackStatus

func (*StackEvent) O5MessageHeader 

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

func (*StackEvent) ProtoMessage 

func (*StackEvent) ProtoMessage()

func (*StackEvent) ProtoReflect 

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

func (*StackEvent) Reset 

func (x *StackEvent) Reset()

func (*StackEvent) String 

func (x *StackEvent) String() string

type UnimplementedDeployerEventsServer 

type UnimplementedDeployerEventsServer struct {
}

UnimplementedDeployerEventsServer must be embedded to have forward compatible implementations.

func (UnimplementedDeployerEventsServer) Deployment 

func (UnimplementedDeployerEventsServer) Deployment(context.Context, *DeploymentEvent) (*emptypb.Empty, error)

func (UnimplementedDeployerEventsServer) Environment 

func (UnimplementedDeployerEventsServer) Environment(context.Context, *EnvironmentEvent) (*emptypb.Empty, error)

func (UnimplementedDeployerEventsServer) Stack 

func (UnimplementedDeployerEventsServer) Stack(context.Context, *StackEvent) (*emptypb.Empty, error)

type UnsafeDeployerEventsServer 

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

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