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 (*GetInstalledComponentRequest) Reset

func (x *GetInstalledComponentRequest) Reset()

func (*GetInstalledComponentRequest) 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 (*GetInstalledComponentResponse) Reset

func (x *GetInstalledComponentResponse) Reset()

func (*GetInstalledComponentResponse) 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 (*InstalledComponentInstance) GetStates

func (*InstalledComponentInstance) ProtoMessage

func (*InstalledComponentInstance) ProtoMessage()

func (*InstalledComponentInstance) ProtoReflect

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 (*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) Enum

func (InstalledComponentStateType) EnumDescriptor deprecated

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

Deprecated: Use InstalledComponentStateType.Descriptor instead.

func (InstalledComponentStateType) Number

func (InstalledComponentStateType) String

func (InstalledComponentStateType) Type

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) Enum

func (InstalledComponentType) EnumDescriptor deprecated

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

Deprecated: Use InstalledComponentType.Descriptor instead.

func (InstalledComponentType) Number

func (InstalledComponentType) String

func (x InstalledComponentType) String() string

func (InstalledComponentType) Type

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.

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 (*ListInstalledComponentsRequest) Reset

func (x *ListInstalledComponentsRequest) Reset()

func (*ListInstalledComponentsRequest) 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 (*ListInstalledComponentsResponse) Reset

func (*ListInstalledComponentsResponse) String

type UnimplementedInstalledComponentsServiceServer

type UnimplementedInstalledComponentsServiceServer struct {
}

UnimplementedInstalledComponentsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedInstalledComponentsServiceServer) GetInstalledComponent

func (UnimplementedInstalledComponentsServiceServer) ListInstalledComponents

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 (*UpdateInstalledComponentStateRequest) Reset

func (*UpdateInstalledComponentStateRequest) 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 (*UpdateInstalledComponentStateResponse) Reset

func (*UpdateInstalledComponentStateResponse) String

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL