ipcpbconnect

package
v0.0.0-...-cb3f5c8 Latest Latest
Warning

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

 Go to latest Published: Jan 6, 2026 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// BuckleyIPCSubscribeProcedure is the fully-qualified name of the BuckleyIPC's Subscribe RPC.
	BuckleyIPCSubscribeProcedure = "/buckley.ipc.v1.BuckleyIPC/Subscribe"
	// BuckleyIPCSendCommandProcedure is the fully-qualified name of the BuckleyIPC's SendCommand RPC.
	BuckleyIPCSendCommandProcedure = "/buckley.ipc.v1.BuckleyIPC/SendCommand"
	// BuckleyIPCListSessionsProcedure is the fully-qualified name of the BuckleyIPC's ListSessions RPC.
	BuckleyIPCListSessionsProcedure = "/buckley.ipc.v1.BuckleyIPC/ListSessions"
	// BuckleyIPCGetSessionProcedure is the fully-qualified name of the BuckleyIPC's GetSession RPC.
	BuckleyIPCGetSessionProcedure = "/buckley.ipc.v1.BuckleyIPC/GetSession"
	// BuckleyIPCCreateHeadlessSessionProcedure is the fully-qualified name of the BuckleyIPC's
	// CreateHeadlessSession RPC.
	BuckleyIPCCreateHeadlessSessionProcedure = "/buckley.ipc.v1.BuckleyIPC/CreateHeadlessSession"
	// BuckleyIPCDeleteHeadlessSessionProcedure is the fully-qualified name of the BuckleyIPC's
	// DeleteHeadlessSession RPC.
	BuckleyIPCDeleteHeadlessSessionProcedure = "/buckley.ipc.v1.BuckleyIPC/DeleteHeadlessSession"
	// BuckleyIPCListHeadlessSessionsProcedure is the fully-qualified name of the BuckleyIPC's
	// ListHeadlessSessions RPC.
	BuckleyIPCListHeadlessSessionsProcedure = "/buckley.ipc.v1.BuckleyIPC/ListHeadlessSessions"
	// BuckleyIPCListPlansProcedure is the fully-qualified name of the BuckleyIPC's ListPlans RPC.
	BuckleyIPCListPlansProcedure = "/buckley.ipc.v1.BuckleyIPC/ListPlans"
	// BuckleyIPCGetPlanProcedure is the fully-qualified name of the BuckleyIPC's GetPlan RPC.
	BuckleyIPCGetPlanProcedure = "/buckley.ipc.v1.BuckleyIPC/GetPlan"
	// BuckleyIPCListProjectsProcedure is the fully-qualified name of the BuckleyIPC's ListProjects RPC.
	BuckleyIPCListProjectsProcedure = "/buckley.ipc.v1.BuckleyIPC/ListProjects"
	// BuckleyIPCCreateProjectProcedure is the fully-qualified name of the BuckleyIPC's CreateProject
	// RPC.
	BuckleyIPCCreateProjectProcedure = "/buckley.ipc.v1.BuckleyIPC/CreateProject"
	// BuckleyIPCListPersonasProcedure is the fully-qualified name of the BuckleyIPC's ListPersonas RPC.
	BuckleyIPCListPersonasProcedure = "/buckley.ipc.v1.BuckleyIPC/ListPersonas"
	// BuckleyIPCWorkflowActionProcedure is the fully-qualified name of the BuckleyIPC's WorkflowAction
	// RPC.
	BuckleyIPCWorkflowActionProcedure = "/buckley.ipc.v1.BuckleyIPC/WorkflowAction"
	// BuckleyIPCRegisterAgentProcedure is the fully-qualified name of the BuckleyIPC's RegisterAgent
	// RPC.
	BuckleyIPCRegisterAgentProcedure = "/buckley.ipc.v1.BuckleyIPC/RegisterAgent"
	// BuckleyIPCReportAgentResultProcedure is the fully-qualified name of the BuckleyIPC's
	// ReportAgentResult RPC.
	BuckleyIPCReportAgentResultProcedure = "/buckley.ipc.v1.BuckleyIPC/ReportAgentResult"
	// BuckleyIPCAgentHeartbeatProcedure is the fully-qualified name of the BuckleyIPC's AgentHeartbeat
	// RPC.
	BuckleyIPCAgentHeartbeatProcedure = "/buckley.ipc.v1.BuckleyIPC/AgentHeartbeat"
	// BuckleyIPCListAgentsProcedure is the fully-qualified name of the BuckleyIPC's ListAgents RPC.
	BuckleyIPCListAgentsProcedure = "/buckley.ipc.v1.BuckleyIPC/ListAgents"
	// BuckleyIPCListPendingApprovalsProcedure is the fully-qualified name of the BuckleyIPC's
	// ListPendingApprovals RPC.
	BuckleyIPCListPendingApprovalsProcedure = "/buckley.ipc.v1.BuckleyIPC/ListPendingApprovals"
	// BuckleyIPCApproveToolCallProcedure is the fully-qualified name of the BuckleyIPC's
	// ApproveToolCall RPC.
	BuckleyIPCApproveToolCallProcedure = "/buckley.ipc.v1.BuckleyIPC/ApproveToolCall"
	// BuckleyIPCRejectToolCallProcedure is the fully-qualified name of the BuckleyIPC's RejectToolCall
	// RPC.
	BuckleyIPCRejectToolCallProcedure = "/buckley.ipc.v1.BuckleyIPC/RejectToolCall"
	// BuckleyIPCGetApprovalPolicyProcedure is the fully-qualified name of the BuckleyIPC's
	// GetApprovalPolicy RPC.
	BuckleyIPCGetApprovalPolicyProcedure = "/buckley.ipc.v1.BuckleyIPC/GetApprovalPolicy"
	// BuckleyIPCUpdateApprovalPolicyProcedure is the fully-qualified name of the BuckleyIPC's
	// UpdateApprovalPolicy RPC.
	BuckleyIPCUpdateApprovalPolicyProcedure = "/buckley.ipc.v1.BuckleyIPC/UpdateApprovalPolicy"
	// BuckleyIPCGetAuditLogProcedure is the fully-qualified name of the BuckleyIPC's GetAuditLog RPC.
	BuckleyIPCGetAuditLogProcedure = "/buckley.ipc.v1.BuckleyIPC/GetAuditLog"
	// BuckleyIPCSubscribePushProcedure is the fully-qualified name of the BuckleyIPC's SubscribePush
	// RPC.
	BuckleyIPCSubscribePushProcedure = "/buckley.ipc.v1.BuckleyIPC/SubscribePush"
	// BuckleyIPCUnsubscribePushProcedure is the fully-qualified name of the BuckleyIPC's
	// UnsubscribePush RPC.
	BuckleyIPCUnsubscribePushProcedure = "/buckley.ipc.v1.BuckleyIPC/UnsubscribePush"
	// BuckleyIPCGetVAPIDPublicKeyProcedure is the fully-qualified name of the BuckleyIPC's
	// GetVAPIDPublicKey RPC.
	BuckleyIPCGetVAPIDPublicKeyProcedure = "/buckley.ipc.v1.BuckleyIPC/GetVAPIDPublicKey"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// BuckleyIPCName is the fully-qualified name of the BuckleyIPC service.
	BuckleyIPCName = "buckley.ipc.v1.BuckleyIPC"
)

