pluginv1

type ActingUser struct {
	Id          string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Username    string   `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	DisplayName string   `protobuf:"bytes,3,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	Roles       []string `protobuf:"bytes,4,rep,name=roles,proto3" json:"roles,omitempty"`
	// contains filtered or unexported fields
}

type AuditRecord struct {
	SessionId string            `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Result    string            `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // "allowed" | "denied" | "error"
	Params    map[string]string ``                                                                  /* 139-byte string literal not displayed */
	Error     string            `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type BrokerRef struct {
	BrokerId uint32 `protobuf:"varint,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// contains filtered or unexported fields
}

type ChannelInfo struct {
	BrokerId   uint32 `protobuf:"varint,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	ChannelId  string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // handle for control RPCs (resize)
	Resizable  bool   `protobuf:"varint,3,opt,name=resizable,proto3" json:"resizable,omitempty"`
	ServerInit []byte `protobuf:"bytes,4,opt,name=server_init,json=serverInit,proto3" json:"server_init,omitempty"` // present iff the channel exposes a desktop init blob
	// contains filtered or unexported fields
}

type ChannelRequest struct {
	SessionId string            `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Kind      string            `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
	Params    map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ChannelResize struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	Cols      int32  `protobuf:"varint,3,opt,name=cols,proto3" json:"cols,omitempty"`
	Rows      int32  `protobuf:"varint,4,opt,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

type Chunk struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type ConnClient interface {
	Pipe(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[Chunk, Chunk], error)
}

type ConnServer interface {
	Pipe(grpc.BidiStreamingServer[Chunk, Chunk]) error
	// contains filtered or unexported methods
}

type Conn_PipeClient = grpc.BidiStreamingClient[Chunk, Chunk]

type Conn_PipeServer = grpc.BidiStreamingServer[Chunk, Chunk]

type ConnectRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	Transport    string `protobuf:"bytes,2,opt,name=transport,proto3" json:"transport,omitempty"`                              // "direct" | "agent"
	ConfigJson   []byte `protobuf:"bytes,3,opt,name=config_json,json=configJson,proto3" json:"config_json,omitempty"`          // decrypted config map, JSON-encoded
	HostBrokerId uint32 `protobuf:"varint,4,opt,name=host_broker_id,json=hostBrokerId,proto3" json:"host_broker_id,omitempty"` // brokered id of the per-connection Host service (0 = none)
	UserId       string `protobuf:"bytes,5,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	ActorScope   string `protobuf:"bytes,6,opt,name=actor_scope,json=actorScope,proto3" json:"actor_scope,omitempty"`
	// contains filtered or unexported fields
}

type DialRequest struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Network   string `protobuf:"bytes,2,opt,name=network,proto3" json:"network,omitempty"` // "tcp" | "unix"
	Address   string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

type DownloadResponse struct {
	Name            string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Mime            string `protobuf:"bytes,2,opt,name=mime,proto3" json:"mime,omitempty"`
	Size            int64  `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	ModTimeUnixNano int64  `protobuf:"varint,4,opt,name=mod_time_unix_nano,json=modTimeUnixNano,proto3" json:"mod_time_unix_nano,omitempty"`
	Inline          bool   `protobuf:"varint,5,opt,name=inline,proto3" json:"inline,omitempty"`
	Body            []byte `protobuf:"bytes,6,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

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

type HostClient interface {
	// DialTarget dials a target through the connection's transport (direct or the
	// agent tunnel) and returns a raw brokered conn (L4 egress).
	DialTarget(ctx context.Context, in *DialRequest, opts ...grpc.CallOption) (*BrokerRef, error)
	// HTTPProxyEndpoint returns the base URL the plugin's http.Client targets for
	// L7 egress (set only when the connection has an L7 transport).
	HTTPProxyEndpoint(ctx context.Context, in *SessionHandle, opts ...grpc.CallOption) (*ProxyEndpoint, error)
	// OpenHTTPConn brokers one connection to the core's L7 reverse proxy; the
	// plugin's http.Transport dials it per HTTP connection.
	OpenHTTPConn(ctx context.Context, in *SessionHandle, opts ...grpc.CallOption) (*BrokerRef, error)
	// Audit records one stream-internal operation against the core audit log.
	Audit(ctx context.Context, in *AuditRecord, opts ...grpc.CallOption) (*Empty, error)
	// Storage persists plugin-owned platform objects through the core.
	StorageGet(ctx context.Context, in *StorageGetRequest, opts ...grpc.CallOption) (*StorageItem, error)
	StoragePut(ctx context.Context, in *StoragePutRequest, opts ...grpc.CallOption) (*StorageItem, error)
	StorageDelete(ctx context.Context, in *StorageDeleteRequest, opts ...grpc.CallOption) (*Empty, error)
	StorageList(ctx context.Context, in *StorageListRequest, opts ...grpc.CallOption) (*StorageListResponse, error)
}

type HostServer interface {
	// DialTarget dials a target through the connection's transport (direct or the
	// agent tunnel) and returns a raw brokered conn (L4 egress).
	DialTarget(context.Context, *DialRequest) (*BrokerRef, error)
	// HTTPProxyEndpoint returns the base URL the plugin's http.Client targets for
	// L7 egress (set only when the connection has an L7 transport).
	HTTPProxyEndpoint(context.Context, *SessionHandle) (*ProxyEndpoint, error)
	// OpenHTTPConn brokers one connection to the core's L7 reverse proxy; the
	// plugin's http.Transport dials it per HTTP connection.
	OpenHTTPConn(context.Context, *SessionHandle) (*BrokerRef, error)
	// Audit records one stream-internal operation against the core audit log.
	Audit(context.Context, *AuditRecord) (*Empty, error)
	// Storage persists plugin-owned platform objects through the core.
	StorageGet(context.Context, *StorageGetRequest) (*StorageItem, error)
	StoragePut(context.Context, *StoragePutRequest) (*StorageItem, error)
	StorageDelete(context.Context, *StorageDeleteRequest) (*Empty, error)
	StorageList(context.Context, *StorageListRequest) (*StorageListResponse, error)
	// contains filtered or unexported methods
}

type InvokeRequest struct {
	SessionId   string            `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	RouteId     string            `protobuf:"bytes,2,opt,name=route_id,json=routeId,proto3" json:"route_id,omitempty"` // stable handle; the core owns permission/risk/audit
	Params      map[string]string ``                                                                                   /* 139-byte string literal not displayed */
	Query       map[string]string ``                                                                                   /* 137-byte string literal not displayed */
	Body        []byte            `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	User        *ActingUser       `protobuf:"bytes,6,opt,name=user,proto3" json:"user,omitempty"`
	ProxyPrefix string            `protobuf:"bytes,7,opt,name=proxy_prefix,json=proxyPrefix,proto3" json:"proxy_prefix,omitempty"` // the connection's public proxy mount
	// contains filtered or unexported fields
}

type InvokeResponse struct {
	ResultJson []byte            `protobuf:"bytes,1,opt,name=result_json,json=resultJson,proto3" json:"result_json,omitempty"`
	Download   *DownloadResponse `protobuf:"bytes,2,opt,name=download,proto3" json:"download,omitempty"`
	// contains filtered or unexported fields
}

type Manifest struct {
	Json []byte `protobuf:"bytes,1,opt,name=json,proto3" json:"json,omitempty"`
	// contains filtered or unexported fields
}

type PluginClient interface {
	GetManifest(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Manifest, error)
	Connect(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*SessionHandle, error)
	HealthCheck(ctx context.Context, in *SessionHandle, opts ...grpc.CallOption) (*Empty, error)
	Close(ctx context.Context, in *SessionHandle, opts ...grpc.CallOption) (*Empty, error)
	// Invoke runs one non-streaming route; result_json is the handler's value.
	Invoke(ctx context.Context, in *InvokeRequest, opts ...grpc.CallOption) (*InvokeResponse, error)
	// OpenStream is the control plane of a streaming route (terminal, exec, logs,
	// results); its data plane is a raw brokered conn named by the returned
	// broker_id. Every WS route is bidirectional in the contract.
	OpenStream(ctx context.Context, in *StreamStart, opts ...grpc.CallOption) (*BrokerRef, error)
	// OpenChannel opens a tracked upstream Channel as a raw brokered conn. The
	// returned info also declares the channel's optional capabilities (resize, a
	// desktop server-init blob) so the host-side wrapper keeps parity with an
	// in-process Channel.
	OpenChannel(ctx context.Context, in *ChannelRequest, opts ...grpc.CallOption) (*ChannelInfo, error)
	// ResizeChannel forwards a terminal resize to an open channel that declared
	// resizable.
	ResizeChannel(ctx context.Context, in *ChannelResize, opts ...grpc.CallOption) (*Empty, error)
	// ServeHTTPProxy lets the plugin serve a reverse-proxied browser request over
	// a raw brokered conn (redirects, assets, and WebSocket upgrades included).
	ServeHTTPProxy(ctx context.Context, in *ProxyRequest, opts ...grpc.CallOption) (*BrokerRef, error)
}

type PluginServer interface {
	GetManifest(context.Context, *Empty) (*Manifest, error)
	Connect(context.Context, *ConnectRequest) (*SessionHandle, error)
	HealthCheck(context.Context, *SessionHandle) (*Empty, error)
	Close(context.Context, *SessionHandle) (*Empty, error)
	// Invoke runs one non-streaming route; result_json is the handler's value.
	Invoke(context.Context, *InvokeRequest) (*InvokeResponse, error)
	// OpenStream is the control plane of a streaming route (terminal, exec, logs,
	// results); its data plane is a raw brokered conn named by the returned
	// broker_id. Every WS route is bidirectional in the contract.
	OpenStream(context.Context, *StreamStart) (*BrokerRef, error)
	// OpenChannel opens a tracked upstream Channel as a raw brokered conn. The
	// returned info also declares the channel's optional capabilities (resize, a
	// desktop server-init blob) so the host-side wrapper keeps parity with an
	// in-process Channel.
	OpenChannel(context.Context, *ChannelRequest) (*ChannelInfo, error)
	// ResizeChannel forwards a terminal resize to an open channel that declared
	// resizable.
	ResizeChannel(context.Context, *ChannelResize) (*Empty, error)
	// ServeHTTPProxy lets the plugin serve a reverse-proxied browser request over
	// a raw brokered conn (redirects, assets, and WebSocket upgrades included).
	ServeHTTPProxy(context.Context, *ProxyRequest) (*BrokerRef, error)
	// contains filtered or unexported methods
}

type ProxyEndpoint struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`                // core forward-proxy address the plugin dials
	BaseUrl string `protobuf:"bytes,2,opt,name=base_url,json=baseUrl,proto3" json:"base_url,omitempty"` // upstream base URL the plugin's client targets
	// contains filtered or unexported fields
}

