reader

package

v0.2.0 Latest Latest Go to latest Published: May 25, 2022 License: Apache-2.0 Imports: 18 Imported by: 0

Details

This section is empty.

This section is empty.

func Filters() *filter.Filters

Filters returns a reader filter singleton

func HandleRead(srv Service, filters ...filter.Filter) shared2.Handle

HandleRead handles read request

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

Record represents a record

func NewRecord(proto *gtly.Proto, columns []string, columnTypes []dsc.ColumnType) *Record

NewRecord creates a record

func (r *Record) Object() (*gtly.Object, error)

Object returns record object

func (r *Record) Reset()

Reset reset record

type Request struct {
	contract.Request
}

Request represents read request

type Response struct {
	contract.Response
}

Response represents

func NewResponse() *Response

NewResponse creates a response

type Service interface {
	Read(ctx context.Context, request *Request) *Response
}

Service represents a reader service

func New(ctx context.Context, config *config2.Config) (Service, error)

New creates a service