pubsub

package
v0.0.0-...-d328d9e Latest Latest
Warning

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

 Go to latest Published: Aug 15, 2024 License: Apache-2.0 Imports: 7 Imported by: 10

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Experiment_Type_name = map[int32]string{
		0: "A_B",
		1: "Switchback",
	}
	Experiment_Type_value = map[string]int32{
		"A_B":        0,
		"Switchback": 1,
	}
)

Enum value maps for Experiment_Type.

View Source 
var (
	Experiment_Status_name = map[int32]string{
		0: "Active",
		1: "Inactive",
	}
	Experiment_Status_value = map[string]int32{
		"Active":   0,
		"Inactive": 1,
	}
)

Enum value maps for Experiment_Status.

View Source 
var (
	Experiment_Tier_name = map[int32]string{
		0: "Default",
		1: "Override",
	}
	Experiment_Tier_value = map[string]int32{
		"Default":  0,
		"Override": 1,
	}
)

Enum value maps for Experiment_Tier.

View Source 
var File_api_proto_experiment_proto protoreflect.FileDescriptor
View Source 
var File_api_proto_message_proto protoreflect.FileDescriptor
View Source 
var File_api_proto_settings_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Experiment 

type Experiment struct {
	Id         int64                                     `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	ProjectId  int64                                     `protobuf:"varint,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	Status     Experiment_Status                         `protobuf:"varint,3,opt,name=status,proto3,enum=pubsub.Experiment_Status" json:"status,omitempty"`
	Name       string                                    `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Segments   map[string]*segmenters.ListSegmenterValue `` /* 157-byte string literal not displayed */
	Type       Experiment_Type                           `protobuf:"varint,6,opt,name=type,proto3,enum=pubsub.Experiment_Type" json:"type,omitempty"`
	Interval   int32                                     `protobuf:"varint,7,opt,name=interval,proto3" json:"interval,omitempty"`
	Tier       Experiment_Tier                           `protobuf:"varint,8,opt,name=tier,proto3,enum=pubsub.Experiment_Tier" json:"tier,omitempty"`
	StartTime  *timestamppb.Timestamp                    `protobuf:"bytes,9,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime    *timestamppb.Timestamp                    `protobuf:"bytes,10,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Treatments []*ExperimentTreatment                    `protobuf:"bytes,11,rep,name=treatments,proto3" json:"treatments,omitempty"`
	UpdatedAt  *timestamppb.Timestamp                    `protobuf:"bytes,12,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Version    int64                                     `protobuf:"varint,13,opt,name=version,proto3" json:"version,omitempty"` // Experiment version
	// contains filtered or unexported fields
}

func (*Experiment) Descriptor deprecated 

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

Deprecated: Use Experiment.ProtoReflect.Descriptor instead.

func (*Experiment) GetEndTime 

func (x *Experiment) GetEndTime() *timestamppb.Timestamp

func (*Experiment) GetId 

func (x *Experiment) GetId() int64

func (*Experiment) GetInterval 

func (x *Experiment) GetInterval() int32

func (*Experiment) GetName 

func (x *Experiment) GetName() string

func (*Experiment) GetProjectId 

func (x *Experiment) GetProjectId() int64

func (*Experiment) GetSegments 

func (x *Experiment) GetSegments() map[string]*segmenters.ListSegmenterValue

func (*Experiment) GetStartTime 

func (x *Experiment) GetStartTime() *timestamppb.Timestamp

func (*Experiment) GetStatus 

func (x *Experiment) GetStatus() Experiment_Status

func (*Experiment) GetTier 

func (x *Experiment) GetTier() Experiment_Tier

func (*Experiment) GetTreatments 

func (x *Experiment) GetTreatments() []*ExperimentTreatment

func (*Experiment) GetType 

func (x *Experiment) GetType() Experiment_Type

func (*Experiment) GetUpdatedAt 

func (x *Experiment) GetUpdatedAt() *timestamppb.Timestamp

func (*Experiment) GetVersion 

func (x *Experiment) GetVersion() int64

func (*Experiment) ProtoMessage 

func (*Experiment) ProtoMessage()

func (*Experiment) ProtoReflect 

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

func (*Experiment) Reset 

func (x *Experiment) Reset()

func (*Experiment) String 

func (x *Experiment) String() string

type ExperimentCreated 

type ExperimentCreated struct {
	Experiment *Experiment `protobuf:"bytes,1,opt,name=experiment,proto3" json:"experiment,omitempty"`
	// contains filtered or unexported fields
}

func (*ExperimentCreated) Descriptor deprecated 

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

Deprecated: Use ExperimentCreated.ProtoReflect.Descriptor instead.

func (*ExperimentCreated) GetExperiment 

func (x *ExperimentCreated) GetExperiment() *Experiment

func (*ExperimentCreated) ProtoMessage 

func (*ExperimentCreated) ProtoMessage()

func (*ExperimentCreated) ProtoReflect 

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

func (*ExperimentCreated) Reset 

func (x *ExperimentCreated) Reset()

func (*ExperimentCreated) String 

func (x *ExperimentCreated) String() string

type ExperimentTreatment 

type ExperimentTreatment struct {
	Name    string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Traffic uint32           `protobuf:"varint,2,opt,name=traffic,proto3" json:"traffic,omitempty"`
	Config  *structpb.Struct `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*ExperimentTreatment) Descriptor deprecated 

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

