experimentservice

package
v0.13.1-0...-264b242 Latest Latest
Warning

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

Go to latest
Published: Nov 13, 2019 License: MIT Imports: 16 Imported by: 0

Documentation

Overview

Package experimentservice is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterExperimentServiceHandler

func RegisterExperimentServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterExperimentServiceHandler registers the http handlers for service ExperimentService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterExperimentServiceHandlerClient

func RegisterExperimentServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ExperimentServiceClient) error

RegisterExperimentServiceHandlerClient registers the http handlers for service ExperimentService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ExperimentServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ExperimentServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ExperimentServiceClient" to call the correct interceptors.

func RegisterExperimentServiceHandlerFromEndpoint

func RegisterExperimentServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterExperimentServiceHandlerFromEndpoint is same as RegisterExperimentServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterExperimentServiceHandlerServer

func RegisterExperimentServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ExperimentServiceServer) error

RegisterExperimentServiceHandlerServer registers the http handlers for service ExperimentService to "mux". UnaryRPC :call ExperimentServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterExperimentServiceServer

func RegisterExperimentServiceServer(s *grpc.Server, srv ExperimentServiceServer)

Types

type CreateExperimentServiceRequest

type CreateExperimentServiceRequest struct {
	Data                 *experiment.Experiment `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*CreateExperimentServiceRequest) Descriptor

func (*CreateExperimentServiceRequest) Descriptor() ([]byte, []int)

func (*CreateExperimentServiceRequest) GetData

func (*CreateExperimentServiceRequest) ProtoMessage

func (*CreateExperimentServiceRequest) ProtoMessage()

func (*CreateExperimentServiceRequest) Reset

func (m *CreateExperimentServiceRequest) Reset()

func (*CreateExperimentServiceRequest) String

func (*CreateExperimentServiceRequest) XXX_DiscardUnknown

func (m *CreateExperimentServiceRequest) XXX_DiscardUnknown()

func (*CreateExperimentServiceRequest) XXX_Marshal

func (m *CreateExperimentServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateExperimentServiceRequest) XXX_Merge

func (m *CreateExperimentServiceRequest) XXX_Merge(src proto.Message)

func (*CreateExperimentServiceRequest) XXX_Size

func (m *CreateExperimentServiceRequest) XXX_Size() int

func (*CreateExperimentServiceRequest) XXX_Unmarshal

func (m *CreateExperimentServiceRequest) XXX_Unmarshal(b []byte) error

type DeleteExperimentServiceRequest

type DeleteExperimentServiceRequest struct {
	Exp                  string       `protobuf:"bytes,1,opt,name=exp,proto3" json:"exp,omitempty"`
	Data                 *empty.Empty `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*DeleteExperimentServiceRequest) Descriptor

func (*DeleteExperimentServiceRequest) Descriptor() ([]byte, []int)

func (*DeleteExperimentServiceRequest) GetData

func (*DeleteExperimentServiceRequest) GetExp

func (*DeleteExperimentServiceRequest) ProtoMessage

func (*DeleteExperimentServiceRequest) ProtoMessage()

func (*DeleteExperimentServiceRequest) Reset

func (m *DeleteExperimentServiceRequest) Reset()

func (*DeleteExperimentServiceRequest) String

func (*DeleteExperimentServiceRequest) XXX_DiscardUnknown

func (m *DeleteExperimentServiceRequest) XXX_DiscardUnknown()

func (*DeleteExperimentServiceRequest) XXX_Marshal

func (m *DeleteExperimentServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteExperimentServiceRequest) XXX_Merge

func (m *DeleteExperimentServiceRequest) XXX_Merge(src proto.Message)

func (*DeleteExperimentServiceRequest) XXX_Size

func (m *DeleteExperimentServiceRequest) XXX_Size() int

func (*DeleteExperimentServiceRequest) XXX_Unmarshal

func (m *DeleteExperimentServiceRequest) XXX_Unmarshal(b []byte) error

type ExperimentServiceClient

