rcredential

package
v0.0.0-...-36d6306 Latest Latest
Warning

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

 Go to latest Published: Jul 5, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateService 

func CreateService(srv CredentialRPC, options []connect.HandlerOption) (*api.Service, error)

Types

type CredentialAnthropicEvent 

type CredentialAnthropicEvent struct {
	Type   string
	Secret *credentialv1.CredentialAnthropic
}

type CredentialAnthropicTopic 

type CredentialAnthropicTopic struct {
	WorkspaceID idwrap.IDWrap
}

type CredentialEvent 

type CredentialEvent struct {
	Type       string
	Credential *credentialv1.Credential
}

type CredentialGeminiEvent 

type CredentialGeminiEvent struct {
	Type   string
	Secret *credentialv1.CredentialGemini
}

type CredentialGeminiTopic 

type CredentialGeminiTopic struct {
	WorkspaceID idwrap.IDWrap
}

type CredentialOpenAiEvent 

type CredentialOpenAiEvent struct {
	Type   string
	Secret *credentialv1.CredentialOpenAi
}

type CredentialOpenAiTopic 

type CredentialOpenAiTopic struct {
	WorkspaceID idwrap.IDWrap
}

type CredentialRPC 

type CredentialRPC struct {
	DB *sql.DB
	// contains filtered or unexported fields
}

func New 

func New(deps CredentialRPCDeps) CredentialRPC

func (*CredentialRPC) CredentialAnthropicCollection 

func (s *CredentialRPC) CredentialAnthropicCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[credentialv1.CredentialAnthropicCollectionResponse], error)

func (*CredentialRPC) CredentialAnthropicDelete 

func (s *CredentialRPC) CredentialAnthropicDelete(
	ctx context.Context,
	req *connect.Request[credentialv1.CredentialAnthropicDeleteRequest],
) (*connect.Response[emptypb.Empty], error)

func (*CredentialRPC) CredentialAnthropicInsert 

func (s *CredentialRPC) CredentialAnthropicInsert(
	ctx context.Context,
	req *connect.Request[credentialv1.CredentialAnthropicInsertRequest],
) (*connect.Response[emptypb.Empty], error)

func (*CredentialRPC) CredentialAnthropicSync 

func (s *CredentialRPC) CredentialAnthropicSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[credentialv1.CredentialAnthropicSyncResponse],
) error

func (*CredentialRPC) CredentialAnthropicUpdate 

func (s *CredentialRPC) CredentialAnthropicUpdate(
	ctx context.Context,
	req *connect.Request[credentialv1.CredentialAnthropicUpdateRequest],
) (*connect.Response[emptypb.Empty], error)

func (*CredentialRPC) CredentialCollection 

func (s *CredentialRPC) CredentialCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[credentialv1.CredentialCollectionResponse], error)

func (*CredentialRPC) CredentialDelete 

func (s *CredentialRPC) CredentialDelete(
	ctx context.Context,
	req *connect.Request[credentialv1.CredentialDeleteRequest],
) (*connect.Response[emptypb.Empty], error)

func (*CredentialRPC) CredentialGeminiCollection 

func (s *CredentialRPC) CredentialGeminiCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[credentialv1.CredentialGeminiCollectionResponse], error)

func (*CredentialRPC) CredentialGeminiDelete 

func (s *CredentialRPC) CredentialGeminiDelete(
	ctx context.Context,
	req *connect.Request[credentialv1.CredentialGeminiDeleteRequest],
) (*connect.Response[emptypb.Empty], error)

func (*CredentialRPC) CredentialGeminiInsert 

func (s *CredentialRPC) CredentialGeminiInsert(
	ctx context.Context,
	req *connect.Request[credentialv1.CredentialGeminiInsertRequest],
) (*connect.Response[emptypb.Empty], error)

func (*CredentialRPC) CredentialGeminiSync 

func (s *CredentialRPC) CredentialGeminiSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[credentialv1.CredentialGeminiSyncResponse],
) error

