proto

package
v0.22.2 Latest Latest
Warning

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

Go to latest
Published: Apr 5, 2024 License: AGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const (
	PluginManager_Get_FullMethodName                = "/proto.PluginManager/Get"
	PluginManager_RefreshConnections_FullMethodName = "/proto.PluginManager/RefreshConnections"
	PluginManager_Shutdown_FullMethodName           = "/proto.PluginManager/Shutdown"
)

Variables

View Source
var File_plugin_manager_proto protoreflect.FileDescriptor
View Source
var PluginManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.PluginManager",
	HandlerType: (*PluginManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _PluginManager_Get_Handler,
		},
		{
			MethodName: "RefreshConnections",
			Handler:    _PluginManager_RefreshConnections_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _PluginManager_Shutdown_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "plugin_manager.proto",
}

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

Functions

func RegisterPluginManagerServer

func RegisterPluginManagerServer(s grpc.ServiceRegistrar, srv PluginManagerServer)

Types

type GetRequest

type GetRequest struct {
	Connections []string `protobuf:"bytes,1,rep,name=connections,proto3" json:"connections,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetConnections

func (x *GetRequest) GetConnections() []string

func (*GetRequest) ProtoMessage

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect

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

func (*GetRequest) Reset

func (x *GetRequest) Reset()

func (*GetRequest) String

func (x *GetRequest) String() string

type GetResponse

type GetResponse struct {
	ReattachMap map[string]*ReattachConfig `` /* 182-byte string literal not displayed */
	FailureMap  map[string]string          `` /* 179-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetFailureMap

func (x *GetResponse) GetFailureMap() map[string]string

func (*GetResponse) GetReattachMap

func (x *GetResponse) GetReattachMap() map[string]*ReattachConfig

func (*GetResponse) ProtoMessage

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect

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

func (*GetResponse) Reset

func (x *GetResponse) Reset()

func (*GetResponse) String

func (x *GetResponse) String() string

type NetAddr

type NetAddr struct {
	Network string `protobuf:"bytes,1,opt,name=Network,proto3" json:"Network,omitempty"` // name of the network (for example, "tcp", "udp")
	Address string `protobuf:"bytes,2,opt,name=Address,proto3" json:"Address,omitempty"` // string form of address (for example, "192.0.2.1:25", "[2001:db8::1]:80")
	// contains filtered or unexported fields
}

func (*NetAddr) Descriptor deprecated

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

Deprecated: Use NetAddr.ProtoReflect.Descriptor instead.

func (*NetAddr) GetAddress

func (x *NetAddr) GetAddress() string

func (*NetAddr) GetNetwork

func (x *NetAddr) GetNetwork() string

func (*NetAddr) ProtoMessage

func (*NetAddr) ProtoMessage()

func (*NetAddr) ProtoReflect

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

func (*NetAddr) Reset

func (x *NetAddr) Reset()

func (*NetAddr) String

func (x *NetAddr) String() string

type PluginManagerClient

type PluginManagerClient interface {
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	RefreshConnections(ctx context.Context, in *RefreshConnectionsRequest, opts ...grpc.CallOption) (*RefreshConnectionsResponse, error)
	Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error)
}

PluginManagerClient is the client API for PluginManager 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 PluginManagerServer

type PluginManagerServer interface {
	Get(context.Context, *GetRequest) (*GetResponse, error)
	RefreshConnections(context.Context, *RefreshConnectionsRequest) (*RefreshConnectionsResponse, error)
	Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)
	// contains filtered or unexported methods
}

PluginManagerServer is the server API for PluginManager service. All implementations must embed UnimplementedPluginManagerServer for forward compatibility

type ReattachConfig

type ReattachConfig struct {
	Protocol            string               `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"`
	ProtocolVersion     int64                `protobuf:"varint,2,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	Addr                *NetAddr             `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
	Pid                 int64                `protobuf:"varint,4,opt,name=pid,proto3" json:"pid,omitempty"`
	SupportedOperations *SupportedOperations `protobuf:"bytes,5,opt,name=supported_operations,json=supportedOperations,proto3" json:"supported_operations,omitempty"`
	Connections         []string             `protobuf:"bytes,6,rep,name=connections,proto3" json:"connections,omitempty"`
	Plugin              string               `protobuf:"bytes,7,opt,name=plugin,proto3" json:"plugin,omitempty"`
	// contains filtered or unexported fields
}

func NewReattachConfig

func NewReattachConfig(pluginName string, src *plugin.ReattachConfig, supportedOperations *SupportedOperations, connections []string) *ReattachConfig

func (*ReattachConfig) AddConnection

func (r *ReattachConfig) AddConnection(connection string)

func (*ReattachConfig) Convert

func (r *ReattachConfig) Convert() *plugin.ReattachConfig

Convert converts from a protobuf reattach config to a plugin.ReattachConfig

func (*ReattachConfig) Descriptor deprecated

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

Deprecated: Use ReattachConfig.ProtoReflect.Descriptor instead.

func (*ReattachConfig) GetAddr

func (x *ReattachConfig) GetAddr() *NetAddr

func (*ReattachConfig) GetConnections

func (x *ReattachConfig) GetConnections() []string

func (*ReattachConfig) GetPid

func (x *ReattachConfig) GetPid() int64

func (*ReattachConfig) GetPlugin

func (x *ReattachConfig) GetPlugin() string

func (*ReattachConfig) GetProtocol

func (x *ReattachConfig) GetProtocol() string

func (*ReattachConfig) GetProtocolVersion

