installed_components

package
v2.87.1 Latest Latest
Warning

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

 Go to latest Published: Jun 5, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	InstalledComponentType_name = map[int32]string{
		0: "INSTALLED_COMPONENT_TYPE_UNSPECIFIED",
		1: "BATCH_JOBS_AGENT",
		2: "BATCH_EXPORTERS_AGENT",
		3: "KAFKA_EXPORTERS_AGENT",
		4: "STREAMS_AGENT",
		5: "EVENT_GATEWAY",
		6: "WEB_SOCKET",
	}
	InstalledComponentType_value = map[string]int32{
		"INSTALLED_COMPONENT_TYPE_UNSPECIFIED": 0,
		"BATCH_JOBS_AGENT":                     1,
		"BATCH_EXPORTERS_AGENT":                2,
		"KAFKA_EXPORTERS_AGENT":                3,
		"STREAMS_AGENT":                        4,
		"EVENT_GATEWAY":                        5,
		"WEB_SOCKET":                           6,
	}
)

Enum value maps for InstalledComponentType.

View Source 
var (
	InstalledComponentStateType_name = map[int32]string{
		0: "INSTALLED_COMPONENT_STATE_TYPE_UNSPECIFIED",
		1: "PROVISIONED",
		2: "RUNNING",
		3: "ERROR",
	}
	InstalledComponentStateType_value = map[string]int32{
		"INSTALLED_COMPONENT_STATE_TYPE_UNSPECIFIED": 0,
		"PROVISIONED": 1,
		"RUNNING":     2,
		"ERROR":       3,
	}
)

Enum value maps for InstalledComponentStateType.

View Source 
var File_strmprivacy_api_installed_components_v1_installed_components_v1_proto protoreflect.FileDescriptor
View Source 
var InstalledComponentsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "strmprivacy.api.installed_components.v1.InstalledComponentsService",
	HandlerType: (*InstalledComponentsServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UpdateInstalledComponentState",
			Handler:    _InstalledComponentsService_UpdateInstalledComponentState_Handler,
		},
		{
			MethodName: "GetInstalledComponent",
			Handler:    _InstalledComponentsService_GetInstalledComponent_Handler,
		},
		{
			MethodName: "ListInstalledComponents",
			Handler:    _InstalledComponentsService_ListInstalledComponents_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "strmprivacy/api/installed_components/v1/installed_components_v1.proto",
}

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

Functions

func RegisterInstalledComponentsServiceServer 

func RegisterInstalledComponentsServiceServer(s grpc.ServiceRegistrar, srv InstalledComponentsServiceServer)

Types

type GetInstalledComponentRequest 

type GetInstalledComponentRequest struct {
	InstalledComponentType InstalledComponentType `` /* 198-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetInstalledComponentRequest) Descriptor deprecated 

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

Deprecated: Use GetInstalledComponentRequest.ProtoReflect.Descriptor instead.

func (*GetInstalledComponentRequest) GetInstalledComponentType 

func (x *GetInstalledComponentRequest) GetInstalledComponentType() InstalledComponentType

func (*GetInstalledComponentRequest) ProtoMessage 

func (*GetInstalledComponentRequest) ProtoMessage()

func (*GetInstalledComponentRequest) ProtoReflect 

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

func (*GetInstalledComponentRequest) Reset 

func (x *GetInstalledComponentRequest) Reset()

func (*GetInstalledComponentRequest) String 

func (x *GetInstalledComponentRequest) String() string

type GetInstalledComponentResponse 

type GetInstalledComponentResponse struct {
	InstalledComponent *InstalledComponent `protobuf:"bytes,1,opt,name=installed_component,json=installedComponent,proto3" json:"installed_component,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInstalledComponentResponse) Descriptor deprecated 

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

Deprecated: Use GetInstalledComponentResponse.ProtoReflect.Descriptor instead.

func (*GetInstalledComponentResponse) GetInstalledComponent 

func (x *GetInstalledComponentResponse) GetInstalledComponent() *InstalledComponent

func (*GetInstalledComponentResponse) ProtoMessage 

func (*GetInstalledComponentResponse) ProtoMessage()

func (*GetInstalledComponentResponse) ProtoReflect 

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

func (*GetInstalledComponentResponse) Reset 

func (x *GetInstalledComponentResponse) Reset()

func (*GetInstalledComponentResponse) String 

func (x *GetInstalledComponentResponse) String() string

type InstalledComponent 

type InstalledComponent struct {

	// One installation always has one InstalledComponent of a given type (e.g. one Event Gateway deployment), so within
	// one installation, the type is unique.
	ComponentType InstalledComponentType        `` /* 169-byte string literal not displayed */
	Instances     []*InstalledComponentInstance `protobuf:"bytes,2,rep,name=instances,proto3" json:"instances,omitempty"`
	// contains filtered or unexported fields
}

