gateway

package
v0.0.0-...-0d6d9b2 Latest Latest
Warning

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

Go to latest
Published: Apr 26, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_proto_gateway_service_proto protoreflect.FileDescriptor

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)
	Track(ctx context.Context, in *TrackRequest, opts ...grpc.CallOption) (*TrackResponse, 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.ClientConnInterface) 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"`
	User       *user.User      `protobuf:"bytes,2,opt,name=user,proto3" json:"user"`
	FeatureId  string          `protobuf:"bytes,3,opt,name=feature_id,json=featureId,proto3" json:"feature_id"`
	SourceId   client.SourceId `protobuf:"varint,4,opt,name=source_id,json=sourceId,proto3,enum=bucketeer.event.client.SourceId" json:"source_id"`
	SdkVersion string          `protobuf:"bytes,5,opt,name=sdk_version,json=sdkVersion,proto3" json:"sdk_version"`
	// contains filtered or unexported fields
}

func (*GetEvaluationRequest) Descriptor deprecated

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

Deprecated: Use GetEvaluationRequest.ProtoReflect.Descriptor instead.

func (*GetEvaluationRequest) GetFeatureId

func (x *GetEvaluationRequest) GetFeatureId() string

func (*GetEvaluationRequest) GetSdkVersion

func (x *GetEvaluationRequest) GetSdkVersion() string

func (*GetEvaluationRequest) GetSourceId

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

func (*GetEvaluationRequest) GetTag

func (x *GetEvaluationRequest) GetTag() string

func (*GetEvaluationRequest) GetUser

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

func (*GetEvaluationRequest) ProtoMessage

func (*GetEvaluationRequest) ProtoMessage()

func (*GetEvaluationRequest) ProtoReflect

func (x *GetEvaluationRequest) ProtoReflect() protoreflect.Message

func (*GetEvaluationRequest) Reset

func (x *GetEvaluationRequest) Reset()

func (*GetEvaluationRequest) String

func (x *GetEvaluationRequest) String() string

type GetEvaluationResponse

type GetEvaluationResponse struct {
	Evaluation *feature.Evaluation `protobuf:"bytes,1,opt,name=evaluation,proto3" json:"evaluation"`
	// contains filtered or unexported fields
}

func (*GetEvaluationResponse) Descriptor deprecated

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

Deprecated: Use GetEvaluationResponse.ProtoReflect.Descriptor instead.

func (*GetEvaluationResponse) GetEvaluation

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

func (*GetEvaluationResponse) ProtoMessage

func (*GetEvaluationResponse) ProtoMessage()

func (*GetEvaluationResponse) ProtoReflect

func (x *GetEvaluationResponse) ProtoReflect() protoreflect.Message

func (*GetEvaluationResponse) Reset

func (x *GetEvaluationResponse) Reset()

func (*GetEvaluationResponse) String

func (x *GetEvaluationResponse) String() string

type GetEvaluationsRequest

type GetEvaluationsRequest struct {
	Tag               string     `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag"`
	User              *user.User `protobuf:"bytes,2,opt,name=user,proto3" json:"user"`
	UserEvaluationsId string     `protobuf:"bytes,3,opt,name=user_evaluations_id,json=userEvaluationsId,proto3" json:"user_evaluations_id"`
	// Deprecated: Do not use.
	FeatureId               string                                         `protobuf:"bytes,4,opt,name=feature_id,json=featureId,proto3" json:"feature_id"` // instead, use GetEvaluation API
	SourceId                client.SourceId                                `protobuf:"varint,5,opt,name=source_id,json=sourceId,proto3,enum=bucketeer.event.client.SourceId" json:"source_id"`
	UserEvaluationCondition *GetEvaluationsRequest_UserEvaluationCondition `protobuf:"bytes,6,opt,name=user_evaluation_condition,json=userEvaluationCondition,proto3" json:"user_evaluation_condition"`
	SdkVersion              string                                         `protobuf:"bytes,7,opt,name=sdk_version,json=sdkVersion,proto3" json:"sdk_version"`
	// contains filtered or unexported fields
}

func (*GetEvaluationsRequest) Descriptor deprecated

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

Deprecated: Use GetEvaluationsRequest.ProtoReflect.Descriptor instead.

func (*GetEvaluationsRequest) GetFeatureId deprecated

func (x *GetEvaluationsRequest) GetFeatureId() string

Deprecated: Do not use.

func (*GetEvaluationsRequest) GetSdkVersion

func (x *GetEvaluationsRequest) GetSdkVersion() string

func (*GetEvaluationsRequest) GetSourceId

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

func (*GetEvaluationsRequest) GetTag

func (x *GetEvaluationsRequest) GetTag() string

func (*GetEvaluationsRequest) GetUser

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

func (*GetEvaluationsRequest) GetUserEvaluationCondition