type ProxyRequest struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Path      string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // route-prefix-stripped target path
	// contains filtered or unexported fields
}

type SessionHandle struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

type StorageDeleteRequest struct {
	Scope *StorageScope `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	Key   string        `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type StorageGetRequest struct {
	Scope *StorageScope `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	Key   string        `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type StorageItem struct {
	Key               string            `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value             []byte            `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	ContentType       string            `protobuf:"bytes,3,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	Metadata          map[string]string `` /* 143-byte string literal not displayed */
	CreatedAtUnixNano int64             `protobuf:"varint,5,opt,name=created_at_unix_nano,json=createdAtUnixNano,proto3" json:"created_at_unix_nano,omitempty"`
	UpdatedAtUnixNano int64             `protobuf:"varint,6,opt,name=updated_at_unix_nano,json=updatedAtUnixNano,proto3" json:"updated_at_unix_nano,omitempty"`
	// contains filtered or unexported fields
}

type StorageListFilter struct {
	Keys                  []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	KeyPrefix             string   `protobuf:"bytes,2,opt,name=key_prefix,json=keyPrefix,proto3" json:"key_prefix,omitempty"`
	ContentType           string   `protobuf:"bytes,3,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	CreatedAfterUnixNano  int64    `` /* 126-byte string literal not displayed */
	CreatedBeforeUnixNano int64    `` /* 129-byte string literal not displayed */
	UpdatedAfterUnixNano  int64    `` /* 126-byte string literal not displayed */
	UpdatedBeforeUnixNano int64    `` /* 129-byte string literal not displayed */
	Limit                 int32    `protobuf:"varint,8,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset                int32    `protobuf:"varint,9,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

type StorageListRequest struct {
	Scope  *StorageScope      `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	Filter *StorageListFilter `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

type StorageListResponse struct {
	Items []*StorageItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

type StoragePutRequest struct {
	Collection string       `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	Item       *StorageItem `protobuf:"bytes,2,opt,name=item,proto3" json:"item,omitempty"`
	// contains filtered or unexported fields
}

type StorageScope struct {
	Collection string `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	Level      string `protobuf:"bytes,2,opt,name=level,proto3" json:"level,omitempty"`
	// contains filtered or unexported fields
}

type StreamStart struct {
	SessionId   string            `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	RouteId     string            `protobuf:"bytes,2,opt,name=route_id,json=routeId,proto3" json:"route_id,omitempty"`
	Params      map[string]string `` /* 139-byte string literal not displayed */
	User        *ActingUser       `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
	ProxyPrefix string            `protobuf:"bytes,5,opt,name=proxy_prefix,json=proxyPrefix,proto3" json:"proxy_prefix,omitempty"` // the connection's public proxy mount
	// contains filtered or unexported fields
}

type UnimplementedConnServer struct{}

type UnimplementedHostServer struct{}

type UnimplementedPluginServer struct{}

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

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

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