Variables

This section is empty.

Functions

func NewBuckleyIPCHandler 

func NewBuckleyIPCHandler(svc BuckleyIPCHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewBuckleyIPCHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

Types

type BuckleyIPCClient 

type BuckleyIPCClient interface {
	// Subscribe opens a server-streaming connection for real-time events.
	// Used by web UI, CLI watchers, and monitoring tools.
	Subscribe(context.Context, *connect.Request[proto.SubscribeRequest]) (*connect.ServerStreamForClient[proto.Event], error)
	// SendCommand dispatches user input or slash commands to a session.
	SendCommand(context.Context, *connect.Request[proto.CommandRequest]) (*connect.Response[proto.CommandResponse], error)
	// ListSessions returns all active and recent sessions.
	ListSessions(context.Context, *connect.Request[proto.ListSessionsRequest]) (*connect.Response[proto.ListSessionsResponse], error)
	// GetSession returns detailed session state including messages and todos.
	GetSession(context.Context, *connect.Request[proto.GetSessionRequest]) (*connect.Response[proto.SessionDetail], error)
	// CreateHeadlessSession spawns an isolated session on the server.
	CreateHeadlessSession(context.Context, *connect.Request[proto.CreateHeadlessRequest]) (*connect.Response[proto.HeadlessSession], error)
	// DeleteHeadlessSession terminates and cleans up a headless session.
	DeleteHeadlessSession(context.Context, *connect.Request[proto.DeleteHeadlessRequest]) (*connect.Response[emptypb.Empty], error)
	// ListHeadlessSessions returns all running headless sessions.
	ListHeadlessSessions(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[proto.HeadlessSessionList], error)
	// ListPlans returns all available plans.
	ListPlans(context.Context, *connect.Request[proto.ListPlansRequest]) (*connect.Response[proto.ListPlansResponse], error)
	// GetPlan returns detailed plan information including tasks.
	GetPlan(context.Context, *connect.Request[proto.GetPlanRequest]) (*connect.Response[proto.Plan], error)
	// ListProjects returns all known projects.
	ListProjects(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[proto.ProjectList], error)
	// CreateProject registers a new project.
	CreateProject(context.Context, *connect.Request[proto.CreateProjectRequest]) (*connect.Response[proto.Project], error)
	// ListPersonas returns available AI personas.
	ListPersonas(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[proto.PersonaList], error)
	// WorkflowAction triggers plan/execute/pause/resume operations.
	WorkflowAction(context.Context, *connect.Request[proto.WorkflowActionRequest]) (*connect.Response[proto.WorkflowActionResponse], error)
	// RegisterAgent connects a host agent to the server.
	// The agent receives commands via the returned stream.
	RegisterAgent(context.Context, *connect.Request[proto.RegisterAgentRequest]) (*connect.ServerStreamForClient[proto.AgentCommand], error)
	// ReportAgentResult sends execution results back to the server.
	ReportAgentResult(context.Context, *connect.Request[proto.AgentResult]) (*connect.Response[emptypb.Empty], error)
	// AgentHeartbeat keeps the agent connection alive and reports status.
	AgentHeartbeat(context.Context, *connect.Request[proto.AgentHeartbeatRequest]) (*connect.Response[proto.AgentHeartbeatResponse], error)
	// ListAgents returns all connected host agents.
	ListAgents(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[proto.AgentList], error)
	// ListPendingApprovals returns pending tool call approvals for a session.
	ListPendingApprovals(context.Context, *connect.Request[proto.ListPendingApprovalsRequest]) (*connect.Response[proto.PendingApprovalsList], error)
	// ApproveToolCall approves a pending tool call.
	ApproveToolCall(context.Context, *connect.Request[proto.ApproveToolCallRequest]) (*connect.Response[proto.ApproveToolCallResponse], error)
	// RejectToolCall rejects a pending tool call.
	RejectToolCall(context.Context, *connect.Request[proto.RejectToolCallRequest]) (*connect.Response[proto.RejectToolCallResponse], error)
	// GetApprovalPolicy returns the active approval policy.
	GetApprovalPolicy(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[proto.ApprovalPolicy], error)
	// UpdateApprovalPolicy updates the approval policy configuration.
	UpdateApprovalPolicy(context.Context, *connect.Request[proto.UpdateApprovalPolicyRequest]) (*connect.Response[proto.ApprovalPolicy], error)
	// GetAuditLog returns the tool execution audit log for a session.
	GetAuditLog(context.Context, *connect.Request[proto.GetAuditLogRequest]) (*connect.Response[proto.AuditLogResponse], error)
	// SubscribePush registers a browser for push notifications.
	SubscribePush(context.Context, *connect.Request[proto.PushSubscriptionRequest]) (*connect.Response[proto.PushSubscriptionResponse], error)
	// UnsubscribePush removes a push subscription.
	UnsubscribePush(context.Context, *connect.Request[proto.UnsubscribePushRequest]) (*connect.Response[emptypb.Empty], error)
	// GetVAPIDPublicKey returns the server's VAPID public key for Web Push.
	GetVAPIDPublicKey(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[proto.VAPIDPublicKeyResponse], error)
}

BuckleyIPCClient is a client for the buckley.ipc.v1.BuckleyIPC service.

func NewBuckleyIPCClient 

func NewBuckleyIPCClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) BuckleyIPCClient

