gateway

package
v1.3.1 Latest Latest
Warning

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

 Go to latest Published: Aug 19, 2022 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 

type GatewayServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	GetEvaluations(context.Context, *GetEvaluationsRequest) (*GetEvaluationsResponse, error)
	GetEvaluation(context.Context, *GetEvaluationRequest) (*GetEvaluationResponse, error)
	RegisterEvents(context.Context, *RegisterEventsRequest) (*RegisterEventsResponse, error)
}

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 (m *GetEvaluationsResponse) GetState() feature.UserEvaluations_State

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 (m *RegisterEventsResponse) GetErrors() map[string]*RegisterEventsResponse_Error

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 (m *RegisterEventsResponse_Error) String() 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) GetEvaluation(ctx context.Context, req *GetEvaluationRequest) (*GetEvaluationResponse, error)

func (*UnimplementedGatewayServer) GetEvaluations 

func (*UnimplementedGatewayServer) GetEvaluations(ctx context.Context, req *GetEvaluationsRequest) (*GetEvaluationsResponse, error)

func (*UnimplementedGatewayServer) Ping 

func (*UnimplementedGatewayServer) Ping(ctx context.Context, req *PingRequest) (*PingResponse, error)

func (*UnimplementedGatewayServer) RegisterEvents 

func (*UnimplementedGatewayServer) RegisterEvents(ctx context.Context, req *RegisterEventsRequest) (*RegisterEventsResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.