Help us shape the future of Go! Take the 2026 Go Developer Survey

bus

package
v0.0.2 Latest Latest
Warning

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

 Go to latest Published: Dec 19, 2025 License: Apache-2.0 Imports: 5 Imported by: 7

Documentation

Index

Constants

View Source 
const MessageBus_BusType_not_set_case case_MessageBus_BusType = 0
View Source 
const MessageBus_InMemory_case case_MessageBus_BusType = 1
View Source 
const MessageBus_Nats_case case_MessageBus_BusType = 3
View Source 
const MessageBus_Redis_case case_MessageBus_BusType = 2

Variables

View Source 
var File_proto_bus_bus_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type InMemoryBus 

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

func (*InMemoryBus) ProtoMessage 

func (*InMemoryBus) ProtoMessage()

func (*InMemoryBus) ProtoReflect 

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

func (*InMemoryBus) Reset 

func (x *InMemoryBus) Reset()

func (*InMemoryBus) String 

func (x *InMemoryBus) String() string

type InMemoryBus_builder 

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

func (InMemoryBus_builder) Build 

func (b0 InMemoryBus_builder) Build() *InMemoryBus

type MessageBus 

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

func (*MessageBus) ClearBusType 

func (x *MessageBus) ClearBusType()

func (*MessageBus) ClearInMemory 

func (x *MessageBus) ClearInMemory()

func (*MessageBus) ClearNats 

func (x *MessageBus) ClearNats()

func (*MessageBus) ClearRedis 

func (x *MessageBus) ClearRedis()

func (*MessageBus) GetInMemory 

func (x *MessageBus) GetInMemory() *InMemoryBus

func (*MessageBus) GetNats 

func (x *MessageBus) GetNats() *NatsBus

func (*MessageBus) GetRedis 

func (x *MessageBus) GetRedis() *RedisBus

func (*MessageBus) HasBusType 

func (x *MessageBus) HasBusType() bool

func (*MessageBus) HasInMemory 

func (x *MessageBus) HasInMemory() bool

func (*MessageBus) HasNats 

func (x *MessageBus) HasNats() bool

func (*MessageBus) HasRedis 

func (x *MessageBus) HasRedis() bool

func (*MessageBus) ProtoMessage 

func (*MessageBus) ProtoMessage()

func (*MessageBus) ProtoReflect 

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

func (*MessageBus) Reset 

func (x *MessageBus) Reset()

func (*MessageBus) SetInMemory 

func (x *MessageBus) SetInMemory(v *InMemoryBus)

func (*MessageBus) SetNats 

func (x *MessageBus) SetNats(v *NatsBus)

func (*MessageBus) SetRedis 

func (x *MessageBus) SetRedis(v *RedisBus)

func (*MessageBus) String 

func (x *MessageBus) String() string

func (*MessageBus) WhichBusType 

func (x *MessageBus) WhichBusType() case_MessageBus_BusType

type MessageBus_builder 

type MessageBus_builder struct {

	// Fields of oneof xxx_hidden_BusType:
	InMemory *InMemoryBus
	Redis    *RedisBus
	Nats     *NatsBus
	// contains filtered or unexported fields
}

func (MessageBus_builder) Build 

func (b0 MessageBus_builder) Build() *MessageBus

type NatsBus 

type NatsBus struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*NatsBus) ClearServerUrl 

func (x *NatsBus) ClearServerUrl()

func (*NatsBus) GetServerUrl 

func (x *NatsBus) GetServerUrl() string

func (*NatsBus) HasServerUrl 

func (x *NatsBus) HasServerUrl() bool

func (*NatsBus) ProtoMessage 

func (*NatsBus) ProtoMessage()

func (*NatsBus) ProtoReflect 

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

func (*NatsBus) Reset 

func (x *NatsBus) Reset()

func (*NatsBus) SetServerUrl 

func (x *NatsBus) SetServerUrl(v string)

func (*NatsBus) String 

func (x *NatsBus) String() string

type NatsBus_builder 

type NatsBus_builder struct {
	ServerUrl *string
	// contains filtered or unexported fields
}

func (NatsBus_builder) Build 

func (b0 NatsBus_builder) Build() *NatsBus

type RedisBus 

type RedisBus struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*RedisBus) ClearAddress 

func (x *RedisBus) ClearAddress()

func (*RedisBus) ClearDb 

func (x *RedisBus) ClearDb()

func (*RedisBus) ClearPassword 

func (x *RedisBus) ClearPassword()

func (*RedisBus) GetAddress 

func (x *RedisBus) GetAddress() string

func (*RedisBus) GetDb 

func (x *RedisBus) GetDb() int32

func (*RedisBus) GetPassword 

func (x *RedisBus) GetPassword() string

func (*RedisBus) HasAddress 

func (x *RedisBus) HasAddress() bool

func (*RedisBus) HasDb 

func (x *RedisBus) HasDb() bool

func (*RedisBus) HasPassword 

func (x *RedisBus) HasPassword() bool

func (*RedisBus) ProtoMessage 

func (*RedisBus) ProtoMessage()

func (*RedisBus) ProtoReflect 

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

func (*RedisBus) Reset 

func (x *RedisBus) Reset()

func (*RedisBus) SetAddress 

func (x *RedisBus) SetAddress(v string)

func (*RedisBus) SetDb 

func (x *RedisBus) SetDb(v int32)

func (*RedisBus) SetPassword 

func (x *RedisBus) SetPassword(v string)

func (*RedisBus) String 

func (x *RedisBus) String() string

type RedisBus_builder 

type RedisBus_builder struct {
	Address  *string
	Db       *int32
	Password *string
	// contains filtered or unexported fields
}

func (RedisBus_builder) Build 

func (b0 RedisBus_builder) Build() *RedisBus

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.