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 (*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 (*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 (*ExecuteUserJourneyCampaignRequest) GetUnused added in v0.0.4

func (*ExecuteUserJourneyCampaignRequest) GetWaitDuration

func (*ExecuteUserJourneyCampaignRequest) ProtoMessage

func (*ExecuteUserJourneyCampaignRequest) ProtoMessage()

func (*ExecuteUserJourneyCampaignRequest) ProtoReflect

func (*ExecuteUserJourneyCampaignRequest) Reset

func (*ExecuteUserJourneyCampaignRequest) 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 (*ExecuteUserJourneyCampaignResponse) ProtoMessage

func (*ExecuteUserJourneyCampaignResponse) ProtoMessage()

func (*ExecuteUserJourneyCampaignResponse) ProtoReflect

func (*ExecuteUserJourneyCampaignResponse) Reset

func (*ExecuteUserJourneyCampaignResponse) 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.

type GeneralGoWorkflowsServer

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 (*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) ExecuteCampaign

func (*UnimplementedGeneralGoWorkflowsServer) HandoverOtp

Jump to

Keyboard shortcuts

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