One functional component, installed in an "installation" (e.g. an Event Gateway). On k8s, this is on the level of a deployment, so one InstalledComponent can contain multiple component instances (Pods) and each of these component instances has its own list of states. It's up to the client (console) to aggregate these states if needed.

func (*InstalledComponent) Descriptor deprecated 

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

Deprecated: Use InstalledComponent.ProtoReflect.Descriptor instead.

func (*InstalledComponent) GetComponentType 

func (x *InstalledComponent) GetComponentType() InstalledComponentType

func (*InstalledComponent) GetInstances 

func (x *InstalledComponent) GetInstances() []*InstalledComponentInstance

func (*InstalledComponent) ProtoMessage 

func (*InstalledComponent) ProtoMessage()

func (*InstalledComponent) ProtoReflect 

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

func (*InstalledComponent) Reset 

func (x *InstalledComponent) Reset()

func (*InstalledComponent) String 

func (x *InstalledComponent) String() string

type InstalledComponentInstance 

type InstalledComponentInstance struct {

	// The unique ID of this instance, e.g. the UID from the Pod metadata.
	Id     string                     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	States []*InstalledComponentState `protobuf:"bytes,2,rep,name=states,proto3" json:"states,omitempty"`
	// contains filtered or unexported fields
}

One instance (Pod) that is part of an installed component (Deployment).

func (*InstalledComponentInstance) Descriptor deprecated 

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

Deprecated: Use InstalledComponentInstance.ProtoReflect.Descriptor instead.

func (*InstalledComponentInstance) GetId 

func (x *InstalledComponentInstance) GetId() string

func (*InstalledComponentInstance) GetStates 

func (x *InstalledComponentInstance) GetStates() []*InstalledComponentState

func (*InstalledComponentInstance) ProtoMessage 

func (*InstalledComponentInstance) ProtoMessage()

func (*InstalledComponentInstance) ProtoReflect 

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

func (*InstalledComponentInstance) Reset 

func (x *InstalledComponentInstance) Reset()

func (*InstalledComponentInstance) String 

func (x *InstalledComponentInstance) String() string

type InstalledComponentState 