NewBuckleyIPCClient constructs a client for the buckley.ipc.v1.BuckleyIPC service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type BuckleyIPCHandler 

type BuckleyIPCHandler interface {
	// Subscribe opens a server-streaming connection for real-time events.
	// Used by web UI, CLI watchers, and monitoring tools.
	Subscribe(context.Context, *connect.Request[proto.SubscribeRequest], *connect.ServerStream[proto.Event]) error
	// SendCommand dispatches user input or slash commands to a session.
	SendCommand(context.Context, *connect.Request[proto.CommandRequest]) (*connect.Response[proto.CommandResponse], error)
	// ListSessions returns all active and recent sessions.
	ListSessions(context.Context, *connect.Request[proto.ListSessionsRequest]) (*connect.Response[proto.ListSessionsResponse], error)
	// GetSession returns detailed session state including messages and todos.
	GetSession(context.Context, *connect.Request[proto.GetSessionRequest]) (*connect.Response[proto.SessionDetail], error)
	// CreateHeadlessSession spawns an isolated session on the server.
	CreateHeadlessSession(context.Context, *connect.Request[proto.CreateHeadlessRequest]) (*connect.Response[proto.HeadlessSession], error)
	// DeleteHeadlessSession terminates and cleans up a headless session.
	DeleteHeadlessSession(context.Context, *connect.Request[proto.DeleteHeadlessRequest]) (*connect.Response[emptypb.Empty], error)
	// ListHeadlessSessions returns all running headless sessions.
	ListHeadlessSessions(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[proto.HeadlessSessionList], error)
	// ListPlans returns all available plans.
	ListPlans(context.Context, *connect.Request[proto.ListPlansRequest]) (*connect.Response[proto.ListPlansResponse], error)
	// GetPlan returns detailed plan information including tasks.
	GetPlan(context.Context, *connect.Request[proto.GetPlanRequest]) (*connect.Response[proto.Plan], error)
	// ListProjects returns all known projects.
	ListProjects(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[proto.ProjectList], error)
	// CreateProject registers a new project.
	CreateProject(context.Context, *connect.Request[proto.CreateProjectRequest]) (*connect.Response[proto.Project], error)
	// ListPersonas returns available AI personas.
	ListPersonas(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[proto.PersonaList], error)
	// WorkflowAction triggers plan/execute/pause/resume operations.
	WorkflowAction(context.Context, *connect.Request[proto.WorkflowActionRequest]) (*connect.Response[proto.WorkflowActionResponse], error)
	// RegisterAgent connects a host agent to the server.
	// The agent receives commands via the returned stream.
	RegisterAgent(context.Context, *connect.Request[proto.RegisterAgentRequest], *connect.ServerStream[proto.AgentCommand]) error
	// ReportAgentResult sends execution results back to the server.
	ReportAgentResult(context.Context, *connect.Request[proto.AgentResult]) (*connect.Response[emptypb.Empty], error)
	// AgentHeartbeat keeps the agent connection alive and reports status.
	AgentHeartbeat(context.Context, *connect.Request[proto.AgentHeartbeatRequest]) (*connect.Response[proto.AgentHeartbeatResponse], error)
	// ListAgents returns all connected host agents.
	ListAgents(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[proto.AgentList], error)
	// ListPendingApprovals returns pending tool call approvals for a session.
	ListPendingApprovals(context.Context, *connect.Request[proto.ListPendingApprovalsRequest]) (*connect.Response[proto.PendingApprovalsList], error)
	// ApproveToolCall approves a pending tool call.
	ApproveToolCall(context.Context, *connect.Request[proto.ApproveToolCallRequest]) (*connect.Response[proto.ApproveToolCallResponse], error)
	// RejectToolCall rejects a pending tool call.
	RejectToolCall(context.Context, *connect.Request[proto.RejectToolCallRequest]) (*connect.Response[proto.RejectToolCallResponse], error)
	// GetApprovalPolicy returns the active approval policy.
	GetApprovalPolicy(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[proto.ApprovalPolicy], error)
	// UpdateApprovalPolicy updates the approval policy configuration.
	UpdateApprovalPolicy(context.Context, *connect.Request[proto.UpdateApprovalPolicyRequest]) (*connect.Response[proto.ApprovalPolicy], error)
	// GetAuditLog returns the tool execution audit log for a session.
	GetAuditLog(context.Context, *connect.Request[proto.GetAuditLogRequest]) (*connect.Response[proto.AuditLogResponse], error)
	// SubscribePush registers a browser for push notifications.
	SubscribePush(context.Context, *connect.Request[proto.PushSubscriptionRequest]) (*connect.Response[proto.PushSubscriptionResponse], error)
	// UnsubscribePush removes a push subscription.
	UnsubscribePush(context.Context, *connect.Request[proto.UnsubscribePushRequest]) (*connect.Response[emptypb.Empty], error)
	// GetVAPIDPublicKey returns the server's VAPID public key for Web Push.
	GetVAPIDPublicKey(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[proto.VAPIDPublicKeyResponse], error)
}

