README
¶
Remote implementation of Catalog datastore APIs
This implementation calls a gRPC service which is backed by the Catalog postgres database. The service offers a streaming gRPC API, which allows for transaction state to be maintained through that stream connection. If the stream closes, normal cleanup will rollback the transaction. The Catalog service APIs include message to begin, commit, and roll-back a transaction.
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCatalogDataStore ¶
func NewCatalogDataStore(config CatalogDataStoreConfig) *catalogDataStore
func ThrowAndCatch ¶
func ThrowAndCatch( catalog *catalogDataStore, request *pb.DataAccessRequest, ) (*pb.DataAccessResponse, error)
Types ¶
type CatalogClient ¶
type CatalogClient struct {
// contains filtered or unexported fields
}
func NewCatalogClient ¶
func NewCatalogClient(ctx context.Context, cfg CatalogConfig) (*CatalogClient, error)
NewCatalogClient creates a new CatalogClient with the provided configuration.
func (*CatalogClient) CloseStream ¶
func (c *CatalogClient) CloseStream() error
func (*CatalogClient) DataAccess ¶
func (c *CatalogClient) DataAccess() (grpc.BidiStreamingClient[pb.DataAccessRequest, pb.DataAccessResponse], error)
type CatalogConfig ¶
type CatalogConfig struct {
GRPC string
Creds credentials.TransportCredentials
}
type CatalogDataStoreConfig ¶
type CatalogDataStoreConfig struct {
Domain string
Environment string
Client *CatalogClient
}
Source Files
Click to show internal directories.
Click to hide internal directories.