func (*GetEvaluationsRequest) GetUserEvaluationsId

func (x *GetEvaluationsRequest) GetUserEvaluationsId() string

func (*GetEvaluationsRequest) ProtoMessage

func (*GetEvaluationsRequest) ProtoMessage()

func (*GetEvaluationsRequest) ProtoReflect

func (x *GetEvaluationsRequest) ProtoReflect() protoreflect.Message

func (*GetEvaluationsRequest) Reset

func (x *GetEvaluationsRequest) Reset()

func (*GetEvaluationsRequest) String

func (x *GetEvaluationsRequest) String() string

type GetEvaluationsRequest_UserEvaluationCondition

type GetEvaluationsRequest_UserEvaluationCondition struct {
	EvaluatedAt           int64 `protobuf:"varint,1,opt,name=evaluated_at,json=evaluatedAt,proto3" json:"evaluated_at"`
	UserAttributesUpdated bool  `protobuf:"varint,2,opt,name=user_attributes_updated,json=userAttributesUpdated,proto3" json:"user_attributes_updated"`
	// contains filtered or unexported fields
}

func (*GetEvaluationsRequest_UserEvaluationCondition) Descriptor deprecated

Deprecated: Use GetEvaluationsRequest_UserEvaluationCondition.ProtoReflect.Descriptor instead.

func (*GetEvaluationsRequest_UserEvaluationCondition) GetEvaluatedAt

func (*GetEvaluationsRequest_UserEvaluationCondition) GetUserAttributesUpdated

func (x *GetEvaluationsRequest_UserEvaluationCondition) GetUserAttributesUpdated() bool

func (*GetEvaluationsRequest_UserEvaluationCondition) ProtoMessage

func (*GetEvaluationsRequest_UserEvaluationCondition) ProtoReflect

func (*GetEvaluationsRequest_UserEvaluationCondition) Reset

func (*GetEvaluationsRequest_UserEvaluationCondition) String

type GetEvaluationsResponse

type GetEvaluationsResponse struct {
	State             feature.UserEvaluations_State `protobuf:"varint,1,opt,name=state,proto3,enum=bucketeer.feature.UserEvaluations_State" json:"state"`
	Evaluations       *feature.UserEvaluations      `protobuf:"bytes,2,opt,name=evaluations,proto3" json:"evaluations"`
	UserEvaluationsId string                        `protobuf:"bytes,3,opt,name=user_evaluations_id,json=userEvaluationsId,proto3" json:"user_evaluations_id"`
	// contains filtered or unexported fields
}

func (*GetEvaluationsResponse) Descriptor deprecated

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

Deprecated: Use GetEvaluationsResponse.ProtoReflect.Descriptor instead.

func (*GetEvaluationsResponse) GetEvaluations

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

func (*GetEvaluationsResponse) GetState

func (*GetEvaluationsResponse) GetUserEvaluationsId

func (x *GetEvaluationsResponse) GetUserEvaluationsId() string

func (*GetEvaluationsResponse) ProtoMessage

func (*GetEvaluationsResponse) ProtoMessage()

func (*GetEvaluationsResponse) ProtoReflect

func (x *GetEvaluationsResponse) ProtoReflect() protoreflect.Message

func (*GetEvaluationsResponse) Reset

func (x *GetEvaluationsResponse) Reset()

func (*GetEvaluationsResponse) String

func (x *GetEvaluationsResponse) String() string

type PingRequest

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

func (*PingRequest) Descriptor deprecated

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) ProtoMessage

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect

func (x *PingRequest) ProtoReflect() protoreflect.Message

func (*PingRequest) Reset

func (x *PingRequest) Reset()

func (*PingRequest) String

func (x *PingRequest) String() string

type PingResponse

type PingResponse struct {
	Time int64 `protobuf:"varint,1,opt,name=time,proto3" json:"time"`
	// contains filtered or unexported fields
}

func (*PingResponse) Descriptor deprecated

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetTime

func (x *PingResponse) GetTime() int64

func (*PingResponse) ProtoMessage

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect

func (x *PingResponse) ProtoReflect() protoreflect.Message

func (*PingResponse) Reset

func (x *PingResponse) Reset()

func (*PingResponse) String

func (x *PingResponse) String() string

type RegisterEventsRequest

type RegisterEventsRequest struct {
	Events     []*client.Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events"`
	SdkVersion string          `protobuf:"bytes,2,opt,name=sdk_version,json=sdkVersion,proto3" json:"sdk_version"`
	SourceId   client.SourceId `protobuf:"varint,3,opt,name=source_id,json=sourceId,proto3,enum=bucketeer.event.client.SourceId" json:"source_id"`
	// contains filtered or unexported fields
}

func (*RegisterEventsRequest) Descriptor deprecated

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

Deprecated: Use RegisterEventsRequest.ProtoReflect.Descriptor instead.