BuckleyIPCHandler is an implementation of the buckley.ipc.v1.BuckleyIPC service.

type UnimplementedBuckleyIPCHandler 

type UnimplementedBuckleyIPCHandler struct{}

UnimplementedBuckleyIPCHandler returns CodeUnimplemented from all methods.

func (UnimplementedBuckleyIPCHandler) AgentHeartbeat 

func (UnimplementedBuckleyIPCHandler) AgentHeartbeat(context.Context, *connect.Request[proto.AgentHeartbeatRequest]) (*connect.Response[proto.AgentHeartbeatResponse], error)

func (UnimplementedBuckleyIPCHandler) ApproveToolCall 

func (UnimplementedBuckleyIPCHandler) ApproveToolCall(context.Context, *connect.Request[proto.ApproveToolCallRequest]) (*connect.Response[proto.ApproveToolCallResponse], error)

func (UnimplementedBuckleyIPCHandler) CreateHeadlessSession 

func (UnimplementedBuckleyIPCHandler) CreateHeadlessSession(context.Context, *connect.Request[proto.CreateHeadlessRequest]) (*connect.Response[proto.HeadlessSession], error)

func (UnimplementedBuckleyIPCHandler) CreateProject 

func (UnimplementedBuckleyIPCHandler) CreateProject(context.Context, *connect.Request[proto.CreateProjectRequest]) (*connect.Response[proto.Project], error)

