GeneralGoWorkflows

package
v0.0.6 Latest Latest
Warning

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

 Go to latest Published: Mar 21, 2023 License: Apache-2.0 Imports: 12 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_Workflows_GeneralGoWorkflows_general_go_workflows_proto protoreflect.FileDescriptor

Functions

func RegisterGeneralGoWorkflowsServer 

func RegisterGeneralGoWorkflowsServer(s *grpc.Server, srv GeneralGoWorkflowsServer)

Types

type CreatePartitionsRequest 

type CreatePartitionsRequest struct {
	TableName    string `protobuf:"bytes,1,opt,name=tableName,proto3" json:"tableName,omitempty"`
	DatabaseName string `protobuf:"bytes,2,opt,name=databaseName,proto3" json:"databaseName,omitempty"`
	Bucket       string `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	NumberOfDays int64  `protobuf:"varint,4,opt,name=numberOfDays,proto3" json:"numberOfDays,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePartitionsRequest) Descriptor deprecated 

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

Deprecated: Use CreatePartitionsRequest.ProtoReflect.Descriptor instead.

func (*CreatePartitionsRequest) GetBucket 

func (x *CreatePartitionsRequest) GetBucket() string

func (*CreatePartitionsRequest) GetDatabaseName 

func (x *CreatePartitionsRequest) GetDatabaseName() string

func (*CreatePartitionsRequest) GetNumberOfDays 

func (x *CreatePartitionsRequest) GetNumberOfDays() int64

func (*CreatePartitionsRequest) GetTableName 

func (x *CreatePartitionsRequest) GetTableName() string

func (*CreatePartitionsRequest) ProtoMessage 

func (*CreatePartitionsRequest) ProtoMessage()

func (*CreatePartitionsRequest) ProtoReflect 

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

func (*CreatePartitionsRequest) Reset 

func (x *CreatePartitionsRequest) Reset()

func (*CreatePartitionsRequest) String 

func (x *CreatePartitionsRequest) String() string

type CreatePartitionsResponse 

type CreatePartitionsResponse struct {
	Status GoCommon.ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=farm.nurture.core.contracts.common.ResponseStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePartitionsResponse) Descriptor deprecated 

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

Deprecated: Use CreatePartitionsResponse.ProtoReflect.Descriptor instead.

func (*CreatePartitionsResponse) GetStatus 

func (x *CreatePartitionsResponse) GetStatus() GoCommon.ResponseStatus

func (*CreatePartitionsResponse) ProtoMessage 

func (*CreatePartitionsResponse) ProtoMessage()

func (*CreatePartitionsResponse) ProtoReflect 

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

func (*CreatePartitionsResponse) Reset 

func (x *CreatePartitionsResponse) Reset()

func (*CreatePartitionsResponse) String 

func (x *CreatePartitionsResponse) String() string

type ExecuteCampaignRequest 

type ExecuteCampaignRequest struct {
	CampaignId           int64                         `protobuf:"varint,1,opt,name=campaign_id,json=campaignId,proto3" json:"campaign_id,omitempty"`
	CampaignScheduleType GoCommon.CampaignScheduleType `` /* 155-byte string literal not displayed */
	InactionDuration     *durationpb.Duration          `protobuf:"bytes,3,opt,name=inactionDuration,proto3" json:"inactionDuration,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteCampaignRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteCampaignRequest.ProtoReflect.Descriptor instead.

func (*ExecuteCampaignRequest) GetCampaignId 

func (x *ExecuteCampaignRequest) GetCampaignId() int64

func (*ExecuteCampaignRequest) GetCampaignScheduleType 

func (x *ExecuteCampaignRequest) GetCampaignScheduleType() GoCommon.CampaignScheduleType

func (*ExecuteCampaignRequest) GetInactionDuration 

func (x *ExecuteCampaignRequest) GetInactionDuration() *durationpb.Duration

func (*ExecuteCampaignRequest) ProtoMessage 

func (*ExecuteCampaignRequest) ProtoMessage()

func (*ExecuteCampaignRequest) ProtoReflect 

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

func (*ExecuteCampaignRequest) Reset 

func (x *ExecuteCampaignRequest) Reset()

func (*ExecuteCampaignRequest) String 

func (x *ExecuteCampaignRequest) String() string

type ExecuteCampaignResponse 

type ExecuteCampaignResponse struct {
	Status GoCommon.ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=farm.nurture.core.contracts.common.ResponseStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteCampaignResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteCampaignResponse.ProtoReflect.Descriptor instead.

func (*ExecuteCampaignResponse) GetStatus 

func (x *ExecuteCampaignResponse) GetStatus() GoCommon.ResponseStatus

func (*ExecuteCampaignResponse) ProtoMessage 

func (*ExecuteCampaignResponse) ProtoMessage()

func (*ExecuteCampaignResponse) ProtoReflect 

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

func (*ExecuteCampaignResponse) Reset 

func (x *ExecuteCampaignResponse) Reset()

func (*ExecuteCampaignResponse) String 

func (x *ExecuteCampaignResponse) String() string

type ExecuteUserJourneyCampaignRequest 

type ExecuteUserJourneyCampaignRequest struct {
	RequestHeaders     *GoCommon.RequestHeaders `protobuf:"bytes,1,opt,name=requestHeaders,proto3" json:"requestHeaders,omitempty"`
	CampaignId         int64                    `protobuf:"varint,2,opt,name=campaignId,proto3" json:"campaignId,omitempty"`
	EngagementVertexId int64                    `protobuf:"varint,3,opt,name=engagementVertexId,proto3" json:"engagementVertexId,omitempty"`
	ReferenceId        string                   `protobuf:"bytes,4,opt,name=referenceId,proto3" json:"referenceId,omitempty"`
	WaitDuration       *durationpb.Duration     `protobuf:"bytes,5,opt,name=waitDuration,proto3" json:"waitDuration,omitempty"`
	Unused             int64                    `protobuf:"varint,6,opt,name=unused,proto3" json:"unused,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteUserJourneyCampaignRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteUserJourneyCampaignRequest.ProtoReflect.Descriptor instead.

func (*ExecuteUserJourneyCampaignRequest) GetCampaignId 

func (x *ExecuteUserJourneyCampaignRequest) GetCampaignId() int64

func (*ExecuteUserJourneyCampaignRequest) GetEngagementVertexId 

func (x *ExecuteUserJourneyCampaignRequest) GetEngagementVertexId() int64

func (*ExecuteUserJourneyCampaignRequest) GetReferenceId 

func (x *ExecuteUserJourneyCampaignRequest) GetReferenceId() string

func (*ExecuteUserJourneyCampaignRequest) GetRequestHeaders 

func (x *ExecuteUserJourneyCampaignRequest) GetRequestHeaders() *GoCommon.RequestHeaders

func (*ExecuteUserJourneyCampaignRequest) GetUnused added in v0.0.4 

func (x *ExecuteUserJourneyCampaignRequest) GetUnused() int64

func (*ExecuteUserJourneyCampaignRequest) GetWaitDuration 

func (x *ExecuteUserJourneyCampaignRequest) GetWaitDuration() *durationpb.Duration

func (*ExecuteUserJourneyCampaignRequest) ProtoMessage 

func (*ExecuteUserJourneyCampaignRequest) ProtoMessage()

func (*ExecuteUserJourneyCampaignRequest) ProtoReflect 

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

func (*ExecuteUserJourneyCampaignRequest) Reset 

func (x *ExecuteUserJourneyCampaignRequest) Reset()

func (*ExecuteUserJourneyCampaignRequest) String 

func (x *ExecuteUserJourneyCampaignRequest) String() string

type ExecuteUserJourneyCampaignResponse 

type ExecuteUserJourneyCampaignResponse struct {
	Status GoCommon.ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=farm.nurture.core.contracts.common.ResponseStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteUserJourneyCampaignResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteUserJourneyCampaignResponse.ProtoReflect.Descriptor instead.

func (*ExecuteUserJourneyCampaignResponse) GetStatus 

func (x *ExecuteUserJourneyCampaignResponse) GetStatus() GoCommon.ResponseStatus

func (*ExecuteUserJourneyCampaignResponse) ProtoMessage 

func (*ExecuteUserJourneyCampaignResponse) ProtoMessage()

func (*ExecuteUserJourneyCampaignResponse) ProtoReflect 

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

func (*ExecuteUserJourneyCampaignResponse) Reset 

func (x *ExecuteUserJourneyCampaignResponse) Reset()

func (*ExecuteUserJourneyCampaignResponse) String 

func (x *ExecuteUserJourneyCampaignResponse) String() string

type GeneralGoWorkflowsClient 

type GeneralGoWorkflowsClient interface {
	ExecuteCampaign(ctx context.Context, in *ExecuteCampaignRequest, opts ...grpc.CallOption) (*ExecuteCampaignResponse, error)
	ExecuteUserJourneyCampaign(ctx context.Context, in *ExecuteUserJourneyCampaignRequest, opts ...grpc.CallOption) (*ExecuteUserJourneyCampaignResponse, error)
	CreatePartitions(ctx context.Context, in *CreatePartitionsRequest, opts ...grpc.CallOption) (*CreatePartitionsResponse, error)
	HandoverOtp(ctx context.Context, in *HandoverOtpRequest, opts ...grpc.CallOption) (*HandoverOtpResponse, error)
}

GeneralGoWorkflowsClient is the client API for GeneralGoWorkflows service.

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

func NewGeneralGoWorkflowsClient 

func NewGeneralGoWorkflowsClient(cc grpc.ClientConnInterface) GeneralGoWorkflowsClient

type GeneralGoWorkflowsServer 

type GeneralGoWorkflowsServer interface {
	ExecuteCampaign(context.Context, *ExecuteCampaignRequest) (*ExecuteCampaignResponse, error)
	ExecuteUserJourneyCampaign(context.Context, *ExecuteUserJourneyCampaignRequest) (*ExecuteUserJourneyCampaignResponse, error)
	CreatePartitions(context.Context, *CreatePartitionsRequest) (*CreatePartitionsResponse, error)
	HandoverOtp(context.Context, *HandoverOtpRequest) (*HandoverOtpResponse, error)
}

GeneralGoWorkflowsServer is the server API for GeneralGoWorkflows service.

type HandoverOtpRequest 

type HandoverOtpRequest struct {
	Otp          string            `protobuf:"bytes,1,opt,name=otp,proto3" json:"otp,omitempty"`
	ActorDetails *GoCommon.ActorID `protobuf:"bytes,2,opt,name=actorDetails,proto3" json:"actorDetails,omitempty"`
	MobileNumber string            `protobuf:"bytes,3,opt,name=mobileNumber,proto3" json:"mobileNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*HandoverOtpRequest) Descriptor deprecated 

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

Deprecated: Use HandoverOtpRequest.ProtoReflect.Descriptor instead.

func (*HandoverOtpRequest) GetActorDetails 

func (x *HandoverOtpRequest) GetActorDetails() *GoCommon.ActorID

func (*HandoverOtpRequest) GetMobileNumber 

func (x *HandoverOtpRequest) GetMobileNumber() string

func (*HandoverOtpRequest) GetOtp 

func (x *HandoverOtpRequest) GetOtp() string

func (*HandoverOtpRequest) ProtoMessage 

func (*HandoverOtpRequest) ProtoMessage()

func (*HandoverOtpRequest) ProtoReflect 

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

func (*HandoverOtpRequest) Reset 

func (x *HandoverOtpRequest) Reset()

func (*HandoverOtpRequest) String 

func (x *HandoverOtpRequest) String() string

type HandoverOtpResponse 

type HandoverOtpResponse struct {
	Status GoCommon.ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=farm.nurture.core.contracts.common.ResponseStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*HandoverOtpResponse) Descriptor deprecated 

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

Deprecated: Use HandoverOtpResponse.ProtoReflect.Descriptor instead.

func (*HandoverOtpResponse) GetStatus 

func (x *HandoverOtpResponse) GetStatus() GoCommon.ResponseStatus

func (*HandoverOtpResponse) ProtoMessage 

func (*HandoverOtpResponse) ProtoMessage()

func (*HandoverOtpResponse) ProtoReflect 

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

func (*HandoverOtpResponse) Reset 

func (x *HandoverOtpResponse) Reset()

func (*HandoverOtpResponse) String 

func (x *HandoverOtpResponse) String() string

type UnimplementedGeneralGoWorkflowsServer 

type UnimplementedGeneralGoWorkflowsServer struct {
}

UnimplementedGeneralGoWorkflowsServer can be embedded to have forward compatible implementations.

func (*UnimplementedGeneralGoWorkflowsServer) CreatePartitions 

func (*UnimplementedGeneralGoWorkflowsServer) CreatePartitions(context.Context, *CreatePartitionsRequest) (*CreatePartitionsResponse, error)

func (*UnimplementedGeneralGoWorkflowsServer) ExecuteCampaign 

func (*UnimplementedGeneralGoWorkflowsServer) ExecuteCampaign(context.Context, *ExecuteCampaignRequest) (*ExecuteCampaignResponse, error)

func (*UnimplementedGeneralGoWorkflowsServer) ExecuteUserJourneyCampaign 

func (*UnimplementedGeneralGoWorkflowsServer) ExecuteUserJourneyCampaign(context.Context, *ExecuteUserJourneyCampaignRequest) (*ExecuteUserJourneyCampaignResponse, error)

func (*UnimplementedGeneralGoWorkflowsServer) HandoverOtp 

func (*UnimplementedGeneralGoWorkflowsServer) HandoverOtp(context.Context, *HandoverOtpRequest) (*HandoverOtpResponse, 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.