type ExperimentServiceClient interface {
	// Creates a new Experiment
	CreateExperiment(ctx context.Context, in *CreateExperimentServiceRequest, opts ...grpc.CallOption) (*experiment.ExperimentEntity, error)
	// Delete a Experiment
	DeleteExperiment(ctx context.Context, in *DeleteExperimentServiceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// The Get method takes zero or more parameters, and returns a ExperimentEntity which contains a Experiment
	GetExperiment(ctx context.Context, in *GetExperimentServiceRequest, opts ...grpc.CallOption) (*experiment.ExperimentEntity, error)
	// The List method takes zero or more parameters as input, and returns a ExperimentCollection of ExperimentEntity that match the input parameters.
	ListExperiments(ctx context.Context, in *ListExperimentServiceRequest, opts ...grpc.CallOption) (*experiment.ExperimentCollection, error)
	// Releases experiment
	ReleaseExperiment(ctx context.Context, in *ReleaseExperimentServiceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Updates a Experiment, partial updates are supported
	UpdateExperiment(ctx context.Context, in *UpdateExperimentServiceRequest, opts ...grpc.CallOption) (*experiment.ExperimentEntity, error)
}

ExperimentServiceClient is the client API for ExperimentService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewExperimentServiceClient

func NewExperimentServiceClient(cc *grpc.ClientConn) ExperimentServiceClient

type ExperimentServiceServer

type ExperimentServiceServer interface {
	// Creates a new Experiment
	CreateExperiment(context.Context, *CreateExperimentServiceRequest) (*experiment.ExperimentEntity, error)
	// Delete a Experiment
	DeleteExperiment(context.Context, *DeleteExperimentServiceRequest) (*empty.Empty, error)
	// The Get method takes zero or more parameters, and returns a ExperimentEntity which contains a Experiment
	GetExperiment(context.Context, *GetExperimentServiceRequest) (*experiment.ExperimentEntity, error)
	// The List method takes zero or more parameters as input, and returns a ExperimentCollection of ExperimentEntity that match the input parameters.
	ListExperiments(context.Context, *ListExperimentServiceRequest) (*experiment.ExperimentCollection, error)
	// Releases experiment
	ReleaseExperiment(context.Context, *ReleaseExperimentServiceRequest) (*empty.Empty, error)
	// Updates a Experiment, partial updates are supported
	UpdateExperiment(context.Context, *UpdateExperimentServiceRequest) (*experiment.ExperimentEntity, error)
}

ExperimentServiceServer is the server API for ExperimentService service.

type GetExperimentServiceRequest

type GetExperimentServiceRequest struct {
	Exp                  string   `protobuf:"bytes,1,opt,name=exp,proto3" json:"exp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetExperimentServiceRequest) Descriptor

func (*GetExperimentServiceRequest) Descriptor() ([]byte, []int)

func (*GetExperimentServiceRequest) GetExp

func (m *GetExperimentServiceRequest) GetExp() string

func (*GetExperimentServiceRequest) ProtoMessage

func (*GetExperimentServiceRequest) ProtoMessage()

func (*GetExperimentServiceRequest) Reset

func (m *GetExperimentServiceRequest) Reset()

func (*GetExperimentServiceRequest) String

func (m *GetExperimentServiceRequest) String() string

func (*GetExperimentServiceRequest) XXX_DiscardUnknown

func (m *GetExperimentServiceRequest) XXX_DiscardUnknown()

func (*GetExperimentServiceRequest) XXX_Marshal

func (m *GetExperimentServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetExperimentServiceRequest) XXX_Merge

func (m *GetExperimentServiceRequest) XXX_Merge(src proto.Message)

func (*GetExperimentServiceRequest) XXX_Size

func (m *GetExperimentServiceRequest) XXX_Size() int

func (*GetExperimentServiceRequest) XXX_Unmarshal

func (m *GetExperimentServiceRequest) XXX_Unmarshal(b []byte) error

type ListExperimentServiceRequest

type ListExperimentServiceRequest struct {
	//Partial representation, fields=id,name
	Fields string `protobuf:"bytes,1,opt,name=fields,proto3" json:"fields,omitempty"`
	//*
	// Sort fields, comma separated list for the ordering
	// use **?filter=-display_name** with a dash to sort descending
	// use **?filter=display_name** to sort ascending
	OrderBy string `protobuf:"bytes,2,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	//Filter
	Filter string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	//Page number for paginated content. Tipp: follow the HATEOAS next, prev,...
	Page int32 `protobuf:"varint,4,opt,name=page,proto3" json:"page,omitempty"`
	//Number of elements to return per page
	Limit int32 `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	//https://cloud.google.com/apis/design/design_patterns#resource_view
	View string `protobuf:"bytes,8,opt,name=view,proto3" json:"view,omitempty"`
	//Query term to search a experiment
	Q                    string   `protobuf:"bytes,11,opt,name=q,proto3" json:"q,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListExperimentServiceRequest) Descriptor

func (*ListExperimentServiceRequest) Descriptor() ([]byte, []int)

func (*ListExperimentServiceRequest) GetFields

func (m *ListExperimentServiceRequest) GetFields() string

func (*ListExperimentServiceRequest) GetFilter

func (m *ListExperimentServiceRequest) GetFilter() string

func (*ListExperimentServiceRequest) GetLimit

func (m *ListExperimentServiceRequest) GetLimit() int32

func (*ListExperimentServiceRequest) GetOrderBy

func (m *ListExperimentServiceRequest) GetOrderBy() string

func (*ListExperimentServiceRequest) GetPage

func (m *ListExperimentServiceRequest) GetPage() int32

func (*ListExperimentServiceRequest) GetQ

func (*ListExperimentServiceRequest) GetView

func (m *ListExperimentServiceRequest) GetView() string

func (*ListExperimentServiceRequest) ProtoMessage

func (*ListExperimentServiceRequest) ProtoMessage()

func (*ListExperimentServiceRequest) Reset

func (m *ListExperimentServiceRequest) Reset()

func (*ListExperimentServiceRequest) String

func (*ListExperimentServiceRequest) XXX_DiscardUnknown

func (m *ListExperimentServiceRequest) XXX_DiscardUnknown()

func (*ListExperimentServiceRequest) XXX_Marshal

func (m *ListExperimentServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListExperimentServiceRequest) XXX_Merge

func (m *ListExperimentServiceRequest) XXX_Merge(src proto.Message)

func (*ListExperimentServiceRequest) XXX_Size

func (m *ListExperimentServiceRequest) XXX_Size() int

func (*ListExperimentServiceRequest) XXX_Unmarshal

func (m *ListExperimentServiceRequest) XXX_Unmarshal(b []byte) error

type ReleaseExperimentServiceRequest

type ReleaseExperimentServiceRequest struct {
	Data                 *experiment.ExperimentEntity `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*ReleaseExperimentServiceRequest) Descriptor

func (*ReleaseExperimentServiceRequest) Descriptor() ([]byte, []int)

func (*ReleaseExperimentServiceRequest) GetData

func (*ReleaseExperimentServiceRequest) ProtoMessage

func (*ReleaseExperimentServiceRequest) ProtoMessage()

func (*ReleaseExperimentServiceRequest) Reset

func (*ReleaseExperimentServiceRequest) String

func (*ReleaseExperimentServiceRequest) XXX_DiscardUnknown

func (m *ReleaseExperimentServiceRequest) XXX_DiscardUnknown()

func (*ReleaseExperimentServiceRequest) XXX_Marshal

func (m *ReleaseExperimentServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReleaseExperimentServiceRequest) XXX_Merge

func (m *ReleaseExperimentServiceRequest) XXX_Merge(src proto.Message)

func (*ReleaseExperimentServiceRequest) XXX_Size

func (m *ReleaseExperimentServiceRequest) XXX_Size() int

func (*ReleaseExperimentServiceRequest) XXX_Unmarshal

func (m *ReleaseExperimentServiceRequest) XXX_Unmarshal(b []byte) error

type UnimplementedExperimentServiceServer

type UnimplementedExperimentServiceServer struct {
}

UnimplementedExperimentServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedExperimentServiceServer) CreateExperiment

func (*UnimplementedExperimentServiceServer) DeleteExperiment

func (*UnimplementedExperimentServiceServer) GetExperiment

func (*UnimplementedExperimentServiceServer) ListExperiments

func (*UnimplementedExperimentServiceServer) ReleaseExperiment

func (*UnimplementedExperimentServiceServer) UpdateExperiment

type UpdateExperimentServiceRequest

type UpdateExperimentServiceRequest struct {
	Exp                  string                 `protobuf:"bytes,1,opt,name=exp,proto3" json:"exp,omitempty"`
	Data                 *experiment.Experiment `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*UpdateExperimentServiceRequest) Descriptor

func (*UpdateExperimentServiceRequest) Descriptor() ([]byte, []int)

func (*UpdateExperimentServiceRequest) GetData

func (*UpdateExperimentServiceRequest) GetExp

func (*UpdateExperimentServiceRequest) ProtoMessage

func (*UpdateExperimentServiceRequest) ProtoMessage()

func (*UpdateExperimentServiceRequest) Reset

func (m *UpdateExperimentServiceRequest) Reset()

func (*UpdateExperimentServiceRequest) String

func (*UpdateExperimentServiceRequest) XXX_DiscardUnknown

func (m *UpdateExperimentServiceRequest) XXX_DiscardUnknown()

func (*UpdateExperimentServiceRequest) XXX_Marshal

func (m *UpdateExperimentServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateExperimentServiceRequest) XXX_Merge

func (m *UpdateExperimentServiceRequest) XXX_Merge(src proto.Message)

func (*UpdateExperimentServiceRequest) XXX_Size

func (m *UpdateExperimentServiceRequest) XXX_Size() int

func (*UpdateExperimentServiceRequest) XXX_Unmarshal

func (m *UpdateExperimentServiceRequest) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL