service

Documentation

Index

• Constants
• Variables
• type ErrorCommit
  • func (e *ErrorCommit) Error() string
• type ErrorDelete
  • func (e *ErrorDelete) Error() string
  • func (e *ErrorDelete) Is(err error) bool
• type ErrorGet
  • func (e *ErrorGet) Error() string
• type ErrorValidation
  • func (e *ErrorValidation) Error() string
• type HTTPServiceGoTSRPCClient
  • func NewDefaultServiceGoTSRPCClient(url string) *HTTPServiceGoTSRPCClient
  • func NewServiceGoTSRPCClient(url string, endpoint string) *HTTPServiceGoTSRPCClient
  • func NewServiceGoTSRPCClientWithClient(url string, endpoint string, client *go_net_http.Client) *HTTPServiceGoTSRPCClient
  • func (tsc *HTTPServiceGoTSRPCClient) Commit(ctx go_context.Context, id github_com_foomo_busser_table.ID, ...) (retCommit_0 *ErrorCommit, clientErr error)
  • func (tsc *HTTPServiceGoTSRPCClient) Delete(ctx go_context.Context, id github_com_foomo_busser_table.ID, ...) (err *ErrorDelete, clientErr error)
  • func (tsc *HTTPServiceGoTSRPCClient) GetCommitted(ctx go_context.Context, id github_com_foomo_busser_table.ID) (t *github_com_foomo_busser_table.Table, ...)
  • func (tsc *HTTPServiceGoTSRPCClient) GetVersion(ctx go_context.Context, id github_com_foomo_busser_table.ID, ...) (t *github_com_foomo_busser_table.Table, ...)
  • func (tsc *HTTPServiceGoTSRPCClient) List(ctx go_context.Context) (retList_0 github_com_foomo_busser_table.Map, retList_1 *ErrorGet, ...)
  • func (tsc *HTTPServiceGoTSRPCClient) Validate(ctx go_context.Context, id github_com_foomo_busser_table.ID) (t *github_com_foomo_busser_table.Table, ...)
• type Service
• type ServiceGoTSRPCClient
• type ServiceGoTSRPCProxy
  • func NewDefaultServiceGoTSRPCProxy(service Service) *ServiceGoTSRPCProxy
  • func NewServiceGoTSRPCProxy(service Service, endpoint string) *ServiceGoTSRPCProxy
  • func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request)

Constants

const (
	ServiceGoTSRPCProxyCommit       = "Commit"
	ServiceGoTSRPCProxyDelete       = "Delete"
	ServiceGoTSRPCProxyGetCommitted = "GetCommitted"
	ServiceGoTSRPCProxyGetVersion   = "GetVersion"
	ServiceGoTSRPCProxyList         = "List"
	ServiceGoTSRPCProxyValidate     = "Validate"
)

Variables

var (
	ErrCommitCouldNotCommit = newCommitError(ErrorCommitCouldNotCommit)
)

var (
	ErrCouldNotLoadTableFromStore = newGetError(ErrorGetCouldNotLoadTableFromStore)
)

var (
	ErrDeleteCouldNotDeleteVersion = newDeleteError(ErrorDeleteCouldNotDeleteVersion)
)

var (
	ErrValidationCouldNotValidate = newValidationError(ErrorValidationCouldNotValidate)
)

Types

type ErrorCommit

type ErrorCommit string

const (
	ErrorCommitCouldNotCommit ErrorCommit = "COULD_NOT_COMMIT"
)

func (*ErrorCommit) Error

func (e *ErrorCommit) Error() string

type ErrorDelete

type ErrorDelete string

const (
	ErrorDeleteCouldNotDeleteVersion ErrorDelete = "COULD_NOT_DELETE_VERSION"
)

func (*ErrorDelete) Error

func (e *ErrorDelete) Error() string

func (*ErrorDelete) Is

func (e *ErrorDelete) Is(err error) bool

type ErrorGet

type ErrorGet string

const (
	ErrorGetCouldNotLoadTableFromStore ErrorGet = "COULD_NOT_LOAD_TABLE_FROM_STORE"
)

func (*ErrorGet) Error

func (e *ErrorGet) Error() string

type ErrorValidation

type ErrorValidation string

const (
	ErrorValidationCouldNotValidate ErrorValidation = "COULD_NOT_LOAD_TABLE_FROM_STORE"
)

func (*ErrorValidation) Error

func (e *ErrorValidation) Error() string

type HTTPServiceGoTSRPCClient

type HTTPServiceGoTSRPCClient struct {
	URL      string
	EndPoint string
	Client   gotsrpc.Client
}

func NewDefaultServiceGoTSRPCClient

func NewDefaultServiceGoTSRPCClient(url string) *HTTPServiceGoTSRPCClient

