v0

package
v0.1.109 Latest Latest
Warning

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

 Go to latest Published: May 21, 2024 License: MIT Imports: 22 Imported by: 0

Documentation

Overview

Package v0 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	CLI_Ping_FullMethodName                                     = "/observability.v0.CLI/Ping"
	CLI_GetAgentInformation_FullMethodName                      = "/observability.v0.CLI/GetAgentInformation"
	CLI_GetWorkspaceInventory_FullMethodName                    = "/observability.v0.CLI/GetWorkspaceInventory"
	CLI_GetWorkspaceServiceDependencyGraph_FullMethodName       = "/observability.v0.CLI/GetWorkspaceServiceDependencyGraph"
	CLI_GetWorkspacePublicModulesDependencyGraph_FullMethodName = "/observability.v0.CLI/GetWorkspacePublicModulesDependencyGraph"
	CLI_GetActive_FullMethodName                                = "/observability.v0.CLI/GetActive"
	CLI_GetAddresses_FullMethodName                             = "/observability.v0.CLI/GetAddresses"
	CLI_GetConfiguration_FullMethodName                         = "/observability.v0.CLI/GetConfiguration"
	CLI_GetDependenciesConfigurations_FullMethodName            = "/observability.v0.CLI/GetDependenciesConfigurations"
	CLI_GetRuntimeConfigurations_FullMethodName                 = "/observability.v0.CLI/GetRuntimeConfigurations"
	CLI_Logs_FullMethodName                                     = "/observability.v0.CLI/Logs"
	CLI_ActiveLogHistory_FullMethodName                         = "/observability.v0.CLI/ActiveLogHistory"
	CLI_GetFlowStatus_FullMethodName                            = "/observability.v0.CLI/GetFlowStatus"
	CLI_StopFlow_FullMethodName                                 = "/observability.v0.CLI/StopFlow"
	CLI_DestroyFlow_FullMethodName                              = "/observability.v0.CLI/DestroyFlow"
)

Variables

View Source 
var CLI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "observability.v0.CLI",
	HandlerType: (*CLIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _CLI_Ping_Handler,
		},
		{
			MethodName: "GetAgentInformation",
			Handler:    _CLI_GetAgentInformation_Handler,
		},
		{
			MethodName: "GetWorkspaceInventory",
			Handler:    _CLI_GetWorkspaceInventory_Handler,
		},
		{
			MethodName: "GetWorkspaceServiceDependencyGraph",
			Handler:    _CLI_GetWorkspaceServiceDependencyGraph_Handler,
		},
		{
			MethodName: "GetWorkspacePublicModulesDependencyGraph",
			Handler:    _CLI_GetWorkspacePublicModulesDependencyGraph_Handler,
		},
		{
			MethodName: "GetActive",
			Handler:    _CLI_GetActive_Handler,
		},
		{
			MethodName: "GetAddresses",
			Handler:    _CLI_GetAddresses_Handler,
		},
		{
			MethodName: "GetConfiguration",
			Handler:    _CLI_GetConfiguration_Handler,
		},
		{
			MethodName: "GetDependenciesConfigurations",
			Handler:    _CLI_GetDependenciesConfigurations_Handler,
		},
		{
			MethodName: "GetRuntimeConfigurations",
			Handler:    _CLI_GetRuntimeConfigurations_Handler,
		},
		{
			MethodName: "ActiveLogHistory",
			Handler:    _CLI_ActiveLogHistory_Handler,
		},
		{
			MethodName: "GetFlowStatus",
			Handler:    _CLI_GetFlowStatus_Handler,
		},
		{
			MethodName: "StopFlow",
			Handler:    _CLI_StopFlow_Handler,
		},
		{
			MethodName: "DestroyFlow",
			Handler:    _CLI_DestroyFlow_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Logs",
			Handler:       _CLI_Logs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "cli/v0/cli.proto",
}

CLI_ServiceDesc is the grpc.ServiceDesc for CLI 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_cli_v0_cli_proto protoreflect.FileDescriptor

Functions

func RegisterCLIHandler 

func RegisterCLIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterCLIHandler registers the http handlers for service CLI to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterCLIHandlerClient 

func RegisterCLIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client CLIClient) error

RegisterCLIHandlerClient registers the http handlers for service CLI to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "CLIClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "CLIClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "CLIClient" to call the correct interceptors.

func RegisterCLIHandlerFromEndpoint 

func RegisterCLIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterCLIHandlerFromEndpoint is same as RegisterCLIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterCLIHandlerServer 

func RegisterCLIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server CLIServer) error

