Documentation ¶
Index ¶
- func Start(ctx context.Context, config configuration.Configuration) error
- type RecordService
- func (rs RecordService) Commit(ctx context.Context, request *services.CommitRecordRequest) (*services.CommitRecordResponse, error)
- func (c RecordService) CreateSchema(ctx context.Context, request *services.CreateSchemaRequest) (*services.CreateSchemaResponse, error)
- func (rs RecordService) Delete(ctx context.Context, request *services.DeleteRecordRequest) (*services.DeleteRecordResponse, error)
- func (c RecordService) FindRecord(ctx context.Context, request *services.FindRecordRequest) (*services.FindRecordResponse, error)
- func (c RecordService) InvalidateSchema(ctx context.Context, request *services.InvalidateSchemaRequest) (*services.InvalidateSchemaResponse, error)
- func (rs RecordService) Query(ctx context.Context, request *services.QueryRecordRequest) (*services.QueryRecordResponse, error)
- func (c RecordService) ValidateRecord(ctx context.Context, request *services.ValidateRecordRequest) (*services.ValidateRecordResponse, error)
- func (rs RecordService) Write(ctx context.Context, request *services.WriteRecordRequest) (*services.WriteRecordResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Start ¶
func Start(ctx context.Context, config configuration.Configuration) error
Types ¶
type RecordService ¶
type RecordService struct { services.UnimplementedRecordServiceServer RecordStore storage.RecordStore }
func CreateRecordService ¶
func CreateRecordService(recordStoreConnectionURI string) (*RecordService, error)
func (RecordService) Commit ¶
func (rs RecordService) Commit(ctx context.Context, request *services.CommitRecordRequest) (*services.CommitRecordResponse, error)
func (RecordService) CreateSchema ¶
func (c RecordService) CreateSchema(ctx context.Context, request *services.CreateSchemaRequest) (*services.CreateSchemaResponse, error)
func (RecordService) Delete ¶
func (rs RecordService) Delete(ctx context.Context, request *services.DeleteRecordRequest) (*services.DeleteRecordResponse, error)
func (RecordService) FindRecord ¶
func (c RecordService) FindRecord(ctx context.Context, request *services.FindRecordRequest) (*services.FindRecordResponse, error)
func (RecordService) InvalidateSchema ¶
func (c RecordService) InvalidateSchema(ctx context.Context, request *services.InvalidateSchemaRequest) (*services.InvalidateSchemaResponse, error)
func (RecordService) Query ¶
func (rs RecordService) Query(ctx context.Context, request *services.QueryRecordRequest) (*services.QueryRecordResponse, error)
func (RecordService) ValidateRecord ¶
func (c RecordService) ValidateRecord(ctx context.Context, request *services.ValidateRecordRequest) (*services.ValidateRecordResponse, error)
func (RecordService) Write ¶
func (rs RecordService) Write(ctx context.Context, request *services.WriteRecordRequest) (*services.WriteRecordResponse, error)
Click to show internal directories.
Click to hide internal directories.