Deprecated: Use ExperimentTreatment.ProtoReflect.Descriptor instead.

func (*ExperimentTreatment) GetConfig 

func (x *ExperimentTreatment) GetConfig() *structpb.Struct

func (*ExperimentTreatment) GetName 

func (x *ExperimentTreatment) GetName() string

func (*ExperimentTreatment) GetTraffic 

func (x *ExperimentTreatment) GetTraffic() uint32

func (*ExperimentTreatment) ProtoMessage 

func (*ExperimentTreatment) ProtoMessage()

func (*ExperimentTreatment) ProtoReflect 

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

func (*ExperimentTreatment) Reset 

func (x *ExperimentTreatment) Reset()

func (*ExperimentTreatment) String 

func (x *ExperimentTreatment) String() string

type ExperimentUpdated 

type ExperimentUpdated struct {
	Experiment *Experiment `protobuf:"bytes,1,opt,name=experiment,proto3" json:"experiment,omitempty"`
	// contains filtered or unexported fields
}

func (*ExperimentUpdated) Descriptor deprecated 

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

Deprecated: Use ExperimentUpdated.ProtoReflect.Descriptor instead.

func (*ExperimentUpdated) GetExperiment 

func (x *ExperimentUpdated) GetExperiment() *Experiment

func (*ExperimentUpdated) ProtoMessage 

func (*ExperimentUpdated) ProtoMessage()

func (*ExperimentUpdated) ProtoReflect 

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

func (*ExperimentUpdated) Reset 

func (x *ExperimentUpdated) Reset()

func (*ExperimentUpdated) String 

func (x *ExperimentUpdated) String() string

type ExperimentVariables 

type ExperimentVariables struct {
	Value []string `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

ExperimentVariables represents a combination of experiment variables name that a segmenter can derrive from

func (*ExperimentVariables) Descriptor deprecated 

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

Deprecated: Use ExperimentVariables.ProtoReflect.Descriptor instead.

func (*ExperimentVariables) GetValue 

func (x *ExperimentVariables) GetValue() []string

func (*ExperimentVariables) ProtoMessage 

func (*ExperimentVariables) ProtoMessage()

func (*ExperimentVariables) ProtoReflect 

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

func (*ExperimentVariables) Reset 

func (x *ExperimentVariables) Reset()

func (*ExperimentVariables) String 

func (x *ExperimentVariables) String() string

type Experiment_Status 

type Experiment_Status int32
const (
	Experiment_Active   Experiment_Status = 0
	Experiment_Inactive Experiment_Status = 1
)

func (Experiment_Status) Descriptor 

func (Experiment_Status) Descriptor() protoreflect.EnumDescriptor

func (Experiment_Status) Enum 

func (x Experiment_Status) Enum() *Experiment_Status

func (Experiment_Status) EnumDescriptor deprecated 

func (Experiment_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Experiment_Status.Descriptor instead.

func (Experiment_Status) Number 

func (x Experiment_Status) Number() protoreflect.EnumNumber

func (Experiment_Status) String 

func (x Experiment_Status) String() string

func (Experiment_Status) Type 

func (Experiment_Status) Type() protoreflect.EnumType

type Experiment_Tier 

type Experiment_Tier int32
const (
	Experiment_Default  Experiment_Tier = 0
	Experiment_Override Experiment_Tier = 1
)

func (Experiment_Tier) Descriptor 

func (Experiment_Tier) Descriptor() protoreflect.EnumDescriptor

func (Experiment_Tier) Enum 

func (x Experiment_Tier) Enum() *Experiment_Tier

func (Experiment_Tier) EnumDescriptor deprecated 

func (Experiment_Tier) EnumDescriptor() ([]byte, []int)

Deprecated: Use Experiment_Tier.Descriptor instead.

func (Experiment_Tier) Number 

func (x Experiment_Tier) Number() protoreflect.EnumNumber

func (Experiment_Tier) String 

func (x Experiment_Tier) String() string

func (Experiment_Tier) Type 

func (Experiment_Tier) Type() protoreflect.EnumType

type Experiment_Type 

type Experiment_Type int32
const (
	Experiment_A_B        Experiment_Type = 0
	Experiment_Switchback Experiment_Type = 1
)

func (Experiment_Type) Descriptor 

func (Experiment_Type) Descriptor() protoreflect.EnumDescriptor

func (Experiment_Type) Enum 

func (x Experiment_Type) Enum() *Experiment_Type

func (Experiment_Type) EnumDescriptor deprecated 

func (Experiment_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use Experiment_Type.Descriptor instead.

func (Experiment_Type) Number 

func (x Experiment_Type) Number() protoreflect.EnumNumber

func (Experiment_Type) String 

func (x Experiment_Type) String() string

func (Experiment_Type) Type 

func (Experiment_Type) Type() protoreflect.EnumType

type MessagePublishState 

type MessagePublishState struct {

	// Types that are assignable to Update:
	//
	//	*MessagePublishState_ExperimentCreated
	//	*MessagePublishState_ExperimentUpdated
	//	*MessagePublishState_ProjectSettingsCreated
	//	*MessagePublishState_ProjectSettingsUpdated
	//	*MessagePublishState_ProjectSegmenterCreated
	//	*MessagePublishState_ProjectSegmenterUpdated
	//	*MessagePublishState_ProjectSegmenterDeleted
	Update isMessagePublishState_Update `protobuf_oneof:"update"`
	// contains filtered or unexported fields
}

func (*MessagePublishState) Descriptor deprecated 

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

Deprecated: Use MessagePublishState.ProtoReflect.Descriptor instead.

func (*MessagePublishState) GetExperimentCreated 

func (x *MessagePublishState) GetExperimentCreated() *ExperimentCreated

func (*MessagePublishState) GetExperimentUpdated 

func (x *MessagePublishState) GetExperimentUpdated() *ExperimentUpdated

func (*MessagePublishState) GetProjectSegmenterCreated 

func (x *MessagePublishState) GetProjectSegmenterCreated() *segmenters.ProjectSegmenterCreated

func (*MessagePublishState) GetProjectSegmenterDeleted 

func (x *MessagePublishState) GetProjectSegmenterDeleted() *segmenters.ProjectSegmenterDeleted

func (*MessagePublishState) GetProjectSegmenterUpdated 

func (x *MessagePublishState) GetProjectSegmenterUpdated() *segmenters.ProjectSegmenterUpdated

func (*MessagePublishState) GetProjectSettingsCreated 

func (x *MessagePublishState) GetProjectSettingsCreated() *ProjectSettingsCreated

func (*MessagePublishState) GetProjectSettingsUpdated 

func (x *MessagePublishState) GetProjectSettingsUpdated() *ProjectSettingsUpdated

func (*MessagePublishState) GetUpdate 

func (m *MessagePublishState) GetUpdate() isMessagePublishState_Update

func (*MessagePublishState) ProtoMessage 

func (*MessagePublishState) ProtoMessage()

func (*MessagePublishState) ProtoReflect 

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

func (*MessagePublishState) Reset 

func (x *MessagePublishState) Reset()

func (*MessagePublishState) String 

func (x *MessagePublishState) String() string

type MessagePublishState_ExperimentCreated 

type MessagePublishState_ExperimentCreated struct {
	ExperimentCreated *ExperimentCreated `protobuf:"bytes,1,opt,name=experiment_created,json=experimentCreated,proto3,oneof"`
}

type MessagePublishState_ExperimentUpdated 

type MessagePublishState_ExperimentUpdated struct {
	ExperimentUpdated *ExperimentUpdated `protobuf:"bytes,2,opt,name=experiment_updated,json=experimentUpdated,proto3,oneof"`
}

type MessagePublishState_ProjectSegmenterCreated 

type MessagePublishState_ProjectSegmenterCreated struct {
	ProjectSegmenterCreated *segmenters.ProjectSegmenterCreated `protobuf:"bytes,5,opt,name=project_segmenter_created,json=projectSegmenterCreated,proto3,oneof"`
}

type MessagePublishState_ProjectSegmenterDeleted 

type MessagePublishState_ProjectSegmenterDeleted struct {
	ProjectSegmenterDeleted *segmenters.ProjectSegmenterDeleted `protobuf:"bytes,7,opt,name=project_segmenter_deleted,json=projectSegmenterDeleted,proto3,oneof"`
}

type MessagePublishState_ProjectSegmenterUpdated 

type MessagePublishState_ProjectSegmenterUpdated struct {
	ProjectSegmenterUpdated *segmenters.ProjectSegmenterUpdated `protobuf:"bytes,6,opt,name=project_segmenter_updated,json=projectSegmenterUpdated,proto3,oneof"`
}

type MessagePublishState_ProjectSettingsCreated 

type MessagePublishState_ProjectSettingsCreated struct {
	ProjectSettingsCreated *ProjectSettingsCreated `protobuf:"bytes,3,opt,name=project_settings_created,json=projectSettingsCreated,proto3,oneof"`
}

type MessagePublishState_ProjectSettingsUpdated 

type MessagePublishState_ProjectSettingsUpdated struct {
	ProjectSettingsUpdated *ProjectSettingsUpdated `protobuf:"bytes,4,opt,name=project_settings_updated,json=projectSettingsUpdated,proto3,oneof"`
}

type ProjectSettings 

type ProjectSettings struct {
	ProjectId            int64                  `protobuf:"varint,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	CreatedAt            *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Username             string                 `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty"`
	Passkey              string                 `protobuf:"bytes,5,opt,name=passkey,proto3" json:"passkey,omitempty"`
	EnableS2IdClustering bool                   `protobuf:"varint,6,opt,name=enable_s2id_clustering,json=enableS2idClustering,proto3" json:"enable_s2id_clustering,omitempty"`
	Segmenters           *Segmenters            `protobuf:"bytes,7,opt,name=segmenters,proto3" json:"segmenters,omitempty"`
	RandomizationKey     string                 `protobuf:"bytes,8,opt,name=randomization_key,json=randomizationKey,proto3" json:"randomization_key,omitempty"`
	// contains filtered or unexported fields
}

func (*ProjectSettings) Descriptor deprecated 

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

Deprecated: Use ProjectSettings.ProtoReflect.Descriptor instead.

func (*ProjectSettings) GetCreatedAt 

func (x *ProjectSettings) GetCreatedAt() *timestamppb.Timestamp

func (*ProjectSettings) GetEnableS2IdClustering 

func (x *ProjectSettings) GetEnableS2IdClustering() bool

func (*ProjectSettings) GetPasskey 

func (x *ProjectSettings) GetPasskey() string

func (*ProjectSettings) GetProjectId 

func (x *ProjectSettings) GetProjectId() int64

func (*ProjectSettings) GetRandomizationKey 

func (x *ProjectSettings) GetRandomizationKey() string

func (*ProjectSettings) GetSegmenters 

func (x *ProjectSettings) GetSegmenters() *Segmenters

func (*ProjectSettings) GetUpdatedAt 

func (x *ProjectSettings) GetUpdatedAt() *timestamppb.Timestamp

func (*ProjectSettings) GetUsername 

func (x *ProjectSettings) GetUsername() string

func (*ProjectSettings) ProtoMessage 

func (*ProjectSettings) ProtoMessage()

func (*ProjectSettings) ProtoReflect 

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

func (*ProjectSettings) Reset 

func (x *ProjectSettings) Reset()

func (*ProjectSettings) String 

func (x *ProjectSettings) String() string

type ProjectSettingsCreated 

type ProjectSettingsCreated struct {
	ProjectSettings *ProjectSettings `protobuf:"bytes,1,opt,name=project_settings,json=projectSettings,proto3" json:"project_settings,omitempty"`
	// contains filtered or unexported fields
}

func (*ProjectSettingsCreated) Descriptor deprecated 

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

Deprecated: Use ProjectSettingsCreated.ProtoReflect.Descriptor instead.

func (*ProjectSettingsCreated) GetProjectSettings 

func (x *ProjectSettingsCreated) GetProjectSettings() *ProjectSettings

func (*ProjectSettingsCreated) ProtoMessage 

func (*ProjectSettingsCreated) ProtoMessage()

func (*ProjectSettingsCreated) ProtoReflect 

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

func (*ProjectSettingsCreated) Reset 

func (x *ProjectSettingsCreated) Reset()

func (*ProjectSettingsCreated) String 

func (x *ProjectSettingsCreated) String() string

type ProjectSettingsUpdated 

type ProjectSettingsUpdated struct {
	ProjectSettings *ProjectSettings `protobuf:"bytes,1,opt,name=project_settings,json=projectSettings,proto3" json:"project_settings,omitempty"`
	// contains filtered or unexported fields
}

func (*ProjectSettingsUpdated) Descriptor deprecated 

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

Deprecated: Use ProjectSettingsUpdated.ProtoReflect.Descriptor instead.

func (*ProjectSettingsUpdated) GetProjectSettings 

func (x *ProjectSettingsUpdated) GetProjectSettings() *ProjectSettings

func (*ProjectSettingsUpdated) ProtoMessage 

func (*ProjectSettingsUpdated) ProtoMessage()

func (*ProjectSettingsUpdated) ProtoReflect 

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

func (*ProjectSettingsUpdated) Reset 

func (x *ProjectSettingsUpdated) Reset()

func (*ProjectSettingsUpdated) String 

func (x *ProjectSettingsUpdated) String() string

type Segmenters 

type Segmenters struct {
	Names     []string                        `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	Variables map[string]*ExperimentVariables `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

Project Segmenters which holds the list of segmenters, in priority order and the configured ExperimentVariables to derive the segmenter from

func (*Segmenters) Descriptor deprecated 

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

Deprecated: Use Segmenters.ProtoReflect.Descriptor instead.

func (*Segmenters) GetNames 

func (x *Segmenters) GetNames() []string

func (*Segmenters) GetVariables 

func (x *Segmenters) GetVariables() map[string]*ExperimentVariables

func (*Segmenters) ProtoMessage 

func (*Segmenters) ProtoMessage()

func (*Segmenters) ProtoReflect 

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

func (*Segmenters) Reset 

func (x *Segmenters) Reset()

func (*Segmenters) String 

func (x *Segmenters) String() string

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.