func (x *ReattachConfig) GetProtocolVersion() int64

func (*ReattachConfig) GetSupportedOperations

func (x *ReattachConfig) GetSupportedOperations() *SupportedOperations

func (*ReattachConfig) ProtoMessage

func (*ReattachConfig) ProtoMessage()

func (*ReattachConfig) ProtoReflect

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

func (*ReattachConfig) RemoveConnection

func (r *ReattachConfig) RemoveConnection(connection string)

func (*ReattachConfig) Reset

func (x *ReattachConfig) Reset()

func (*ReattachConfig) String

func (x *ReattachConfig) String() string

func (*ReattachConfig) UpdateConnections added in v0.21.0

func (r *ReattachConfig) UpdateConnections(configs []*proto.ConnectionConfig)

type RefreshConnectionsRequest

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

func (*RefreshConnectionsRequest) Descriptor deprecated

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

Deprecated: Use RefreshConnectionsRequest.ProtoReflect.Descriptor instead.

func (*RefreshConnectionsRequest) ProtoMessage

func (*RefreshConnectionsRequest) ProtoMessage()

func (*RefreshConnectionsRequest) ProtoReflect

func (*RefreshConnectionsRequest) Reset

func (x *RefreshConnectionsRequest) Reset()

func (*RefreshConnectionsRequest) String

func (x *RefreshConnectionsRequest) String() string

type RefreshConnectionsResponse

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

func (*RefreshConnectionsResponse) Descriptor deprecated

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

Deprecated: Use RefreshConnectionsResponse.ProtoReflect.Descriptor instead.

func (*RefreshConnectionsResponse) ProtoMessage

func (*RefreshConnectionsResponse) ProtoMessage()

func (*RefreshConnectionsResponse) ProtoReflect

func (*RefreshConnectionsResponse) Reset

func (x *RefreshConnectionsResponse) Reset()

func (*RefreshConnectionsResponse) String

func (x *RefreshConnectionsResponse) String() string

type ShutdownRequest

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

func (*ShutdownRequest) Descriptor deprecated

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

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

func (*ShutdownRequest) ProtoMessage

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) ProtoReflect

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

func (*ShutdownRequest) Reset

func (x *ShutdownRequest) Reset()

func (*ShutdownRequest) String

func (x *ShutdownRequest) String() string

type ShutdownResponse

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

func (*ShutdownResponse) Descriptor deprecated

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

Deprecated: Use ShutdownResponse.ProtoReflect.Descriptor instead.

func (*ShutdownResponse) ProtoMessage

func (*ShutdownResponse) ProtoMessage()

func (*ShutdownResponse) ProtoReflect

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

func (*ShutdownResponse) Reset

func (x *ShutdownResponse) Reset()

func (*ShutdownResponse) String

func (x *ShutdownResponse) String() string

type SimpleAddr

type SimpleAddr struct {
	NetworkString string `json:"network"`
	AddressString string `json:"string"`
}

func NewSimpleAddr

func NewSimpleAddr(addr net.Addr) *SimpleAddr

func (SimpleAddr) Network

func (s SimpleAddr) Network() string

func (SimpleAddr) String

func (s SimpleAddr) String() string

type SupportedOperations

type SupportedOperations struct {
	QueryCache          bool `protobuf:"varint,1,opt,name=query_cache,json=queryCache,proto3" json:"query_cache,omitempty"`
	MultipleConnections bool `protobuf:"varint,2,opt,name=multiple_connections,json=multipleConnections,proto3" json:"multiple_connections,omitempty"`
	MessageStream       bool `protobuf:"varint,3,opt,name=message_stream,json=messageStream,proto3" json:"message_stream,omitempty"`
	SetCacheOptions     bool `protobuf:"varint,4,opt,name=set_cache_options,json=setCacheOptions,proto3" json:"set_cache_options,omitempty"`
	RateLimiters        bool `protobuf:"varint,5,opt,name=rate_limiters,json=rateLimiters,proto3" json:"rate_limiters,omitempty"`
	// contains filtered or unexported fields
}

NOTE: this must be consistent with GetSupportedOperationsResponse in steampipe-plugin-sdk/grpc/proto/plugin.proto

func (*SupportedOperations) Descriptor deprecated

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

Deprecated: Use SupportedOperations.ProtoReflect.Descriptor instead.

func (*SupportedOperations) GetMessageStream

func (x *SupportedOperations) GetMessageStream() bool

func (*SupportedOperations) GetMultipleConnections

func (x *SupportedOperations) GetMultipleConnections() bool

func (*SupportedOperations) GetQueryCache

func (x *SupportedOperations) GetQueryCache() bool

func (*SupportedOperations) GetRateLimiters added in v0.21.0

func (x *SupportedOperations) GetRateLimiters() bool

func (*SupportedOperations) GetSetCacheOptions added in v0.21.0

func (x *SupportedOperations) GetSetCacheOptions() bool

func (*SupportedOperations) ProtoMessage

func (*SupportedOperations) ProtoMessage()

func (*SupportedOperations) ProtoReflect

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

func (*SupportedOperations) Reset

func (x *SupportedOperations) Reset()

func (*SupportedOperations) String

func (x *SupportedOperations) String() string

type UnimplementedPluginManagerServer

type UnimplementedPluginManagerServer struct {
}

UnimplementedPluginManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedPluginManagerServer) Get

func (UnimplementedPluginManagerServer) RefreshConnections

func (UnimplementedPluginManagerServer) Shutdown

type UnsafePluginManagerServer

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

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

Jump to

Keyboard shortcuts

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