func (UnimplementedBuckleyIPCHandler) DeleteHeadlessSession 

func (UnimplementedBuckleyIPCHandler) DeleteHeadlessSession(context.Context, *connect.Request[proto.DeleteHeadlessRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedBuckleyIPCHandler) GetApprovalPolicy 

func (UnimplementedBuckleyIPCHandler) GetApprovalPolicy(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[proto.ApprovalPolicy], error)

func (UnimplementedBuckleyIPCHandler) GetAuditLog 

func (UnimplementedBuckleyIPCHandler) GetAuditLog(context.Context, *connect.Request[proto.GetAuditLogRequest]) (*connect.Response[proto.AuditLogResponse], error)

func (UnimplementedBuckleyIPCHandler) GetPlan 

func (UnimplementedBuckleyIPCHandler) GetPlan(context.Context, *connect.Request[proto.GetPlanRequest]) (*connect.Response[proto.Plan], error)

func (UnimplementedBuckleyIPCHandler) GetSession 

func (UnimplementedBuckleyIPCHandler) GetSession(context.Context, *connect.Request[proto.GetSessionRequest]) (*connect.Response[proto.SessionDetail], error)

func (UnimplementedBuckleyIPCHandler) GetVAPIDPublicKey 

func (UnimplementedBuckleyIPCHandler) GetVAPIDPublicKey(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[proto.VAPIDPublicKeyResponse], error)

func (UnimplementedBuckleyIPCHandler) ListAgents 

func (UnimplementedBuckleyIPCHandler) ListAgents(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[proto.AgentList], error)

func (UnimplementedBuckleyIPCHandler) ListHeadlessSessions 

func (UnimplementedBuckleyIPCHandler) ListHeadlessSessions(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[proto.HeadlessSessionList], error)

func (UnimplementedBuckleyIPCHandler) ListPendingApprovals 

func (UnimplementedBuckleyIPCHandler) ListPendingApprovals(context.Context, *connect.Request[proto.ListPendingApprovalsRequest]) (*connect.Response[proto.PendingApprovalsList], error)

func (UnimplementedBuckleyIPCHandler) ListPersonas 

func (UnimplementedBuckleyIPCHandler) ListPersonas(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[proto.PersonaList], error)

func (UnimplementedBuckleyIPCHandler) ListPlans 

func (UnimplementedBuckleyIPCHandler) ListPlans(context.Context, *connect.Request[proto.ListPlansRequest]) (*connect.Response[proto.ListPlansResponse], error)

func (UnimplementedBuckleyIPCHandler) ListProjects 

func (UnimplementedBuckleyIPCHandler) ListProjects(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[proto.ProjectList], error)

func (UnimplementedBuckleyIPCHandler) ListSessions 

func (UnimplementedBuckleyIPCHandler) ListSessions(context.Context, *connect.Request[proto.ListSessionsRequest]) (*connect.Response[proto.ListSessionsResponse], error)

func (UnimplementedBuckleyIPCHandler) RegisterAgent 

func (UnimplementedBuckleyIPCHandler) RegisterAgent(context.Context, *connect.Request[proto.RegisterAgentRequest], *connect.ServerStream[proto.AgentCommand]) error

func (UnimplementedBuckleyIPCHandler) RejectToolCall 

func (UnimplementedBuckleyIPCHandler) RejectToolCall(context.Context, *connect.Request[proto.RejectToolCallRequest]) (*connect.Response[proto.RejectToolCallResponse], error)

func (UnimplementedBuckleyIPCHandler) ReportAgentResult 

func (UnimplementedBuckleyIPCHandler) ReportAgentResult(context.Context, *connect.Request[proto.AgentResult]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedBuckleyIPCHandler) SendCommand 

func (UnimplementedBuckleyIPCHandler) SendCommand(context.Context, *connect.Request[proto.CommandRequest]) (*connect.Response[proto.CommandResponse], error)

func (UnimplementedBuckleyIPCHandler) Subscribe 

func (UnimplementedBuckleyIPCHandler) Subscribe(context.Context, *connect.Request[proto.SubscribeRequest], *connect.ServerStream[proto.Event]) error

func (UnimplementedBuckleyIPCHandler) SubscribePush 

func (UnimplementedBuckleyIPCHandler) SubscribePush(context.Context, *connect.Request[proto.PushSubscriptionRequest]) (*connect.Response[proto.PushSubscriptionResponse], error)

func (UnimplementedBuckleyIPCHandler) UnsubscribePush 

func (UnimplementedBuckleyIPCHandler) UnsubscribePush(context.Context, *connect.Request[proto.UnsubscribePushRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedBuckleyIPCHandler) UpdateApprovalPolicy 

func (UnimplementedBuckleyIPCHandler) UpdateApprovalPolicy(context.Context, *connect.Request[proto.UpdateApprovalPolicyRequest]) (*connect.Response[proto.ApprovalPolicy], error)

func (UnimplementedBuckleyIPCHandler) WorkflowAction 

func (UnimplementedBuckleyIPCHandler) WorkflowAction(context.Context, *connect.Request[proto.WorkflowActionRequest]) (*connect.Response[proto.WorkflowActionResponse], error)

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.