func (*CredentialRPC) CredentialGeminiUpdate 

func (s *CredentialRPC) CredentialGeminiUpdate(
	ctx context.Context,
	req *connect.Request[credentialv1.CredentialGeminiUpdateRequest],
) (*connect.Response[emptypb.Empty], error)

func (*CredentialRPC) CredentialInsert 

func (s *CredentialRPC) CredentialInsert(
	ctx context.Context,
	req *connect.Request[credentialv1.CredentialInsertRequest],
) (*connect.Response[emptypb.Empty], error)

func (*CredentialRPC) CredentialOpenAiCollection 

func (s *CredentialRPC) CredentialOpenAiCollection(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[credentialv1.CredentialOpenAiCollectionResponse], error)

func (*CredentialRPC) CredentialOpenAiDelete 

func (s *CredentialRPC) CredentialOpenAiDelete(
	ctx context.Context,
	req *connect.Request[credentialv1.CredentialOpenAiDeleteRequest],
) (*connect.Response[emptypb.Empty], error)

func (*CredentialRPC) CredentialOpenAiInsert 

func (s *CredentialRPC) CredentialOpenAiInsert(
	ctx context.Context,
	req *connect.Request[credentialv1.CredentialOpenAiInsertRequest],
) (*connect.Response[emptypb.Empty], error)

func (*CredentialRPC) CredentialOpenAiSync 

func (s *CredentialRPC) CredentialOpenAiSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[credentialv1.CredentialOpenAiSyncResponse],
) error

func (*CredentialRPC) CredentialOpenAiUpdate 

func (s *CredentialRPC) CredentialOpenAiUpdate(
	ctx context.Context,
	req *connect.Request[credentialv1.CredentialOpenAiUpdateRequest],
) (*connect.Response[emptypb.Empty], error)

func (*CredentialRPC) CredentialSync 

func (s *CredentialRPC) CredentialSync(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
	stream *connect.ServerStream[credentialv1.CredentialSyncResponse],
) error

func (*CredentialRPC) CredentialUpdate 

func (s *CredentialRPC) CredentialUpdate(
	ctx context.Context,
	req *connect.Request[credentialv1.CredentialUpdateRequest],
) (*connect.Response[emptypb.Empty], error)

type CredentialRPCDeps 

type CredentialRPCDeps struct {
	DB        *sql.DB
	Services  CredentialRPCServices
	Readers   CredentialRPCReaders
	Streamers CredentialRPCStreamers
	Publisher mutation.Publisher // Unified publisher for cascade delete events
}

func (*CredentialRPCDeps) Validate 

func (d *CredentialRPCDeps) Validate() error

type CredentialRPCReaders 

type CredentialRPCReaders struct {
	Credential *scredential.CredentialReader
}

func (*CredentialRPCReaders) Validate 

func (r *CredentialRPCReaders) Validate() error

type CredentialRPCServices 

type CredentialRPCServices struct {
	Credential scredential.CredentialService
	User       suser.UserService
	Workspace  sworkspace.WorkspaceService
}

func (*CredentialRPCServices) Validate 

func (s *CredentialRPCServices) Validate() error

type CredentialRPCStreamers 

type CredentialRPCStreamers struct {
	Credential eventstream.SyncStreamer[CredentialTopic, CredentialEvent]
	OpenAi     eventstream.SyncStreamer[CredentialOpenAiTopic, CredentialOpenAiEvent]
	Gemini     eventstream.SyncStreamer[CredentialGeminiTopic, CredentialGeminiEvent]
	Anthropic  eventstream.SyncStreamer[CredentialAnthropicTopic, CredentialAnthropicEvent]
}

func (*CredentialRPCStreamers) Validate 

func (s *CredentialRPCStreamers) Validate() error

type CredentialTopic 

type CredentialTopic struct {
	WorkspaceID idwrap.IDWrap
}

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.