type InstalledComponentState struct {
	StateTime *timestamppb.Timestamp      `protobuf:"bytes,1,opt,name=state_time,json=stateTime,proto3" json:"state_time,omitempty"`
	StateType InstalledComponentStateType `` /* 162-byte string literal not displayed */
	Message   string                      `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*InstalledComponentState) Descriptor deprecated 

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

Deprecated: Use InstalledComponentState.ProtoReflect.Descriptor instead.

func (*InstalledComponentState) GetMessage 

func (x *InstalledComponentState) GetMessage() string

func (*InstalledComponentState) GetStateTime 

func (x *InstalledComponentState) GetStateTime() *timestamppb.Timestamp

func (*InstalledComponentState) GetStateType 

func (x *InstalledComponentState) GetStateType() InstalledComponentStateType

func (*InstalledComponentState) ProtoMessage 

func (*InstalledComponentState) ProtoMessage()

func (*InstalledComponentState) ProtoReflect 

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

func (*InstalledComponentState) Reset 

func (x *InstalledComponentState) Reset()

func (*InstalledComponentState) String 

func (x *InstalledComponentState) String() string

type InstalledComponentStateType 

type InstalledComponentStateType int32
const (
	InstalledComponentStateType_INSTALLED_COMPONENT_STATE_TYPE_UNSPECIFIED InstalledComponentStateType = 0
	// The Helm chart has been installed, but an application isn't yet started
	InstalledComponentStateType_PROVISIONED InstalledComponentStateType = 1
	// The application is running correctly
	InstalledComponentStateType_RUNNING InstalledComponentStateType = 2
	// An error occurred preventing the application to run correctly
	InstalledComponentStateType_ERROR InstalledComponentStateType = 3
)

func (InstalledComponentStateType) Descriptor 

func (InstalledComponentStateType) Descriptor() protoreflect.EnumDescriptor

func (InstalledComponentStateType) Enum 

func (x InstalledComponentStateType) Enum() *InstalledComponentStateType

func (InstalledComponentStateType) EnumDescriptor deprecated 

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

Deprecated: Use InstalledComponentStateType.Descriptor instead.

func (InstalledComponentStateType) Number 

func (x InstalledComponentStateType) Number() protoreflect.EnumNumber

func (InstalledComponentStateType) String 

func (x InstalledComponentStateType) String() string

func (InstalledComponentStateType) Type 

func (InstalledComponentStateType) Type() protoreflect.EnumType

type InstalledComponentType 

type InstalledComponentType int32
const (
	InstalledComponentType_INSTALLED_COMPONENT_TYPE_UNSPECIFIED InstalledComponentType = 0
	InstalledComponentType_BATCH_JOBS_AGENT                     InstalledComponentType = 1
	InstalledComponentType_BATCH_EXPORTERS_AGENT                InstalledComponentType = 2
	InstalledComponentType_KAFKA_EXPORTERS_AGENT                InstalledComponentType = 3
	InstalledComponentType_STREAMS_AGENT                        InstalledComponentType = 4
	InstalledComponentType_EVENT_GATEWAY                        InstalledComponentType = 5
	InstalledComponentType_WEB_SOCKET                           InstalledComponentType = 6
)

func (InstalledComponentType) Descriptor 

func (InstalledComponentType) Descriptor() protoreflect.EnumDescriptor

func (InstalledComponentType) Enum 

func (x InstalledComponentType) Enum() *InstalledComponentType

func (InstalledComponentType) EnumDescriptor deprecated 

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

Deprecated: Use InstalledComponentType.Descriptor instead.

func (InstalledComponentType) Number 

func (x InstalledComponentType) Number() protoreflect.EnumNumber

func (InstalledComponentType) String 

func (x InstalledComponentType) String() string

func (InstalledComponentType) Type 

func (InstalledComponentType) Type() protoreflect.EnumType

type InstalledComponentsServiceClient 

type InstalledComponentsServiceClient interface {
	UpdateInstalledComponentState(ctx context.Context, in *UpdateInstalledComponentStateRequest, opts ...grpc.CallOption) (*UpdateInstalledComponentStateResponse, error)
	GetInstalledComponent(ctx context.Context, in *GetInstalledComponentRequest, opts ...grpc.CallOption) (*GetInstalledComponentResponse, error)
	ListInstalledComponents(ctx context.Context, in *ListInstalledComponentsRequest, opts ...grpc.CallOption) (*ListInstalledComponentsResponse, error)
}

InstalledComponentsServiceClient is the client API for InstalledComponentsService 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 NewInstalledComponentsServiceClient 

func NewInstalledComponentsServiceClient(cc grpc.ClientConnInterface) InstalledComponentsServiceClient

type InstalledComponentsServiceServer 

type InstalledComponentsServiceServer interface {
	UpdateInstalledComponentState(context.Context, *UpdateInstalledComponentStateRequest) (*UpdateInstalledComponentStateResponse, error)
	GetInstalledComponent(context.Context, *GetInstalledComponentRequest) (*GetInstalledComponentResponse, error)
	ListInstalledComponents(context.Context, *ListInstalledComponentsRequest) (*ListInstalledComponentsResponse, error)
	// contains filtered or unexported methods
}

InstalledComponentsServiceServer is the server API for InstalledComponentsService service. All implementations must embed UnimplementedInstalledComponentsServiceServer for forward compatibility

type ListInstalledComponentsRequest 

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

func (*ListInstalledComponentsRequest) Descriptor deprecated 

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

Deprecated: Use ListInstalledComponentsRequest.ProtoReflect.Descriptor instead.

func (*ListInstalledComponentsRequest) ProtoMessage 

func (*ListInstalledComponentsRequest) ProtoMessage()

func (*ListInstalledComponentsRequest) ProtoReflect 

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

func (*ListInstalledComponentsRequest) Reset 

func (x *ListInstalledComponentsRequest) Reset()

func (*ListInstalledComponentsRequest) String 

func (x *ListInstalledComponentsRequest) String() string

type ListInstalledComponentsResponse 

type ListInstalledComponentsResponse struct {
	InstalledComponents []*InstalledComponent `protobuf:"bytes,1,rep,name=installed_components,json=installedComponents,proto3" json:"installed_components,omitempty"`
	// contains filtered or unexported fields
}

func (*ListInstalledComponentsResponse) Descriptor deprecated 

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

Deprecated: Use ListInstalledComponentsResponse.ProtoReflect.Descriptor instead.

func (*ListInstalledComponentsResponse) GetInstalledComponents 

func (x *ListInstalledComponentsResponse) GetInstalledComponents() []*InstalledComponent

func (*ListInstalledComponentsResponse) ProtoMessage 

func (*ListInstalledComponentsResponse) ProtoMessage()

func (*ListInstalledComponentsResponse) ProtoReflect 

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

func (*ListInstalledComponentsResponse) Reset 

func (x *ListInstalledComponentsResponse) Reset()

func (*ListInstalledComponentsResponse) String 

func (x *ListInstalledComponentsResponse) String() string

type UnimplementedInstalledComponentsServiceServer 

type UnimplementedInstalledComponentsServiceServer struct {
}

UnimplementedInstalledComponentsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedInstalledComponentsServiceServer) GetInstalledComponent 

func (UnimplementedInstalledComponentsServiceServer) GetInstalledComponent(context.Context, *GetInstalledComponentRequest) (*GetInstalledComponentResponse, error)

func (UnimplementedInstalledComponentsServiceServer) ListInstalledComponents 

func (UnimplementedInstalledComponentsServiceServer) ListInstalledComponents(context.Context, *ListInstalledComponentsRequest) (*ListInstalledComponentsResponse, error)

func (UnimplementedInstalledComponentsServiceServer) UpdateInstalledComponentState 

func (UnimplementedInstalledComponentsServiceServer) UpdateInstalledComponentState(context.Context, *UpdateInstalledComponentStateRequest) (*UpdateInstalledComponentStateResponse, error)

type UnsafeInstalledComponentsServiceServer 

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

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

type UpdateInstalledComponentStateRequest 

type UpdateInstalledComponentStateRequest struct {
	InstalledComponentState *InstalledComponentState `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

(-- api-linter: core::0134::request-mask-required=disabled 

aip.dev/not-precedent: This RPC only updates one field. --)

func (*UpdateInstalledComponentStateRequest) Descriptor deprecated 

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

Deprecated: Use UpdateInstalledComponentStateRequest.ProtoReflect.Descriptor instead.

func (*UpdateInstalledComponentStateRequest) GetInstalledComponentState 

func (x *UpdateInstalledComponentStateRequest) GetInstalledComponentState() *InstalledComponentState

func (*UpdateInstalledComponentStateRequest) ProtoMessage 

func (*UpdateInstalledComponentStateRequest) ProtoMessage()

func (*UpdateInstalledComponentStateRequest) ProtoReflect 

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

func (*UpdateInstalledComponentStateRequest) Reset 

func (x *UpdateInstalledComponentStateRequest) Reset()

func (*UpdateInstalledComponentStateRequest) String 

func (x *UpdateInstalledComponentStateRequest) String() string

type UpdateInstalledComponentStateResponse 

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

func (*UpdateInstalledComponentStateResponse) Descriptor deprecated 

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

Deprecated: Use UpdateInstalledComponentStateResponse.ProtoReflect.Descriptor instead.

func (*UpdateInstalledComponentStateResponse) ProtoMessage 

func (*UpdateInstalledComponentStateResponse) ProtoMessage()

func (*UpdateInstalledComponentStateResponse) ProtoReflect 

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

func (*UpdateInstalledComponentStateResponse) Reset 

func (x *UpdateInstalledComponentStateResponse) Reset()

func (*UpdateInstalledComponentStateResponse) String 

func (x *UpdateInstalledComponentStateResponse) String() string

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.