RegisterCLIHandlerServer registers the http handlers for service CLI to "mux". UnaryRPC :call CLIServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterCLIHandlerFromEndpoint instead.

func RegisterCLIServer 

func RegisterCLIServer(s grpc.ServiceRegistrar, srv CLIServer)

Types

type ActiveResponse 

type ActiveResponse struct {
	Workspace string `protobuf:"bytes,1,opt,name=workspace,proto3" json:"workspace,omitempty"`
	Module    string `protobuf:"bytes,2,opt,name=module,proto3" json:"module,omitempty"`
	Service   string `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func (*ActiveResponse) Descriptor deprecated 

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

Deprecated: Use ActiveResponse.ProtoReflect.Descriptor instead.

func (*ActiveResponse) GetModule added in v0.1.89 

func (x *ActiveResponse) GetModule() string

func (*ActiveResponse) GetService 

func (x *ActiveResponse) GetService() string

func (*ActiveResponse) GetWorkspace added in v0.1.89 

func (x *ActiveResponse) GetWorkspace() string

func (*ActiveResponse) ProtoMessage 

func (*ActiveResponse) ProtoMessage()

func (*ActiveResponse) ProtoReflect 

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

func (*ActiveResponse) Reset 

func (x *ActiveResponse) Reset()

func (*ActiveResponse) String 

func (x *ActiveResponse) String() string

type CLIClient 

type CLIClient interface {
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetAgentInformation(ctx context.Context, in *GetAgentInformationRequest, opts ...grpc.CallOption) (*v0.AgentInformation, error)
	GetWorkspaceInventory(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*v01.Workspace, error)
	GetWorkspaceServiceDependencyGraph(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*v02.GraphResponse, error)
	GetWorkspacePublicModulesDependencyGraph(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*MultiGraphResponse, error)
	GetActive(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ActiveResponse, error)
	GetAddresses(ctx context.Context, in *GetAddressRequest, opts ...grpc.CallOption) (*GetAddressResponse, error)
	GetConfiguration(ctx context.Context, in *GetConfigurationRequest, opts ...grpc.CallOption) (*GetConfigurationResponse, error)
	GetDependenciesConfigurations(ctx context.Context, in *GetConfigurationRequest, opts ...grpc.CallOption) (*GetConfigurationsResponse, error)
	GetRuntimeConfigurations(ctx context.Context, in *GetConfigurationRequest, opts ...grpc.CallOption) (*GetConfigurationsResponse, error)
	Logs(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (CLI_LogsClient, error)
	ActiveLogHistory(ctx context.Context, in *v02.LogRequest, opts ...grpc.CallOption) (*v02.LogResponse, error)
	GetFlowStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*FlowStatus, error)
	StopFlow(ctx context.Context, in *StopFlowRequest, opts ...grpc.CallOption) (*StopFlowResponse, error)
	DestroyFlow(ctx context.Context, in *DestroyFlowRequest, opts ...grpc.CallOption) (*DestroyFlowResponse, error)
}

CLIClient is the client API for CLI 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 NewCLIClient 

func NewCLIClient(cc grpc.ClientConnInterface) CLIClient

type CLIServer 

type CLIServer interface {
	Ping(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	GetAgentInformation(context.Context, *GetAgentInformationRequest) (*v0.AgentInformation, error)
	GetWorkspaceInventory(context.Context, *emptypb.Empty) (*v01.Workspace, error)
	GetWorkspaceServiceDependencyGraph(context.Context, *emptypb.Empty) (*v02.GraphResponse, error)
	GetWorkspacePublicModulesDependencyGraph(context.Context, *emptypb.Empty) (*MultiGraphResponse, error)
	GetActive(context.Context, *emptypb.Empty) (*ActiveResponse, error)
	GetAddresses(context.Context, *GetAddressRequest) (*GetAddressResponse, error)
	GetConfiguration(context.Context, *GetConfigurationRequest) (*GetConfigurationResponse, error)
	GetDependenciesConfigurations(context.Context, *GetConfigurationRequest) (*GetConfigurationsResponse, error)
	GetRuntimeConfigurations(context.Context, *GetConfigurationRequest) (*GetConfigurationsResponse, error)
	Logs(*emptypb.Empty, CLI_LogsServer) error
	ActiveLogHistory(context.Context, *v02.LogRequest) (*v02.LogResponse, error)
	GetFlowStatus(context.Context, *emptypb.Empty) (*FlowStatus, error)
	StopFlow(context.Context, *StopFlowRequest) (*StopFlowResponse, error)
	DestroyFlow(context.Context, *DestroyFlowRequest) (*DestroyFlowResponse, error)
	// contains filtered or unexported methods
}

CLIServer is the server API for CLI service. All implementations must embed UnimplementedCLIServer for forward compatibility

type CLI_LogsClient 

type CLI_LogsClient interface {
	Recv() (*v02.Log, error)
	grpc.ClientStream
}

type CLI_LogsServer 

type CLI_LogsServer interface {
	Send(*v02.Log) error
	grpc.ServerStream
}

type DestroyFlowRequest added in v0.1.89 

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

func (*DestroyFlowRequest) Descriptor deprecated added in v0.1.89 

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

Deprecated: Use DestroyFlowRequest.ProtoReflect.Descriptor instead.

func (*DestroyFlowRequest) ProtoMessage added in v0.1.89 

func (*DestroyFlowRequest) ProtoMessage()

func (*DestroyFlowRequest) ProtoReflect added in v0.1.89 

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

func (*DestroyFlowRequest) Reset added in v0.1.89 

func (x *DestroyFlowRequest) Reset()

func (*DestroyFlowRequest) String added in v0.1.89 

func (x *DestroyFlowRequest) String() string

type DestroyFlowResponse added in v0.1.89 

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

func (*DestroyFlowResponse) Descriptor deprecated added in v0.1.89 

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

Deprecated: Use DestroyFlowResponse.ProtoReflect.Descriptor instead.

func (*DestroyFlowResponse) ProtoMessage added in v0.1.89 

func (*DestroyFlowResponse) ProtoMessage()

func (*DestroyFlowResponse) ProtoReflect added in v0.1.89 

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

func (*DestroyFlowResponse) Reset added in v0.1.89 

func (x *DestroyFlowResponse) Reset()

func (*DestroyFlowResponse) String added in v0.1.89 

func (x *DestroyFlowResponse) String() string

type FlowStatus 

type FlowStatus struct {
	Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowStatus) Descriptor deprecated 

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

Deprecated: Use FlowStatus.ProtoReflect.Descriptor instead.

func (*FlowStatus) GetReady 

func (x *FlowStatus) GetReady() bool

func (*FlowStatus) ProtoMessage 

func (*FlowStatus) ProtoMessage()

func (*FlowStatus) ProtoReflect 

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

func (*FlowStatus) Reset 

func (x *FlowStatus) Reset()

func (*FlowStatus) String 

func (x *FlowStatus) String() string

type GetAddressRequest 

type GetAddressRequest struct {
	Module   string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	Service  string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Endpoint string `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAddressRequest) Descriptor deprecated 

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