func NewServiceGoTSRPCClient

func NewServiceGoTSRPCClient(url string, endpoint string) *HTTPServiceGoTSRPCClient

func NewServiceGoTSRPCClientWithClient

func NewServiceGoTSRPCClientWithClient(url string, endpoint string, client *go_net_http.Client) *HTTPServiceGoTSRPCClient

func (*HTTPServiceGoTSRPCClient) Commit

func (tsc *HTTPServiceGoTSRPCClient) Commit(ctx go_context.Context, id github_com_foomo_busser_table.ID, version github_com_foomo_busser_table.Version) (retCommit_0 *ErrorCommit, clientErr error)

func (*HTTPServiceGoTSRPCClient) Delete

func (tsc *HTTPServiceGoTSRPCClient) Delete(ctx go_context.Context, id github_com_foomo_busser_table.ID, versions []github_com_foomo_busser_table.Version) (err *ErrorDelete, clientErr error)

func (*HTTPServiceGoTSRPCClient) GetCommitted

func (tsc *HTTPServiceGoTSRPCClient) GetCommitted(ctx go_context.Context, id github_com_foomo_busser_table.ID) (t *github_com_foomo_busser_table.Table, vt *github_com_foomo_busser_table_validation.Table, err *ErrorGet, clientErr error)

func (*HTTPServiceGoTSRPCClient) GetVersion

func (tsc *HTTPServiceGoTSRPCClient) GetVersion(ctx go_context.Context, id github_com_foomo_busser_table.ID, version github_com_foomo_busser_table.Version) (t *github_com_foomo_busser_table.Table, vt *github_com_foomo_busser_table_validation.Table, err *ErrorGet, clientErr error)

func (*HTTPServiceGoTSRPCClient) List

func (tsc *HTTPServiceGoTSRPCClient) List(ctx go_context.Context) (retList_0 github_com_foomo_busser_table.Map, retList_1 *ErrorGet, clientErr error)

func (*HTTPServiceGoTSRPCClient) Validate

func (tsc *HTTPServiceGoTSRPCClient) Validate(ctx go_context.Context, id github_com_foomo_busser_table.ID) (t *github_com_foomo_busser_table.Table, vt *github_com_foomo_busser_table_validation.Table, err *ErrorValidation, clientErr error)

type Service

type Service interface {
	Validate(id table.ID) (t *table.Table, vt *validation.Table, err *ErrorValidation)
	GetVersion(id table.ID, version table.Version) (t *table.Table, vt *validation.Table, err *ErrorGet)
	GetCommitted(id table.ID) (t *table.Table, vt *validation.Table, err *ErrorGet)
	Delete(id table.ID, versions []table.Version) (err *ErrorDelete)
	Commit(id table.ID, version table.Version) *ErrorCommit
	List() (table.Map, *ErrorGet)
}

type ServiceGoTSRPCClient

type ServiceGoTSRPCClient interface {
	Commit(ctx go_context.Context, id github_com_foomo_busser_table.ID, version github_com_foomo_busser_table.Version) (retCommit_0 *ErrorCommit, clientErr error)
	Delete(ctx go_context.Context, id github_com_foomo_busser_table.ID, versions []github_com_foomo_busser_table.Version) (err *ErrorDelete, clientErr error)
	GetCommitted(ctx go_context.Context, id github_com_foomo_busser_table.ID) (t *github_com_foomo_busser_table.Table, vt *github_com_foomo_busser_table_validation.Table, err *ErrorGet, clientErr error)
	GetVersion(ctx go_context.Context, id github_com_foomo_busser_table.ID, version github_com_foomo_busser_table.Version) (t *github_com_foomo_busser_table.Table, vt *github_com_foomo_busser_table_validation.Table, err *ErrorGet, clientErr error)
	List(ctx go_context.Context) (retList_0 github_com_foomo_busser_table.Map, retList_1 *ErrorGet, clientErr error)
	Validate(ctx go_context.Context, id github_com_foomo_busser_table.ID) (t *github_com_foomo_busser_table.Table, vt *github_com_foomo_busser_table_validation.Table, err *ErrorValidation, clientErr error)
}

type ServiceGoTSRPCProxy

type ServiceGoTSRPCProxy struct {
	EndPoint string
	// contains filtered or unexported fields
}

func NewDefaultServiceGoTSRPCProxy

func NewDefaultServiceGoTSRPCProxy(service Service) *ServiceGoTSRPCProxy

func NewServiceGoTSRPCProxy

func NewServiceGoTSRPCProxy(service Service, endpoint string) *ServiceGoTSRPCProxy

func (*ServiceGoTSRPCProxy) ServeHTTP

func (p *ServiceGoTSRPCProxy) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP exposes your service