gateway

package
Version: v1.3.0 Latest Latest
Warning

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

Go to latest
Published: Jun 10, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterGatewayServer

func RegisterGatewayServer(s *grpc.Server, srv GatewayServer)

Types

type GatewayClient

type GatewayClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	GetEvaluations(ctx context.Context, in *GetEvaluationsRequest, opts ...grpc.CallOption) (*GetEvaluationsResponse, error)
	GetEvaluation(ctx context.Context, in *GetEvaluationRequest, opts ...grpc.CallOption) (*GetEvaluationResponse, error)
	RegisterEvents(ctx context.Context, in *RegisterEventsRequest, opts ...grpc.CallOption) (*RegisterEventsResponse, error)
}

GatewayClient is the client API for Gateway service.

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

func NewGatewayClient

func NewGatewayClient(cc *grpc.ClientConn) GatewayClient

type GatewayServer

GatewayServer is the server API for Gateway service.

type GetEvaluationRequest

type GetEvaluationRequest struct {
	Tag                  string          `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	User                 *user.User      `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	FeatureId            string          `protobuf:"bytes,3,opt,name=feature_id,json=featureId,proto3" json:"feature_id,omitempty"`
	SourceId             client.SourceId `protobuf:"varint,4,opt,name=source_id,json=sourceId,proto3,enum=bucketeer.event.client.SourceId" json:"source_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetEvaluationRequest) Descriptor

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

func (*GetEvaluationRequest) GetFeatureId

func (m *GetEvaluationRequest) GetFeatureId() string

func (*GetEvaluationRequest) GetSourceId added in v1.3.0

func (m *GetEvaluationRequest) GetSourceId() client.SourceId

func (*GetEvaluationRequest) GetTag

func (m *GetEvaluationRequest) GetTag() string

func (*GetEvaluationRequest) GetUser

func (m *GetEvaluationRequest) GetUser() *user.User

func (*GetEvaluationRequest) ProtoMessage

func (*GetEvaluationRequest) ProtoMessage()

func (*GetEvaluationRequest) Reset

func (m *GetEvaluationRequest) Reset()

func (*GetEvaluationRequest) String

func (m *GetEvaluationRequest) String() string

func (*GetEvaluationRequest) XXX_DiscardUnknown

func (m *GetEvaluationRequest) XXX_DiscardUnknown()

func (*GetEvaluationRequest) XXX_Marshal

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

func (*GetEvaluationRequest) XXX_Merge

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

func (*GetEvaluationRequest) XXX_Size

func (m *GetEvaluationRequest) XXX_Size() int

func (*GetEvaluationRequest) XXX_Unmarshal

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

type GetEvaluationResponse

type GetEvaluationResponse struct {
	Evaluation           *feature.Evaluation `protobuf:"bytes,1,opt,name=evaluation,proto3" json:"evaluation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*GetEvaluationResponse) Descriptor

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

func (*GetEvaluationResponse) GetEvaluation

func (m *GetEvaluationResponse) GetEvaluation() *feature.Evaluation

func (*GetEvaluationResponse) ProtoMessage

func (*GetEvaluationResponse) ProtoMessage()

func (*GetEvaluationResponse) Reset

func (m *GetEvaluationResponse) Reset()

func (*GetEvaluationResponse) String

func (m *GetEvaluationResponse) String() string

func (*GetEvaluationResponse) XXX_DiscardUnknown

func (m *GetEvaluationResponse) XXX_DiscardUnknown()

func (*GetEvaluationResponse) XXX_Marshal

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

func (*GetEvaluationResponse) XXX_Merge

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

func (*GetEvaluationResponse) XXX_Size

func (m *GetEvaluationResponse) XXX_Size() int

func (*GetEvaluationResponse) XXX_Unmarshal

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

type GetEvaluationsRequest

type GetEvaluationsRequest struct {
	Tag                  string          `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	User                 *user.User      `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	UserEvaluationsId    string          `protobuf:"bytes,3,opt,name=user_evaluations_id,json=userEvaluationsId,proto3" json:"user_evaluations_id,omitempty"`
	FeatureId            string          `protobuf:"bytes,4,opt,name=feature_id,json=featureId,proto3" json:"feature_id,omitempty"` // Deprecated: Do not use.
	SourceId             client.SourceId `protobuf:"varint,5,opt,name=source_id,json=sourceId,proto3,enum=bucketeer.event.client.SourceId" json:"source_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetEvaluationsRequest) Descriptor

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

func (*GetEvaluationsRequest) GetFeatureId deprecated

func (m *GetEvaluationsRequest) GetFeatureId() string

Deprecated: Do not use.

func (*GetEvaluationsRequest) GetSourceId added in v1.3.0

func (m *GetEvaluationsRequest) GetSourceId() client.SourceId

func (*GetEvaluationsRequest) GetTag

func (m *GetEvaluationsRequest) GetTag() string

func (*GetEvaluationsRequest) GetUser

func (m *GetEvaluationsRequest) GetUser() *user.User

func (*GetEvaluationsRequest) GetUserEvaluationsId

func (m *GetEvaluationsRequest) GetUserEvaluationsId() string

func (*GetEvaluationsRequest) ProtoMessage

func (*GetEvaluationsRequest) ProtoMessage()

func (*GetEvaluationsRequest) Reset

func (m *GetEvaluationsRequest) Reset()

func (*GetEvaluationsRequest) String

func (m *GetEvaluationsRequest) String() string

func (*GetEvaluationsRequest) XXX_DiscardUnknown

func (m *GetEvaluationsRequest) XXX_DiscardUnknown()

func (*GetEvaluationsRequest) XXX_Marshal

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

func (*GetEvaluationsRequest) XXX_Merge

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

func (*GetEvaluationsRequest) XXX_Size

func (m *GetEvaluationsRequest) XXX_Size() int

func (*GetEvaluationsRequest) XXX_Unmarshal

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

type GetEvaluationsResponse

type GetEvaluationsResponse struct {
	State                feature.UserEvaluations_State `protobuf:"varint,1,opt,name=state,proto3,enum=bucketeer.feature.UserEvaluations_State" json:"state,omitempty"`
	Evaluations          *feature.UserEvaluations      `protobuf:"bytes,2,opt,name=evaluations,proto3" json:"evaluations,omitempty"`
	UserEvaluationsId    string                        `protobuf:"bytes,3,opt,name=user_evaluations_id,json=userEvaluationsId,proto3" json:"user_evaluations_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*GetEvaluationsResponse) Descriptor

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

func (*GetEvaluationsResponse) GetEvaluations

func (m *GetEvaluationsResponse) GetEvaluations() *feature.UserEvaluations

func (*GetEvaluationsResponse) GetState

func (*GetEvaluationsResponse) GetUserEvaluationsId

func (m *GetEvaluationsResponse) GetUserEvaluationsId() string

func (*GetEvaluationsResponse) ProtoMessage

func (*GetEvaluationsResponse) ProtoMessage()

func (*GetEvaluationsResponse) Reset

func (m *GetEvaluationsResponse) Reset()

func (*GetEvaluationsResponse) String

func (m *GetEvaluationsResponse) String() string

func (*GetEvaluationsResponse) XXX_DiscardUnknown

func (m *GetEvaluationsResponse) XXX_DiscardUnknown()

func (*GetEvaluationsResponse) XXX_Marshal

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

func (*GetEvaluationsResponse) XXX_Merge

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

func (*GetEvaluationsResponse) XXX_Size

func (m *GetEvaluationsResponse) XXX_Size() int

func (*GetEvaluationsResponse) XXX_Unmarshal

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

type PingRequest

type PingRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PingRequest) Descriptor

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

func (*PingRequest) ProtoMessage

func (*PingRequest) ProtoMessage()

func (*PingRequest) Reset

func (m *PingRequest) Reset()

func (*PingRequest) String

func (m *PingRequest) String() string

func (*PingRequest) XXX_DiscardUnknown

func (m *PingRequest) XXX_DiscardUnknown()

func (*PingRequest) XXX_Marshal

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

func (*PingRequest) XXX_Merge

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

func (*PingRequest) XXX_Size

func (m *PingRequest) XXX_Size() int

func (*PingRequest) XXX_Unmarshal

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

type PingResponse

type PingResponse struct {
	Time                 int64    `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PingResponse) Descriptor

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

func (*PingResponse) GetTime

func (m *PingResponse) GetTime() int64

func (*PingResponse) ProtoMessage

func (*PingResponse) ProtoMessage()

func (*PingResponse) Reset

func (m *PingResponse) Reset()

func (*PingResponse) String

func (m *PingResponse) String() string

func (*PingResponse) XXX_DiscardUnknown

func (m *PingResponse) XXX_DiscardUnknown()

func (*PingResponse) XXX_Marshal

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

func (*PingResponse) XXX_Merge

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

func (*PingResponse) XXX_Size

func (m *PingResponse) XXX_Size() int

func (*PingResponse) XXX_Unmarshal

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

type RegisterEventsRequest

type RegisterEventsRequest struct {
	Events               []*client.Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*RegisterEventsRequest) Descriptor

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

func (*RegisterEventsRequest) GetEvents

func (m *RegisterEventsRequest) GetEvents() []*client.Event

func (*RegisterEventsRequest) ProtoMessage

func (*RegisterEventsRequest) ProtoMessage()

func (*RegisterEventsRequest) Reset

func (m *RegisterEventsRequest) Reset()

func (*RegisterEventsRequest) String

func (m *RegisterEventsRequest) String() string

func (*RegisterEventsRequest) XXX_DiscardUnknown

func (m *RegisterEventsRequest) XXX_DiscardUnknown()

func (*RegisterEventsRequest) XXX_Marshal

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

func (*RegisterEventsRequest) XXX_Merge

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

func (*RegisterEventsRequest) XXX_Size

func (m *RegisterEventsRequest) XXX_Size() int

func (*RegisterEventsRequest) XXX_Unmarshal

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

type RegisterEventsResponse

type RegisterEventsResponse struct {
	Errors               map[string]*RegisterEventsResponse_Error `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                 `json:"-"`
	XXX_unrecognized     []byte                                   `json:"-"`
	XXX_sizecache        int32                                    `json:"-"`
}

func (*RegisterEventsResponse) Descriptor

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

func (*RegisterEventsResponse) GetErrors

func (*RegisterEventsResponse) ProtoMessage

func (*RegisterEventsResponse) ProtoMessage()

func (*RegisterEventsResponse) Reset

func (m *RegisterEventsResponse) Reset()

func (*RegisterEventsResponse) String

func (m *RegisterEventsResponse) String() string

func (*RegisterEventsResponse) XXX_DiscardUnknown

func (m *RegisterEventsResponse) XXX_DiscardUnknown()

func (*RegisterEventsResponse) XXX_Marshal

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

func (*RegisterEventsResponse) XXX_Merge

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

func (*RegisterEventsResponse) XXX_Size

func (m *RegisterEventsResponse) XXX_Size() int

func (*RegisterEventsResponse) XXX_Unmarshal

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

type RegisterEventsResponse_Error

type RegisterEventsResponse_Error struct {
	Retriable            bool     `protobuf:"varint,1,opt,name=retriable,proto3" json:"retriable,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterEventsResponse_Error) Descriptor

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

func (*RegisterEventsResponse_Error) GetMessage

func (m *RegisterEventsResponse_Error) GetMessage() string

func (*RegisterEventsResponse_Error) GetRetriable

func (m *RegisterEventsResponse_Error) GetRetriable() bool

func (*RegisterEventsResponse_Error) ProtoMessage

func (*RegisterEventsResponse_Error) ProtoMessage()

func (*RegisterEventsResponse_Error) Reset

func (m *RegisterEventsResponse_Error) Reset()

func (*RegisterEventsResponse_Error) String

func (*RegisterEventsResponse_Error) XXX_DiscardUnknown

func (m *RegisterEventsResponse_Error) XXX_DiscardUnknown()

func (*RegisterEventsResponse_Error) XXX_Marshal

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

func (*RegisterEventsResponse_Error) XXX_Merge

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

func (*RegisterEventsResponse_Error) XXX_Size

func (m *RegisterEventsResponse_Error) XXX_Size() int

func (*RegisterEventsResponse_Error) XXX_Unmarshal

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

type UnimplementedGatewayServer

type UnimplementedGatewayServer struct {
}

UnimplementedGatewayServer can be embedded to have forward compatible implementations.

func (*UnimplementedGatewayServer) GetEvaluation

func (*UnimplementedGatewayServer) GetEvaluations

func (*UnimplementedGatewayServer) Ping

func (*UnimplementedGatewayServer) RegisterEvents

Source Files

Jump to

Keyboard shortcuts

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