Deprecated: Use GetAddressRequest.ProtoReflect.Descriptor instead.

func (*GetAddressRequest) GetEndpoint 

func (x *GetAddressRequest) GetEndpoint() string

func (*GetAddressRequest) GetModule added in v0.1.89 

func (x *GetAddressRequest) GetModule() string

func (*GetAddressRequest) GetService 

func (x *GetAddressRequest) GetService() string

func (*GetAddressRequest) ProtoMessage 

func (*GetAddressRequest) ProtoMessage()

func (*GetAddressRequest) ProtoReflect 

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

func (*GetAddressRequest) Reset 

func (x *GetAddressRequest) Reset()

func (*GetAddressRequest) String 

func (x *GetAddressRequest) String() string

type GetAddressResponse 

type GetAddressResponse struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAddressResponse) Descriptor deprecated 

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

Deprecated: Use GetAddressResponse.ProtoReflect.Descriptor instead.

func (*GetAddressResponse) GetAddress 

func (x *GetAddressResponse) GetAddress() string

func (*GetAddressResponse) ProtoMessage 

func (*GetAddressResponse) ProtoMessage()

func (*GetAddressResponse) ProtoReflect 

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

func (*GetAddressResponse) Reset 

func (x *GetAddressResponse) Reset()

func (*GetAddressResponse) String 

func (x *GetAddressResponse) String() string

type GetAgentInformationRequest 

type GetAgentInformationRequest struct {
	Agent string `protobuf:"bytes,1,opt,name=agent,proto3" json:"agent,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAgentInformationRequest) Descriptor deprecated 

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

Deprecated: Use GetAgentInformationRequest.ProtoReflect.Descriptor instead.

func (*GetAgentInformationRequest) GetAgent 

func (x *GetAgentInformationRequest) GetAgent() string

func (*GetAgentInformationRequest) ProtoMessage 

func (*GetAgentInformationRequest) ProtoMessage()

func (*GetAgentInformationRequest) ProtoReflect 

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

func (*GetAgentInformationRequest) Reset 

func (x *GetAgentInformationRequest) Reset()

func (*GetAgentInformationRequest) String 

func (x *GetAgentInformationRequest) String() string

type GetConfigurationRequest added in v0.1.62 

type GetConfigurationRequest struct {
	Module  string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConfigurationRequest) Descriptor deprecated added in v0.1.62 

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

Deprecated: Use GetConfigurationRequest.ProtoReflect.Descriptor instead.

func (*GetConfigurationRequest) GetModule added in v0.1.89 

func (x *GetConfigurationRequest) GetModule() string

func (*GetConfigurationRequest) GetService added in v0.1.62 

func (x *GetConfigurationRequest) GetService() string

func (*GetConfigurationRequest) ProtoMessage added in v0.1.62 

func (*GetConfigurationRequest) ProtoMessage()

func (*GetConfigurationRequest) ProtoReflect added in v0.1.62 

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

func (*GetConfigurationRequest) Reset added in v0.1.62 

func (x *GetConfigurationRequest) Reset()

func (*GetConfigurationRequest) String added in v0.1.62 

func (x *GetConfigurationRequest) String() string

type GetConfigurationResponse added in v0.1.62 

type GetConfigurationResponse struct {
	Configuration *v01.Configuration `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConfigurationResponse) Descriptor deprecated added in v0.1.62 

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

Deprecated: Use GetConfigurationResponse.ProtoReflect.Descriptor instead.

func (*GetConfigurationResponse) GetConfiguration added in v0.1.89 

func (x *GetConfigurationResponse) GetConfiguration() *v01.Configuration

func (*GetConfigurationResponse) ProtoMessage added in v0.1.62 

func (*GetConfigurationResponse) ProtoMessage()

func (*GetConfigurationResponse) ProtoReflect added in v0.1.62 

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

func (*GetConfigurationResponse) Reset added in v0.1.62 

func (x *GetConfigurationResponse) Reset()

func (*GetConfigurationResponse) String added in v0.1.62 

func (x *GetConfigurationResponse) String() string

type GetConfigurationsResponse added in v0.1.89 

type GetConfigurationsResponse struct {
	Configurations []*v01.Configuration `protobuf:"bytes,1,rep,name=configurations,proto3" json:"configurations,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConfigurationsResponse) Descriptor deprecated added in v0.1.89 

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

Deprecated: Use GetConfigurationsResponse.ProtoReflect.Descriptor instead.

func (*GetConfigurationsResponse) GetConfigurations added in v0.1.89 

func (x *GetConfigurationsResponse) GetConfigurations() []*v01.Configuration

func (*GetConfigurationsResponse) ProtoMessage added in v0.1.89 

func (*GetConfigurationsResponse) ProtoMessage()

func (*GetConfigurationsResponse) ProtoReflect added in v0.1.89 

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

func (*GetConfigurationsResponse) Reset added in v0.1.89 

func (x *GetConfigurationsResponse) Reset()

func (*GetConfigurationsResponse) String added in v0.1.89 

func (x *GetConfigurationsResponse) String() string

type MultiGraphResponse 

type MultiGraphResponse struct {
	Graphs []*v0.GraphResponse `protobuf:"bytes,1,rep,name=graphs,proto3" json:"graphs,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiGraphResponse) Descriptor deprecated 

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

Deprecated: Use MultiGraphResponse.ProtoReflect.Descriptor instead.

func (*MultiGraphResponse) GetGraphs 

func (x *MultiGraphResponse) GetGraphs() []*v0.GraphResponse

func (*MultiGraphResponse) ProtoMessage 

func (*MultiGraphResponse) ProtoMessage()

func (*MultiGraphResponse) ProtoReflect 

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

func (*MultiGraphResponse) Reset 

func (x *MultiGraphResponse) Reset()

func (*MultiGraphResponse) String 

func (x *MultiGraphResponse) String() string

type RunningInformation 

type RunningInformation struct {
	Module   string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	Service  string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	AgentPid int32  `protobuf:"varint,3,opt,name=agent_pid,json=agentPid,proto3" json:"agent_pid,omitempty"`
	// contains filtered or unexported fields
}

func (*RunningInformation) Descriptor deprecated 

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

Deprecated: Use RunningInformation.ProtoReflect.Descriptor instead.

func (*RunningInformation) GetAgentPid 

func (x *RunningInformation) GetAgentPid() int32

func (*RunningInformation) GetModule added in v0.1.89 

func (x *RunningInformation) GetModule() string

func (*RunningInformation) GetService 

func (x *RunningInformation) GetService() string

func (*RunningInformation) ProtoMessage 

func (*RunningInformation) ProtoMessage()

func (*RunningInformation) ProtoReflect 

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

func (*RunningInformation) Reset 

func (x *RunningInformation) Reset()

func (*RunningInformation) String 

func (x *RunningInformation) String() string

type StopFlowRequest added in v0.1.89 

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

func (*StopFlowRequest) Descriptor deprecated added in v0.1.89 

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

Deprecated: Use StopFlowRequest.ProtoReflect.Descriptor instead.

func (*StopFlowRequest) ProtoMessage added in v0.1.89 

func (*StopFlowRequest) ProtoMessage()

func (*StopFlowRequest) ProtoReflect added in v0.1.89 

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

func (*StopFlowRequest) Reset added in v0.1.89 

func (x *StopFlowRequest) Reset()

func (*StopFlowRequest) String added in v0.1.89 

func (x *StopFlowRequest) String() string

type StopFlowResponse added in v0.1.89 

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

func (*StopFlowResponse) Descriptor deprecated added in v0.1.89 

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

Deprecated: Use StopFlowResponse.ProtoReflect.Descriptor instead.

func (*StopFlowResponse) ProtoMessage added in v0.1.89 

func (*StopFlowResponse) ProtoMessage()

func (*StopFlowResponse) ProtoReflect added in v0.1.89 

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

func (*StopFlowResponse) Reset added in v0.1.89 

func (x *StopFlowResponse) Reset()

func (*StopFlowResponse) String added in v0.1.89 

func (x *StopFlowResponse) String() string

type UnimplementedCLIServer 

type UnimplementedCLIServer struct {
}

UnimplementedCLIServer must be embedded to have forward compatible implementations.

func (UnimplementedCLIServer) ActiveLogHistory 

func (UnimplementedCLIServer) ActiveLogHistory(context.Context, *v02.LogRequest) (*v02.LogResponse, error)

func (UnimplementedCLIServer) DestroyFlow added in v0.1.89 

func (UnimplementedCLIServer) DestroyFlow(context.Context, *DestroyFlowRequest) (*DestroyFlowResponse, error)

func (UnimplementedCLIServer) GetActive 

func (UnimplementedCLIServer) GetActive(context.Context, *emptypb.Empty) (*ActiveResponse, error)

func (UnimplementedCLIServer) GetAddresses 

func (UnimplementedCLIServer) GetAddresses(context.Context, *GetAddressRequest) (*GetAddressResponse, error)

func (UnimplementedCLIServer) GetAgentInformation 

func (UnimplementedCLIServer) GetAgentInformation(context.Context, *GetAgentInformationRequest) (*v0.AgentInformation, error)

func (UnimplementedCLIServer) GetConfiguration added in v0.1.89 

func (UnimplementedCLIServer) GetConfiguration(context.Context, *GetConfigurationRequest) (*GetConfigurationResponse, error)

func (UnimplementedCLIServer) GetDependenciesConfigurations added in v0.1.89 

func (UnimplementedCLIServer) GetDependenciesConfigurations(context.Context, *GetConfigurationRequest) (*GetConfigurationsResponse, error)

func (UnimplementedCLIServer) GetFlowStatus 

func (UnimplementedCLIServer) GetFlowStatus(context.Context, *emptypb.Empty) (*FlowStatus, error)

func (UnimplementedCLIServer) GetRuntimeConfigurations added in v0.1.89 

func (UnimplementedCLIServer) GetRuntimeConfigurations(context.Context, *GetConfigurationRequest) (*GetConfigurationsResponse, error)

func (UnimplementedCLIServer) GetWorkspaceInventory added in v0.1.89 

func (UnimplementedCLIServer) GetWorkspaceInventory(context.Context, *emptypb.Empty) (*v01.Workspace, error)

func (UnimplementedCLIServer) GetWorkspacePublicModulesDependencyGraph added in v0.1.89 

func (UnimplementedCLIServer) GetWorkspacePublicModulesDependencyGraph(context.Context, *emptypb.Empty) (*MultiGraphResponse, error)

func (UnimplementedCLIServer) GetWorkspaceServiceDependencyGraph added in v0.1.89 

func (UnimplementedCLIServer) GetWorkspaceServiceDependencyGraph(context.Context, *emptypb.Empty) (*v02.GraphResponse, error)

func (UnimplementedCLIServer) Logs 

func (UnimplementedCLIServer) Logs(*emptypb.Empty, CLI_LogsServer) error

func (UnimplementedCLIServer) Ping 

func (UnimplementedCLIServer) Ping(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedCLIServer) StopFlow 

func (UnimplementedCLIServer) StopFlow(context.Context, *StopFlowRequest) (*StopFlowResponse, error)

type UnsafeCLIServer 

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

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