func (*RegisterEventsRequest) GetEvents

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

func (*RegisterEventsRequest) GetSdkVersion

func (x *RegisterEventsRequest) GetSdkVersion() string

func (*RegisterEventsRequest) GetSourceId

func (x *RegisterEventsRequest) GetSourceId() client.SourceId

func (*RegisterEventsRequest) ProtoMessage

func (*RegisterEventsRequest) ProtoMessage()

func (*RegisterEventsRequest) ProtoReflect

func (x *RegisterEventsRequest) ProtoReflect() protoreflect.Message

func (*RegisterEventsRequest) Reset

func (x *RegisterEventsRequest) Reset()

func (*RegisterEventsRequest) String

func (x *RegisterEventsRequest) String() string

type RegisterEventsResponse

type RegisterEventsResponse struct {
	Errors map[string]*RegisterEventsResponse_Error `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RegisterEventsResponse) Descriptor deprecated

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

Deprecated: Use RegisterEventsResponse.ProtoReflect.Descriptor instead.

func (*RegisterEventsResponse) GetErrors

func (*RegisterEventsResponse) ProtoMessage

func (*RegisterEventsResponse) ProtoMessage()

func (*RegisterEventsResponse) ProtoReflect

func (x *RegisterEventsResponse) ProtoReflect() protoreflect.Message

func (*RegisterEventsResponse) Reset

func (x *RegisterEventsResponse) Reset()

func (*RegisterEventsResponse) String

func (x *RegisterEventsResponse) String() string

type RegisterEventsResponse_Error

type RegisterEventsResponse_Error struct {
	Retriable bool   `protobuf:"varint,1,opt,name=retriable,proto3" json:"retriable"`
	Message   string `protobuf:"bytes,2,opt,name=message,proto3" json:"message"`
	// contains filtered or unexported fields
}

func (*RegisterEventsResponse_Error) Descriptor deprecated

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

Deprecated: Use RegisterEventsResponse_Error.ProtoReflect.Descriptor instead.

func (*RegisterEventsResponse_Error) GetMessage

func (x *RegisterEventsResponse_Error) GetMessage() string

func (*RegisterEventsResponse_Error) GetRetriable

func (x *RegisterEventsResponse_Error) GetRetriable() bool

func (*RegisterEventsResponse_Error) ProtoMessage

func (*RegisterEventsResponse_Error) ProtoMessage()

func (*RegisterEventsResponse_Error) ProtoReflect

func (*RegisterEventsResponse_Error) Reset

func (x *RegisterEventsResponse_Error) Reset()

func (*RegisterEventsResponse_Error) String

type TrackRequest

type TrackRequest struct {
	Apikey    string  `protobuf:"bytes,1,opt,name=apikey,proto3" json:"apikey"`
	Userid    string  `protobuf:"bytes,2,opt,name=userid,proto3" json:"userid"`
	Goalid    string  `protobuf:"bytes,3,opt,name=goalid,proto3" json:"goalid"`
	Tag       string  `protobuf:"bytes,4,opt,name=tag,proto3" json:"tag"`
	Timestamp int64   `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp"`
	Value     float64 `protobuf:"fixed64,6,opt,name=value,proto3" json:"value"`
	// contains filtered or unexported fields
}

func (*TrackRequest) Descriptor deprecated

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

Deprecated: Use TrackRequest.ProtoReflect.Descriptor instead.

func (*TrackRequest) GetApikey

func (x *TrackRequest) GetApikey() string

func (*TrackRequest) GetGoalid

func (x *TrackRequest) GetGoalid() string

func (*TrackRequest) GetTag

func (x *TrackRequest) GetTag() string

func (*TrackRequest) GetTimestamp

func (x *TrackRequest) GetTimestamp() int64

func (*TrackRequest) GetUserid

func (x *TrackRequest) GetUserid() string

func (*TrackRequest) GetValue

func (x *TrackRequest) GetValue() float64

func (*TrackRequest) ProtoMessage

func (*TrackRequest) ProtoMessage()

func (*TrackRequest) ProtoReflect

func (x *TrackRequest) ProtoReflect() protoreflect.Message

func (*TrackRequest) Reset

func (x *TrackRequest) Reset()

func (*TrackRequest) String

func (x *TrackRequest) String() string

type TrackResponse

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

func (*TrackResponse) Descriptor deprecated

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

Deprecated: Use TrackResponse.ProtoReflect.Descriptor instead.

func (*TrackResponse) ProtoMessage

func (*TrackResponse) ProtoMessage()

func (*TrackResponse) ProtoReflect

func (x *TrackResponse) ProtoReflect() protoreflect.Message

func (*TrackResponse) Reset

func (x *TrackResponse) Reset()

func (*TrackResponse) String

func (x *TrackResponse) String() string

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

func (*UnimplementedGatewayServer) Track

Jump to

Keyboard shortcuts

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